From 6ea7f7e0961d05c5f0d995eecc785d1fd1e96b6f Mon Sep 17 00:00:00 2001 From: snowdrop Date: Tue, 14 Sep 2004 17:34:36 +0000 Subject: fixed: select() function in http_run() --- nanohttp/nanohttp-server.c | 75 ++++++++++++++++++++-------------------------- 1 file changed, 33 insertions(+), 42 deletions(-) diff --git a/nanohttp/nanohttp-server.c b/nanohttp/nanohttp-server.c index 3136652..f6f2288 100644 --- a/nanohttp/nanohttp-server.c +++ b/nanohttp/nanohttp-server.c @@ -1,5 +1,5 @@ /****************************************************************** -* $Id: nanohttp-server.c,v 1.23 2004/09/14 15:50:54 snowdrop Exp $ +* $Id: nanohttp-server.c,v 1.24 2004/09/14 17:34:36 snowdrop Exp $ * * CSOAP Project: A http client/server library in C * Copyright (C) 2003 Ferhat Ayaz @@ -508,33 +508,6 @@ void _httpd_start_thread(conndata_t* conn) } -/* - * ----------------------------------------------------- - * FUNCTION: _httpd_select - * Returns 0 if success != otherwise - * ----------------------------------------------------- - */ -static -int _httpd_select(fd_set *pfds) -{ - int err; - struct timeval timeout; - - timeout.tv_sec = 1; - timeout.tv_usec = 0; - -#ifndef WIN32 - select (1, pfds, NULL, NULL, &timeout); -#else - if (select (1, pfds, NULL, NULL, &timeout) == SOCKET_ERROR) - { - err = WSAGetLastError (); - log_error1 ("select error"); - return 1; - } -#endif - return 0; -} /* * ----------------------------------------------------- @@ -548,9 +521,13 @@ httpd_run () int err; conndata_t *conn; fd_set fds; + struct timeval timeout; log_verbose1 ("starting run routine"); + timeout.tv_sec = 1; + timeout.tv_usec = 0; + /* listen to port */ err = hsocket_listen (_httpd_socket, 15); if (err != HSOCKET_OK) @@ -571,9 +548,6 @@ httpd_run () return err; } - /* zero file descriptior */ - FD_ZERO (&fds); - FD_SET (_httpd_socket, &fds); while (_httpd_run) { @@ -581,19 +555,36 @@ httpd_run () conn = _httpd_wait_for_empty_conn(); if (!_httpd_run) break; - /* Select file descriptor */ - if (_httpd_select(&fds)) - { - log_error1("Can not select!"); - return -1; - } - + /* Wait for a socket to accept */ - while (_httpd_run && (!FD_ISSET (_httpd_socket, &fds))); + while (_httpd_run) + { + /* zero and set file descriptior */ + FD_ZERO (&fds); + FD_SET (_httpd_socket, &fds); + + /* select socket descriptor */ + switch (select(_httpd_socket+1, &fds, NULL, NULL, &timeout)) + { + case 0: + /* descriptor is not ready */ + continue; + case -1: + /* got a signal? */ + continue; + default: + /* no nothing */ + break; + } + if (FD_ISSET (_httpd_socket, &fds)) { + break; + } + } - if (!_httpd_run) - break; - + /* check signal status*/ + if (!_httpd_run) + break; + /* Accept a socket */ err = hsocket_accept(_httpd_socket, &(conn->sock)); if (err != HSOCKET_OK) -- cgit v1.1-32-gdbae