comparison: src/server/daemon/httplistener.c
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"); |
