http-server/AllServer/HttpServer.hpp at main · 2iaad/http-server · GitHub

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
#pragma once

#define BACKLOG 128

#include "../ConfigParsing/config.hpp"
#include "../Request/Request.hpp"
#include "../Response/responseHeader.hpp"

class Response;
class Request;

struct EventContext {
    int ident;
    pid_t cgi_pid;
    Request* req;
    Response* res;
    bool is_cgi;
	bool marked_for_deletion;
	bool    cgi_timed_out;
	std::vector<pid_t> registered_procs;
    EventContext() : ident(-1), cgi_pid(0),req(NULL), res(NULL),
                 is_cgi(false), marked_for_deletion(false),
				 cgi_timed_out(false) {}
};

class HttpServer{
	public:
		HttpServer();
		HttpServer(const HttpServer& other);
		~HttpServer();
		void	SetAllContexts(EventContext* ctx);
		void setup_server(std::vector<ConfigNode> ConfigPars);
		void run(std::vector<ConfigNode> ConfigPars);
		void  accept_new_client_fd(int server_fd, std::vector<ConfigNode> ConfigPars);
		void	traiteCgiProcess(std::vector<Response*> all_res, int kq, std::vector<Request*> all_request, std::vector<ConfigNode> ConfigPars, int i);
		void handle_client(int client_fd, struct kevent* event, std::vector<ConfigNode> ConfigPars, std::vector<Request * >& all, std::vector<Response *> & all_res);
		void remove_client(int client_fd);
		void RemoveClient(int client_fd);
		void RemoveReqRes(int client_fd);

		void handle_client_read(EventContext* ctx, Request * request, Response * response);
		void handle_client_write(EventContext* ctx, Request * request, Response * response, std::vector<ConfigNode> ConfigPars);
		void handle_cgi_exit(EventContext* ctx, Request *request, Response *response);
		void handle_cgi_timeout(EventContext* ctx, Request & request, Response & response);
		void AddToKqueue(struct kevent &event, int kq, intptr_t ident, int filter, int flags, void *udata, int fflags, intptr_t data);
		void handle_timeout(EventContext* ctx, Request & request);
		std::vector<EventContext*> all_contexts;
		void FreeContexts();
	private:
		int kq;
   		struct kevent events[BACKLOG];
		std::vector<EventContext*> pending_deletions;
		// int kq;
		std::vector<int> server_fds;
};