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
|
#include <sys/socket.h>
#include <stdio.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <pthread.h>
#include <string.h>
#include "src/i_str.h"
#define max_con 10
#define BUFFER_SIZE 2048
size_t recv_full_buffer(int client_fd, char** _buffer, int* header_eof){
char* buffer = malloc(BUFFER_SIZE * sizeof * buffer);
char* header;
size_t len = 0;
*header_eof = -1;
int n;
for(;;){
n = recv(client_fd, buffer + len, BUFFER_SIZE, 0);
if(*header_eof == -1 && (header = strstr(buffer, "\r\n\r\n")) != NULL){
*header_eof = header - buffer;
}
if(n != BUFFER_SIZE) break;
len += BUFFER_SIZE;
buffer = realloc(buffer, len + BUFFER_SIZE);
}
*_buffer = buffer;
return len + BUFFER_SIZE;
}
void parse_header(char* buffer, int header_eof, str*** _table, int* _len){
char add[] = {0,0};
int lines = 3;
for(int i = 0; i != header_eof; i++) lines += buffer[i] == '\n';
str** table = malloc(sizeof ** table * lines * 2);
table[0] = str_init("Request");// table[1] = str_init("Post|Get");
table[2] = str_init("Path");// table[3] = str_init("/");
table[4] = str_init("Version");// table[5] = str_init("HTTP/1.1");
str* current = str_init("");
int ins = 1;
for(int i = 0; i != header_eof; i++){
add[0] = buffer[i];
if(buffer[i] == '\n') break;
if(buffer[i] == ' '){
table[ins] = str_init(current->c);
ins += 2;
str_clear(current);
} else str_push(current, add);
}
table[ins] = str_init(current->c);
int tlen = 6;
int key = 1;
for(int i = (strstr(buffer,"\n") - buffer) + 1; i != header_eof; i++){
if(key && buffer[i]==':' || !key && buffer[i]=='\n') {
table[tlen] = str_init(current->c);
str_clear(current);
tlen++;
key = !key;
i++;
continue;
}
add[0] = buffer[i];
str_push(current, add);
}
table[tlen] = str_init(current->c);
tlen++;
str_free(current);
*_len = tlen / 2;
*_table = table;
}
void* handle_client(void *arg){
int client_fd = *((int*)arg);
char* buffer;
int header_eof;
size_t bytes_received = recv_full_buffer(client_fd, &buffer, &header_eof);
if(bytes_received > 0){
/*str** table;
int len;
parse_header(buffer, header_eof, &table, &len);
printf("%i\n",len);
for(int i = 0; i != len * 2; i+=2){
printf("%s :: %s\n",table[i]->c, table[i+1]->c);
}*/
}
free(buffer);
return NULL;
}
int main(){
int server_fd;
struct sockaddr_in server_addr;
if((server_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0){
printf("error\n");
abort();
}
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = INADDR_ANY;
server_addr.sin_port = htons(3041);
if(bind(server_fd, (struct sockaddr*)&server_addr, sizeof(server_addr)) < 0){
printf("failed to bind\n");
abort();
}
if(listen(server_fd, max_con) < 0){
printf("failed to listen\n");
abort();
}
for(;;){
struct sockaddr_in client_addr;
socklen_t client_addr_len = sizeof(client_addr);
int* client_fd = malloc(sizeof(int));
if((*client_fd = accept(server_fd, (struct sockaddr*)&client_addr, &client_addr_len)) < 0){
printf("failed to accept\n");
abort();
}
pthread_t thread_id;
pthread_create(&thread_id, NULL, handle_client, (void*)client_fd);
pthread_detach(thread_id);
}
}
|
