src/server/daemon/httplistener.c

changeset 15
cff9c4101dd7
parent 14
b8bf95b39952
child 19
d680536f8c2f
equal deleted inserted replaced
14:b8bf95b39952 15:cff9c4101dd7
44 #include <unistd.h> 44 #include <unistd.h>
45 #include <strings.h> 45 #include <strings.h>
46 #include <stdbool.h> 46 #include <stdbool.h>
47 #include <pthread.h> 47 #include <pthread.h>
48 48
49 #include "../util/map.h" 49 #include "../ucx/map.h"
50 #include "httplistener.h" 50 #include "httplistener.h"
51 51
52 #include "session.h" 52 #include "session.h"
53 53
54 hashmap_t *listener_map = NULL; 54 UcxMap *listener_map = NULL;
55 55
56 56
57 int start_all_listener() { 57 int start_all_listener() {
58 HttpListener *listener = get_http_listener("default"); 58 HttpListener *listener = get_http_listener("default");
59 http_listener_start(listener); 59 http_listener_start(listener);
60 60
61 return 0; 61 return 0;
62 } 62 }
63 63
64 HttpListener* get_http_listener(char *name) { 64 HttpListener* get_http_listener(char *name) {
65 return hashmap_get(listener_map, sstr(name)); 65 return ucx_map_cstr_get(listener_map, name);
66 } 66 }
67 67
68 68
69 HttpListener* http_listener_new(ListenerConfig *conf) { 69 HttpListener* http_listener_new(ListenerConfig *conf) {
70 HttpListener *listener = malloc(sizeof(HttpListener)); 70 HttpListener *listener = malloc(sizeof(HttpListener));
103 for (int i=0;i<listener->nacceptors;i++) { 103 for (int i=0;i<listener->nacceptors;i++) {
104 listener->acceptors[i] = acceptor_new(listener); 104 listener->acceptors[i] = acceptor_new(listener);
105 } 105 }
106 106
107 if(listener_map == NULL) { 107 if(listener_map == NULL) {
108 listener_map = hashmap_new(8); 108 listener_map = ucx_map_new(8);
109 } 109 }
110 hashmap_put(listener_map, sstr(conf->name), listener); 110 ucx_map_cstr_put(listener_map, conf->name, listener);
111 return listener; 111 return listener;
112 } 112 }
113 113
114 int http_listener_start(HttpListener *listener) { 114 int http_listener_start(HttpListener *listener) {
115 printf("INFO: start listener\n"); 115 printf("INFO: start listener\n");

mercurial