/home/mrjunejune/zenbu: seobeo/s

annotate seobeo/s_web.c @ 17:d97ec3ded2ae

[Seobeo] Few changes... - Fixed seobeo edge for macos - Updated so that socket creation can be used for both client and server - Started on a cutelient library for making connection to the server.

author	June Park <parkjune1995@gmail.com>
date	Sat, 04 Oct 2025 07:53:12 -0700
parents	fb2cff495a60
children	fa2b8af609d9

rev	line source
7 114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	1 #include "seobeo/seobeo.h"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	2
17 d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	3 int Seobeo_Web_GenerateRequestHeader(void buffer, const char host,
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	4 const char *path)
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	5 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	6 return sprintf(
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	7 buffer,
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	8 "GET %s HTTP/1.1\r\n"
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	9 "Host: %s\r\n"
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	10 "Connection: close\r\n"
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	11 "\r\n",
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	12 path, host
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	13 );
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	14 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	15
7 114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	16 void Seobeo_Web_GenerateResponseHeader(void *buffer, int status,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	17 const char *content_type, const int content_length)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	18 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	19 const char *status_text;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	20 switch(status)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	21 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	22 case HTTP_OK: status_text = "OK"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	23 case HTTP_CREATED: status_text = "Created"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	24 case HTTP_MOVED_PERMANENTLY: status_text = "Moved Permanently"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	25 case HTTP_FOUND: status_text = "Found"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	26 case HTTP_BAD_REQUEST: status_text = "Bad Request"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	27 case HTTP_UNAUTHORIZED: status_text = "Unauthorized"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	28 case HTTP_FORBIDDEN: status_text = "Forbidden"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	29 case HTTP_NOT_FOUND: status_text = "Not Found"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	30 case HTTP_INTERNAL_ERROR: status_text = "Internal Server Error"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	31 default: status_text = "Unknown"; break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	32 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	33
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	34 sprintf(
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	35 buffer,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	36 "HTTP/2.2 %d %s\r\n"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	37 "Content-Type: %s\r\n"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	38 "Content-Length: %d\r\n"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	39 "Connection: close\r\n"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	40 "\r\n",
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	41 status, status_text, content_type, content_length
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	42 );
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	43 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	44
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	45 void Seobeo_Web_HandleClientRequest(Seobeo_PHandle p_cli_handle,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	46 Dowa_PHashMap p_html_cache)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	47 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	48 Dowa_PArena p_response_arena = Dowa_Arena_Create(8192);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	49 Dowa_PHashMap p_req_map = NULL;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	50
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	51 Dowa_PHashEntry entry = NULL;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	52 Dowa_PHashMap p_current = p_html_cache;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	53 char *slash;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	54
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	55 if (!p_response_arena) { perror("Dowa_Arena_Initialize"); goto clean_up; }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	56
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	57 void *p_response_header = Dowa_Arena_Allocate(p_response_arena, (size_t)2048);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	58 if (!p_response_header) { perror("Dowa_Arena_Allocate"); goto clean_up; }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	59
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	60 p_req_map = Dowa_HashMap_Create(32);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	61 if (Seobeo_Web_ParseClientHeader(p_cli_handle, p_req_map) != 0)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	62 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	63 // malformed request or closed — respond 400
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	64 Seobeo_Web_GenerateResponseHeader(p_response_header,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	65 HTTP_BAD_REQUEST,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	66 "text/plain", 0);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	67 Seobeo_Handle_Queue(p_cli_handle,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	68 (const uint8*)p_response_header,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	69 (uint32)strlen(p_response_header));
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	70 Seobeo_Handle_Flush(p_cli_handle);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	71 goto clean_up;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	72 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	73
17 d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	74 Dowa_HashMap_Print(p_req_map);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	75
7 114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	76 const char path = (const char)Dowa_HashMap_Get(p_req_map, "Path");
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	77
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	78 char *file_path = Dowa_Arena_Allocate(p_response_arena, (size_t)512);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	79
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	80 if (!path \|\| strcmp(path, "/") == 0)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	81 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	82 strcpy(file_path, "index.html");
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	83 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	84 else
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	85 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	86 size_t L = strlen(path);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	87 // strip leading '/'
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	88 if (path[0] == '/')
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	89 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	90 if (strchr(path, '.') == NULL)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	91 snprintf(file_path, 512, "%.*s/index.html", (int)(L-1), path+1);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	92 else
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	93 snprintf(file_path, 512, "%.*s", (int)(L-1), path+1);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	94 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	95 else
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	96 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	97 // Probably never get here?
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	98 strcpy(file_path, path);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	99 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	100 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	101
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	102 // printf("\n\nfile_path: %s\n", file_path);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	103
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	104 // Recursively go though the path until it gets to a file
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	105 while ((slash = strchr(file_path, '/')))
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	106 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	107 *slash = '\0'; // e.g. file_path="foo", slash+1="index.html"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	108 char *dir = file_path; // "foo"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	109 file_path = slash + 1; // "index.html"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	110
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	111 p_current = Dowa_HashMap_Get(p_current, dir);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	112 if (!p_current) { perror("No value"); goto clean_up; }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	113 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	114
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	115 size_t pos = Dowa_HashMap_GetPosition(p_current, file_path);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	116 entry = p_current->entries[pos];
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	117
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	118 // Missing so 404
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	119 if (!entry)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	120 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	121 Seobeo_Web_GenerateResponseHeader(p_response_header,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	122 HTTP_NOT_FOUND,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	123 "text/html", 0);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	124 Seobeo_Handle_Queue(p_cli_handle,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	125 (const uint8*)p_response_header,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	126 (uint32)strlen(p_response_header));
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	127 Seobeo_Handle_Flush(p_cli_handle);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	128 goto clean_up;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	129 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	130
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	131
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	132 const char *mime = "application/octet-stream"; // Default binary
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	133 if (strstr(file_path, ".html")) mime = "text/html; charset=utf-8";
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	134 else if (strstr(file_path, ".css")) mime = "text/css";
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	135 else if (strstr(file_path, ".js")) mime = "application/javascript";
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	136 else if (strstr(file_path, ".png")) mime = "image/png";
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	137 else if (strstr(file_path, ".jpg") \|\| strstr(file_path, ".jpeg")) mime = "image/jpeg";
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	138 else if (strstr(file_path, ".gif")) mime = "image/gif";
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	139 else if (strstr(file_path, ".svg")) mime = "image/svg+xml";
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	140 else if (strstr(file_path, ".ico")) mime = "image/x-icon";
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	141 else if (strstr(file_path, ".json")) mime = "application/json";
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	142
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	143 size_t body_size = entry->capacity;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	144 Seobeo_Web_GenerateResponseHeader(p_response_header,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	145 HTTP_OK,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	146 mime,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	147 body_size);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	148 Seobeo_Handle_Queue(p_cli_handle,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	149 (const uint8*)p_response_header,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	150 (uint32)strlen(p_response_header));
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	151 Seobeo_Handle_Queue(p_cli_handle,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	152 (const uint8*)entry->buffer,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	153 (uint32)body_size);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	154 Seobeo_Handle_Flush(p_cli_handle);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	155
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	156 clean_up:
16 fb2cff495a60 [Seobeo] Fixed the problem with edge server. June Park <parkjune1995@gmail.com> parents: 7 diff changeset	157 if (p_cli_handle)
fb2cff495a60 [Seobeo] Fixed the problem with edge server. June Park <parkjune1995@gmail.com> parents: 7 diff changeset	158 Seobeo_Handle_Destroy(p_cli_handle);
fb2cff495a60 [Seobeo] Fixed the problem with edge server. June Park <parkjune1995@gmail.com> parents: 7 diff changeset	159 if (p_response_arena)
fb2cff495a60 [Seobeo] Fixed the problem with edge server. June Park <parkjune1995@gmail.com> parents: 7 diff changeset	160 Dowa_Arena_Free(p_response_arena);
fb2cff495a60 [Seobeo] Fixed the problem with edge server. June Park <parkjune1995@gmail.com> parents: 7 diff changeset	161 if (p_req_map)
fb2cff495a60 [Seobeo] Fixed the problem with edge server. June Park <parkjune1995@gmail.com> parents: 7 diff changeset	162 Dowa_HashMap_Free(p_req_map); // TODO: Maybe initilized hashmap within the Arena?
7 114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	163 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	164
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	165 int Seobeo_Web_ParseClientHeader(Seobeo_PHandle p_handle, Dowa_PHashMap map)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	166 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	167 // 1) Fill read_buffer until we see "\r\n\r\n"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	168 while (1)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	169 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	170 int r = Seobeo_Handle_Read(p_handle);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	171 if (r < 0) return -1; // fatal error
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	172 if (r == -2) return -2; // connection closed TODO: Add this as part of Handle struct.
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	173
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	174 if (p_handle->read_buffer_len >= 4 &&
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	175 strstr((char*)p_handle->read_buffer, "\r\n\r\n") != NULL)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	176 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	177 break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	178 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	179 if (r == 0) return 1; // EAGAIN, try again later TODO: Add this as part of Handle struct.
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	180 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	181
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	182 // 2) Parse request‐line "METHOD SP PATH SP VERSION CRLF"
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	183 char buf = (char)p_handle->read_buffer;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	184 char *hdr_end = strstr(buf, "\r\n\r\n");
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	185 size_t hdr_len = hdr_end - buf + 4;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	186
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	187 char method[16], path[256], version[16];
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	188 if (sscanf(buf, "%15s %255s %15s", method, path, version) != 3)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	189 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	190 return -1;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	191 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	192
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	193 Dowa_HashMap_PushValueWithType(map, "Method", method, strlen(method) + 1, DOWA_HASH_MAP_TYPE_STRING);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	194 Dowa_HashMap_PushValueWithType(map, "Path", path, strlen(path) + 1, DOWA_HASH_MAP_TYPE_STRING);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	195 Dowa_HashMap_PushValueWithType(map, "Version", version, strlen(version) + 1, DOWA_HASH_MAP_TYPE_STRING);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	196
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	197 // 3) Parse each header line until the blank line
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	198 char *line = buf + strlen(method) + 1 + strlen(path) + 1 + strlen(version) + 2;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	199 while (line < hdr_end)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	200 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	201 char *next = strstr(line, "\r\n");
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	202 if (!next) break;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	203
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	204 // split at colon
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	205 char *colon = memchr(line, ':', next - line);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	206 if (colon) {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	207 size_t key_len = colon - line;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	208 size_t value_len = next - colon - 1;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	209
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	210 char *val_start = colon + 1;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	211 if (*val_start == ' ')
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	212 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	213 val_start++;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	214 value_len--;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	215 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	216
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	217 char *key = malloc(key_len + 1);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	218 memcpy(key, line, key_len);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	219 key[key_len] = '\0';
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	220
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	221 char *val = malloc(value_len + 1);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	222 memcpy(val, val_start, value_len);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	223 val[value_len] = '\0';
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	224
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	225 Dowa_HashMap_PushValue(map, key, val, value_len + 1);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	226
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	227 free(key);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	228 free(val);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	229 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	230
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	231 line = next + 2;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	232 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	233 Seobeo_Handle_Consume(p_handle, (uint32)hdr_len);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	234
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	235 // 4) If Content-Length was provided, read that much body
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	236 int content_length_pos = Dowa_HashMap_GetPosition(map, "Content-Length");
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	237 Dowa_PHashEntry p_content_length_entry = map->entries[content_length_pos];
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	238 if (p_content_length_entry)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	239 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	240 size_t body_len = atoi((char*)p_content_length_entry->buffer);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	241 while (p_handle->read_buffer_len < body_len)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	242 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	243 int r = Seobeo_Handle_Read(p_handle);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	244 if (r < 0) return -1;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	245 if (r == 0) return 1; // wait for more data
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	246 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	247
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	248 char *body = malloc(body_len + 1);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	249 memcpy(body, p_handle->read_buffer, body_len);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	250 body[body_len] = '\0';
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	251
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	252 Dowa_HashMap_PushValue(map, "Body", body, body_len + 1);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	253 free(body);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	254
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	255 Seobeo_Handle_Consume(p_handle, (uint32)body_len);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	256 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	257
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	258 return 0; // success; map now holds Method, Path, Version, headers, and optional Body
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	259 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	260
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	261 // TODO: Do epoll or kqueue depending on the OS.
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	262 void SigchildHandler(int s)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	263 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	264 (void)s; // quiet unused variable warning
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	265
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	266 // waitpid() might overwrite errno, so we save and restore it:
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	267 int saved_errno = errno;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	268
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	269 while(waitpid(-1, NULL, WNOHANG) > 0);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	270
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	271 errno = saved_errno;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	272 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	273
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	274 int Seobeo_Web_StartBasicHTTPServer(
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	275 const char *folder_path,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	276 const char *port,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	277 Seobeo_ServerMode mode,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	278 int thread_count)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	279 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	280 Dowa_PHashMap p_html_cache = Dowa_HashMap_Create(1024);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	281 if (Dowa_HashMap_Cache_Folder(p_html_cache,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	282 folder_path) != 0)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	283 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	284 perror("Dowa_Cache_Folder");
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	285 return -1;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	286 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	287
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	288 Seobeo_PHandle p_server_handle =
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	289 Seobeo_Stream_Handle_Create(NULL, port);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	290 if (p_server_handle->socket < 0) return 1;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	291 printf("Listening on port %s\n", port);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	292
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	293 // Fork‐based fallback
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	294 if (mode == SEOBEO_MODE_FORK)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	295 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	296 struct sigaction sa;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	297 sa.sa_handler = SigchildHandler;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	298 sigemptyset(&sa.sa_mask);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	299 sa.sa_flags = SA_RESTART;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	300 sigaction(SIGCHLD, &sa, NULL);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	301
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	302 while (1) {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	303 Seobeo_PHandle cli =
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	304 Seobeo_Stream_Handle_Accept(p_server_handle);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	305 if (!cli) continue;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	306
16 fb2cff495a60 [Seobeo] Fixed the problem with edge server. June Park <parkjune1995@gmail.com> parents: 7 diff changeset	307 if (fork() == 0)
fb2cff495a60 [Seobeo] Fixed the problem with edge server. June Park <parkjune1995@gmail.com> parents: 7 diff changeset	308 {
7 114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	309 Seobeo_Web_HandleClientRequest(cli,
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	310 p_html_cache);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	311 _exit(0);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	312 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	313 Seobeo_Handle_Destroy(cli);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	314 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	315 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	316
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	317 if (mode == SEOBEO_MODE_EDGE)
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	318 {
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	319 Seobeo_Web_Edge(p_server_handle, thread_count, p_html_cache);
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	320 }
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	321
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	322 return -1;
114cad94008f [Seobeo] Updated to support thread and edge server calls. June Park <parkjune1995@gmail.com> parents: diff changeset	323 }
17 d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	324
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	325
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	326 int Seobeo_Web_ClientGet(const char *host,
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	327 const char *port,
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	328 const char *path)
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	329 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	330 Seobeo_PHandle h = Seobeo_Stream_Handle_Create(host, port);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	331 if (!h \|\| h->socket < 0)
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	332 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	333 if (h) Seobeo_Handle_Destroy(h);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	334 return -1;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	335 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	336
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	337 Dowa_PArena p_request_arena = Dowa_Arena_Create(1 * 1024 * 1024);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	338 if (!p_request_arena)
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	339 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	340 perror("Dowa_Arena_Create");
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	341 return -1;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	342 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	343 void *p_request_header = Dowa_Arena_Allocate(p_request_arena, 4096);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	344 if (!p_request_header)
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	345 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	346 perror("Dowa_Arena_Allocate");
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	347 return -1;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	348 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	349
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	350 int request_len = Seobeo_Web_GenerateRequestHeader(p_request_header, host, path);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	351 printf("request: %s\n", (char *)p_request_header);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	352 Seobeo_Handle_Queue(h, (uint8 *)p_request_header, (uint32)request_len);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	353
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	354 if (Seobeo_Handle_Flush(h) < 0)
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	355 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	356 perror("Seobeo_Handle_Flush");
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	357 Seobeo_Handle_Destroy(h);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	358 return -1;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	359 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	360
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	361 size_t cap = 1024*8, used = 0;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	362 char *p_request_body = Dowa_Arena_Allocate(p_request_arena, cap);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	363 if (!p_request_body) { Seobeo_Handle_Destroy(h); return -1; }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	364
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	365 while (1) {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	366 int n = Seobeo_Handle_Read(h);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	367 if (n > 0)
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	368 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	369 memcpy(p_request_body + used, h->read_buffer, h->read_buffer_len);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	370 used += h->read_buffer_len;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	371 Seobeo_Handle_Consume(h, (uint32)h->read_buffer_len);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	372 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	373 else if (n == 0)
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	374 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	375 // non-blocking mode and no data right now → keep looping or break?
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	376 // For a simple blocking client, you could block instead:
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	377 continue;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	378 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	379 else if (n == -2)
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	380 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	381 // peer closed; we’ve got everything
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	382 break;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	383 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	384 else
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	385 {
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	386 Dowa_Arena_Free(p_request_arena);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	387 Seobeo_Handle_Destroy(h);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	388 return -1;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	389 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	390 }
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	391
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	392 printf("%s\n\n", p_request_body);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	393 Dowa_Arena_Free(p_request_arena);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	394 Seobeo_Handle_Destroy(h);
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	395 return 0;
d97ec3ded2ae [Seobeo] Few changes... June Park <parkjune1995@gmail.com> parents: 16 diff changeset	396 }

Mercurial

annotate seobeo/s_web.c @ 17:d97ec3ded2ae