comparison: src/server/httplistener.c
src/server/httplistener.c
- changeset 14
- b8bf95b39952
- parent 13
- 1fdbf4170ef4
- child 15
- cff9c4101dd7
equal
deleted
inserted
replaced
| 13:1fdbf4170ef4 | 14:b8bf95b39952 |
|---|---|
| 1 /* | |
| 2 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER. | |
| 3 * | |
| 4 * Copyright 2011 Olaf Wintermann. All rights reserved. | |
| 5 * | |
| 6 * Redistribution and use in source and binary forms, with or without | |
| 7 * modification, are permitted provided that the following conditions are met: | |
| 8 * | |
| 9 * 1. Redistributions of source code must retain the above copyright | |
| 10 * notice, this list of conditions and the following disclaimer. | |
| 11 * | |
| 12 * 2. Redistributions in binary form must reproduce the above copyright | |
| 13 * notice, this list of conditions and the following disclaimer in the | |
| 14 * documentation and/or other materials provided with the distribution. | |
| 15 * | |
| 16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" | |
| 17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | |
| 18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE | |
| 19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE | |
| 20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR | |
| 21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF | |
| 22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS | |
| 23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN | |
| 24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) | |
| 25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE | |
| 26 * POSSIBILITY OF SUCH DAMAGE. | |
| 27 */ | |
| 28 | |
| 29 #include "nsapi.h" | |
| 30 | |
| 31 #include <stdio.h> | |
| 32 #include <stdlib.h> | |
| 33 #include <fcntl.h> | |
| 34 #include <sys/shm.h> | |
| 35 #include <sys/types.h> | |
| 36 #include <sys/ipc.h> | |
| 37 #include <sys/socket.h> | |
| 38 #include <sys/file.h> | |
| 39 #include <netinet/in.h> | |
| 40 #include <netdb.h> | |
| 41 #include <stdio.h> | |
| 42 #include <stdlib.h> | |
| 43 #include <fcntl.h> | |
| 44 #include <unistd.h> | |
| 45 #include <strings.h> | |
| 46 #include <stdbool.h> | |
| 47 #include <pthread.h> | |
| 48 | |
| 49 #include "map.h" | |
| 50 #include "httplistener.h" | |
| 51 | |
| 52 #include "session.h" | |
| 53 | |
| 54 hashmap_t *listener_map = NULL; | |
| 55 | |
| 56 | |
| 57 int start_all_listener() { | |
| 58 HttpListener *listener = get_http_listener("default"); | |
| 59 http_listener_start(listener); | |
| 60 | |
| 61 return 0; | |
| 62 } | |
| 63 | |
| 64 HttpListener* get_http_listener(char *name) { | |
| 65 return hashmap_get(listener_map, sstr(name)); | |
| 66 } | |
| 67 | |
| 68 | |
| 69 HttpListener* http_listener_new(ListenerConfig *conf) { | |
| 70 HttpListener *listener = malloc(sizeof(HttpListener)); | |
| 71 listener->session_handler = create_basic_session_handler(); | |
| 72 listener->nacceptors = conf->nacceptors; | |
| 73 | |
| 74 struct sockaddr_in servaddr; /* server address */ | |
| 75 | |
| 76 /* init address structure */ | |
| 77 memset(&servaddr, 0, sizeof(servaddr)); | |
| 78 servaddr.sin_family = AF_INET; | |
| 79 servaddr.sin_addr.s_addr = htonl(INADDR_ANY); | |
| 80 servaddr.sin_port = htons(conf->port); | |
| 81 | |
| 82 /* create socket */ | |
| 83 if((listener->server_socket = socket(AF_INET, SOCK_STREAM, 0)) == -1) { | |
| 84 perror("Error: http_listener_new: socket"); | |
| 85 return NULL; | |
| 86 } | |
| 87 | |
| 88 int o = 1; | |
| 89 setsockopt( | |
| 90 listener->server_socket, | |
| 91 SOL_SOCKET, SO_REUSEADDR, | |
| 92 &o, | |
| 93 sizeof(int)); | |
| 94 | |
| 95 /* bind server socket to address */ | |
| 96 if(bind(listener->server_socket, (struct sockaddr*)&servaddr, sizeof(servaddr))){ | |
| 97 perror("Error: http_listener_new: bind"); | |
| 98 return NULL; | |
| 99 } | |
| 100 | |
| 101 /* create acceptors */ | |
| 102 listener->acceptors = calloc(listener->nacceptors, sizeof(void*)); | |
| 103 for (int i=0;i<listener->nacceptors;i++) { | |
| 104 listener->acceptors[i] = acceptor_new(listener); | |
| 105 } | |
| 106 | |
| 107 if(listener_map == NULL) { | |
| 108 listener_map = hashmap_new(8); | |
| 109 } | |
| 110 hashmap_put(listener_map, sstr(conf->name), listener); | |
| 111 return listener; | |
| 112 } | |
| 113 | |
| 114 int http_listener_start(HttpListener *listener) { | |
| 115 printf("INFO: start listener\n"); | |
| 116 | |
| 117 if (listen(listener->server_socket, 16) == -1) { | |
| 118 perror("Error: http_listener_start: listen"); | |
| 119 return -1; | |
| 120 } | |
| 121 | |
| 122 /* start acceptor threads */ | |
| 123 for (int i=0;i<listener->nacceptors;i++) { | |
| 124 acceptor_start(listener->acceptors[i]); | |
| 125 } | |
| 126 } | |
| 127 | |
| 128 | |
| 129 | |
| 130 Acceptor* acceptor_new(HttpListener *listener) { | |
| 131 Acceptor *acceptor = malloc(sizeof(Acceptor)); | |
| 132 acceptor->listener = listener; | |
| 133 return acceptor; | |
| 134 } | |
| 135 | |
| 136 void acceptor_start(Acceptor *a) { | |
| 137 if(pthread_create( | |
| 138 &a->tid, | |
| 139 NULL, | |
| 140 (void*(*)(void*))acceptor_thread, | |
| 141 a) != 0) | |
| 142 { | |
| 143 perror("Error: acceptor_start: pthread_create"); | |
| 144 } | |
| 145 } | |
| 146 | |
| 147 void* acceptor_thread(Acceptor *acceptor) { | |
| 148 HttpListener *listener = acceptor->listener; | |
| 149 | |
| 150 for (;;) { | |
| 151 /* accept connections */ | |
| 152 struct sockaddr_in ca; | |
| 153 socklen_t length = sizeof(ca); | |
| 154 int clientfd; | |
| 155 | |
| 156 /* accept a connection */ | |
| 157 clientfd = accept( | |
| 158 listener->server_socket, | |
| 159 (struct sockaddr*)&ca, | |
| 160 &length); | |
| 161 if (clientfd == -1) { | |
| 162 perror("Error: acceptor_thread: accept"); | |
| 163 continue; | |
| 164 } | |
| 165 | |
| 166 /* create Connection object */ | |
| 167 Connection *conn = malloc(sizeof(Connection)); | |
| 168 conn->address = ca; | |
| 169 conn->fd = clientfd; | |
| 170 | |
| 171 /* enqueue the connection */ | |
| 172 listener->session_handler->enqueue_connection( | |
| 173 listener->session_handler, | |
| 174 conn); | |
| 175 | |
| 176 /* ready for new connection */ | |
| 177 } | |
| 178 } |
