1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
|
#ifndef API_H
#define API_H
#define API_REQ_PADSTART (2048)
#define API_REQ_LIST_MAX 1024
#define API_ZSTD_LVL (2)
struct apiCon {
int fd;
int accept;
struct char_buffer reply;
size_t bytesSent;
uint32_t events;
int open;
int wakeups;
int keepalive;
int http_minor_version;
int include_version;
struct char_buffer request;
int64_t lastReset; // milliseconds
char *content_type;
};
struct apiCircle {
double lat;
double lon;
double radius; // in meters
bool onlyClosest;
};
struct apiOptions {
int64_t request_received; // microseconds
int64_t request_processed; // microseconds
double box[4];
struct apiCircle circle;
int is_box;
int is_circle;
int is_hexList;
int is_callsignList;
int is_regList;
int is_typeList;
int include_no_position;
int filter_typeList;
int closest;
int all;
int all_with_pos;
int jamesv2;
int filter_squawk;
int binCraft;
int zstd;
int zstd_encode;
unsigned squawk;
int filter_dbFlag;
int filter_mil;
int filter_interesting;
int filter_pia;
int filter_ladd;
int filter_with_pos;
int filter_callsign_exact;
char callsign_exact[9];
int filter_callsign_prefix;
char callsign_prefix[9];
int32_t filter_alt_baro;
int32_t above_alt_baro;
int32_t below_alt_baro;
int hexCount;
uint32_t hexList[API_REQ_LIST_MAX];
int callsignCount;
char callsignList[API_REQ_LIST_MAX * memberSize(struct binCraft, callsign) + 1];
int regCount;
char regList[API_REQ_LIST_MAX * memberSize(struct binCraft, registration) + 1];
int typeCount;
char typeList[API_REQ_LIST_MAX * memberSize(struct binCraft, typeCode) + 1];
};
struct offset {
int32_t offset;
int32_t len;
};
struct apiEntry {
struct offset jsonOffset;
struct binCraft bin;
struct apiEntry *nextHex;
struct apiEntry *nextReg;
struct apiEntry *nextCallsign;
float distance;
float direction;
int32_t globe_index;
};
struct range {
int from; // inclusive
int to; // exclusive
};
struct apiBuffer {
int len;
int len_flag;
int alloc;
int jsonLen;
char *json;
struct apiEntry *list;
struct apiEntry *list_flag;
struct range list_pos_range;
struct range list_flag_pos_range;
int64_t timestamp;
int hashBuckets;
int hashBits;
struct apiEntry **hexHash;
struct apiEntry **regHash;
struct apiEntry **callsignHash;
uint32_t focus;
int aircraftJsonCount;
};
struct apiThread {
pthread_t thread;
int index;
int epfd;
int eventfd;
int responseBytesBuffered;
uint32_t requestCount;
int conCount;
int stackCount;
struct apiCon *cons;
struct apiCon **stack;
ZSTD_CCtx* cctx;
// for producing average request len numbers
int64_t request_len_sum;
int64_t request_count;
int64_t next_bounce;
int64_t antiSpam[16];
};
void apiBufferInit();
void apiBufferCleanup();
void apiInit();
void apiCleanup();
struct char_buffer apiGenerateAircraftJson(threadpool_buffer_t *pbuffer);
struct char_buffer apiGenerateGlobeJson(int globe_index, threadpool_buffer_t *pbuffer);
#endif
|
