blob: f663be4a1d28eec1279ae90cc8798bd642762782 (
plain)
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
|
#ifdef NETDATA_WITH_ZLIB
#include <zlib.h>
#endif
#include <sys/time.h>
#include <string.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include "web_buffer.h"
#include "dictionary.h"
#define DEFAULT_DISCONNECT_IDLE_WEB_CLIENTS_AFTER_SECONDS 60
extern int web_client_timeout;
extern int web_enable_gzip;
#ifndef NETDATA_WEB_CLIENT_H
#define NETDATA_WEB_CLIENT_H 1
#define WEB_CLIENT_MODE_NORMAL 0
#define WEB_CLIENT_MODE_FILECOPY 1
#define WEB_CLIENT_MODE_OPTIONS 2
#define URL_MAX 8192
#define ZLIB_CHUNK 16384
#define HTTP_RESPONSE_HEADER_SIZE 4096
#define COOKIE_MAX 1024
#define ORIGIN_MAX 1024
struct response {
BUFFER *header; // our response header
BUFFER *header_output; // internal use
BUFFER *data; // our response data buffer
int code; // the HTTP response code
size_t rlen; // if non-zero, the excepted size of ifd (input)
size_t sent; // current data length sent to output
int zoutput; // if set to 1, web_client_send() will send compressed data
#ifdef NETDATA_WITH_ZLIB
z_stream zstream; // zlib stream for sending compressed output to client
Bytef zbuffer[ZLIB_CHUNK]; // temporary buffer for storing compressed output
long zsent; // the compressed bytes we have sent to the client
long zhave; // the compressed bytes that we have to send
int zinitialized;
#endif
};
struct web_client {
unsigned long long id;
char client_ip[NI_MAXHOST+1];
char client_port[NI_MAXSERV+1];
char last_url[URL_MAX+1];
struct timeval tv_in, tv_ready;
char cookie1[COOKIE_MAX+1];
char cookie2[COOKIE_MAX+1];
char origin[ORIGIN_MAX+1];
int mode;
int keepalive;
int enable_gzip;
char *decoded_url;
struct sockaddr_storage clientaddr;
pthread_t thread; // the thread servicing this client
int obsolete; // if set to 1, the listener will remove this client
int ifd;
int ofd;
struct response response;
int wait_receive;
int wait_send;
struct web_client *prev;
struct web_client *next;
};
extern struct web_client *web_clients;
extern uid_t web_files_uid(void);
extern uid_t web_files_gid(void);
extern struct web_client *web_client_create(int listener);
extern struct web_client *web_client_free(struct web_client *w);
extern void *web_client_main(void *ptr);
#endif
|
