249 perror("Error: acceptor_start: pthread_create"); |
249 perror("Error: acceptor_start: pthread_create"); |
250 } |
250 } |
251 } |
251 } |
252 |
252 |
253 void* acceptor_thread(Acceptor *acceptor) { |
253 void* acceptor_thread(Acceptor *acceptor) { |
|
254 WS_ASSERT(acceptor); |
|
255 WS_ASSERT(acceptor->listener); |
|
256 WS_ASSERT(acceptor->listener->session_handler); |
|
257 WS_ASSERT(acceptor->listener->session_handler->enqueue_connection); |
|
258 |
254 HttpListener *listener = acceptor->listener; |
259 HttpListener *listener = acceptor->listener; |
255 |
260 |
256 for (;;) { |
261 for (;;) { |
257 /* accept connections */ |
262 /* accept connections */ |
258 struct sockaddr_in ca; |
263 struct sockaddr_in ca; |