diff options
Diffstat (limited to 'src/microhttpd/daemon.c')
-rw-r--r-- | src/microhttpd/daemon.c | 50 |
1 files changed, 25 insertions, 25 deletions
diff --git a/src/microhttpd/daemon.c b/src/microhttpd/daemon.c index c7ff9040..af77644a 100644 --- a/src/microhttpd/daemon.c +++ b/src/microhttpd/daemon.c | |||
@@ -25,6 +25,7 @@ | |||
25 | * @author Christian Grothoff | 25 | * @author Christian Grothoff |
26 | */ | 26 | */ |
27 | #include "platform.h" | 27 | #include "platform.h" |
28 | #include "platform_interface.h" | ||
28 | #include "internal.h" | 29 | #include "internal.h" |
29 | #include "response.h" | 30 | #include "response.h" |
30 | #include "connection.h" | 31 | #include "connection.h" |
@@ -1052,7 +1053,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1052 | addr, addrlen, | 1053 | addr, addrlen, |
1053 | external_add); | 1054 | external_add); |
1054 | /* all pools are at their connection limit, must refuse */ | 1055 | /* all pools are at their connection limit, must refuse */ |
1055 | if (0 != CLOSE (client_socket)) | 1056 | if (0 != MHD_socket_close_ (client_socket)) |
1056 | MHD_PANIC ("close failed\n"); | 1057 | MHD_PANIC ("close failed\n"); |
1057 | #if ENFILE | 1058 | #if ENFILE |
1058 | errno = ENFILE; | 1059 | errno = ENFILE; |
@@ -1070,7 +1071,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1070 | client_socket, | 1071 | client_socket, |
1071 | FD_SETSIZE); | 1072 | FD_SETSIZE); |
1072 | #endif | 1073 | #endif |
1073 | if (0 != CLOSE (client_socket)) | 1074 | if (0 != MHD_socket_close_ (client_socket)) |
1074 | MHD_PANIC ("close failed\n"); | 1075 | MHD_PANIC ("close failed\n"); |
1075 | #if EINVAL | 1076 | #if EINVAL |
1076 | errno = EINVAL; | 1077 | errno = EINVAL; |
@@ -1093,7 +1094,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1093 | MHD_DLOG (daemon, | 1094 | MHD_DLOG (daemon, |
1094 | "Server reached connection limit (closing inbound connection)\n"); | 1095 | "Server reached connection limit (closing inbound connection)\n"); |
1095 | #endif | 1096 | #endif |
1096 | if (0 != CLOSE (client_socket)) | 1097 | if (0 != MHD_socket_close_ (client_socket)) |
1097 | MHD_PANIC ("close failed\n"); | 1098 | MHD_PANIC ("close failed\n"); |
1098 | #if ENFILE | 1099 | #if ENFILE |
1099 | errno = ENFILE; | 1100 | errno = ENFILE; |
@@ -1111,7 +1112,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1111 | MHD_DLOG (daemon, "Connection rejected, closing connection\n"); | 1112 | MHD_DLOG (daemon, "Connection rejected, closing connection\n"); |
1112 | #endif | 1113 | #endif |
1113 | #endif | 1114 | #endif |
1114 | if (0 != CLOSE (client_socket)) | 1115 | if (0 != MHD_socket_close_ (client_socket)) |
1115 | MHD_PANIC ("close failed\n"); | 1116 | MHD_PANIC ("close failed\n"); |
1116 | MHD_ip_limit_del (daemon, addr, addrlen); | 1117 | MHD_ip_limit_del (daemon, addr, addrlen); |
1117 | #if EACCESS | 1118 | #if EACCESS |
@@ -1138,7 +1139,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1138 | "Error allocating memory: %s\n", | 1139 | "Error allocating memory: %s\n", |
1139 | STRERROR (errno)); | 1140 | STRERROR (errno)); |
1140 | #endif | 1141 | #endif |
1141 | if (0 != CLOSE (client_socket)) | 1142 | if (0 != MHD_socket_close_ (client_socket)) |
1142 | MHD_PANIC ("close failed\n"); | 1143 | MHD_PANIC ("close failed\n"); |
1143 | MHD_ip_limit_del (daemon, addr, addrlen); | 1144 | MHD_ip_limit_del (daemon, addr, addrlen); |
1144 | errno = eno; | 1145 | errno = eno; |
@@ -1153,7 +1154,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1153 | "Error allocating memory: %s\n", | 1154 | "Error allocating memory: %s\n", |
1154 | STRERROR (errno)); | 1155 | STRERROR (errno)); |
1155 | #endif | 1156 | #endif |
1156 | if (0 != CLOSE (client_socket)) | 1157 | if (0 != MHD_socket_close_ (client_socket)) |
1157 | MHD_PANIC ("close failed\n"); | 1158 | MHD_PANIC ("close failed\n"); |
1158 | MHD_ip_limit_del (daemon, addr, addrlen); | 1159 | MHD_ip_limit_del (daemon, addr, addrlen); |
1159 | free (connection); | 1160 | free (connection); |
@@ -1172,7 +1173,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1172 | "Error allocating memory: %s\n", | 1173 | "Error allocating memory: %s\n", |
1173 | STRERROR (errno)); | 1174 | STRERROR (errno)); |
1174 | #endif | 1175 | #endif |
1175 | if (0 != CLOSE (client_socket)) | 1176 | if (0 != MHD_socket_close_ (client_socket)) |
1176 | MHD_PANIC ("close failed\n"); | 1177 | MHD_PANIC ("close failed\n"); |
1177 | MHD_ip_limit_del (daemon, addr, addrlen); | 1178 | MHD_ip_limit_del (daemon, addr, addrlen); |
1178 | MHD_pool_destroy (connection->pool); | 1179 | MHD_pool_destroy (connection->pool); |
@@ -1209,8 +1210,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1209 | { | 1210 | { |
1210 | #if HAVE_MESSAGES | 1211 | #if HAVE_MESSAGES |
1211 | MHD_DLOG (daemon, | 1212 | MHD_DLOG (daemon, |
1212 | "Failed to make socket %d non-blocking: %s\n", | 1213 | "Failed to make socket non-blocking: %s\n", |
1213 | connection->socket_fd, | ||
1214 | STRERROR (errno)); | 1214 | STRERROR (errno)); |
1215 | #endif | 1215 | #endif |
1216 | } | 1216 | } |
@@ -1252,7 +1252,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1252 | "Failed to setup TLS credentials: unknown credential type %d\n", | 1252 | "Failed to setup TLS credentials: unknown credential type %d\n", |
1253 | daemon->cred_type); | 1253 | daemon->cred_type); |
1254 | #endif | 1254 | #endif |
1255 | if (0 != CLOSE (client_socket)) | 1255 | if (0 != MHD_socket_close_ (client_socket)) |
1256 | MHD_PANIC ("close failed\n"); | 1256 | MHD_PANIC ("close failed\n"); |
1257 | MHD_ip_limit_del (daemon, addr, addrlen); | 1257 | MHD_ip_limit_del (daemon, addr, addrlen); |
1258 | free (connection->addr); | 1258 | free (connection->addr); |
@@ -1351,7 +1351,7 @@ internal_add_connection (struct MHD_Daemon *daemon, | |||
1351 | daemon->max_connections--; | 1351 | daemon->max_connections--; |
1352 | return MHD_YES; | 1352 | return MHD_YES; |
1353 | cleanup: | 1353 | cleanup: |
1354 | if (0 != CLOSE (client_socket)) | 1354 | if (0 != MHD_socket_close_ (client_socket)) |
1355 | MHD_PANIC ("close failed\n"); | 1355 | MHD_PANIC ("close failed\n"); |
1356 | MHD_ip_limit_del (daemon, addr, addrlen); | 1356 | MHD_ip_limit_del (daemon, addr, addrlen); |
1357 | if ( (0 != (daemon->options & MHD_USE_THREAD_PER_CONNECTION)) && | 1357 | if ( (0 != (daemon->options & MHD_USE_THREAD_PER_CONNECTION)) && |
@@ -1721,7 +1721,7 @@ MHD_accept_connection (struct MHD_Daemon *daemon) | |||
1721 | #endif | 1721 | #endif |
1722 | if (MHD_INVALID_SOCKET != s) | 1722 | if (MHD_INVALID_SOCKET != s) |
1723 | { | 1723 | { |
1724 | if (0 != CLOSE (s)) | 1724 | if (0 != MHD_socket_close_ (s)) |
1725 | MHD_PANIC ("close failed\n"); | 1725 | MHD_PANIC ("close failed\n"); |
1726 | /* just in case */ | 1726 | /* just in case */ |
1727 | } | 1727 | } |
@@ -1816,7 +1816,7 @@ MHD_cleanup_connections (struct MHD_Daemon *daemon) | |||
1816 | #ifdef WINDOWS | 1816 | #ifdef WINDOWS |
1817 | SHUTDOWN (pos->socket_fd, SHUT_WR); | 1817 | SHUTDOWN (pos->socket_fd, SHUT_WR); |
1818 | #endif | 1818 | #endif |
1819 | if (0 != CLOSE (pos->socket_fd)) | 1819 | if (0 != MHD_socket_close_ (pos->socket_fd)) |
1820 | MHD_PANIC ("close failed\n"); | 1820 | MHD_PANIC ("close failed\n"); |
1821 | } | 1821 | } |
1822 | if (NULL != pos->addr) | 1822 | if (NULL != pos->addr) |
@@ -3530,7 +3530,7 @@ MHD_start_daemon_va (unsigned int flags, | |||
3530 | (unsigned int) port, | 3530 | (unsigned int) port, |
3531 | STRERROR (errno)); | 3531 | STRERROR (errno)); |
3532 | #endif | 3532 | #endif |
3533 | if (0 != CLOSE (socket_fd)) | 3533 | if (0 != MHD_socket_close_ (socket_fd)) |
3534 | MHD_PANIC ("close failed\n"); | 3534 | MHD_PANIC ("close failed\n"); |
3535 | goto free_and_fail; | 3535 | goto free_and_fail; |
3536 | } | 3536 | } |
@@ -3545,7 +3545,7 @@ MHD_start_daemon_va (unsigned int flags, | |||
3545 | "Failed to make listen socket non-blocking: %s\n", | 3545 | "Failed to make listen socket non-blocking: %s\n", |
3546 | STRERROR (errno)); | 3546 | STRERROR (errno)); |
3547 | #endif | 3547 | #endif |
3548 | if (0 != CLOSE (socket_fd)) | 3548 | if (0 != MHD_socket_close_ (socket_fd)) |
3549 | MHD_PANIC ("close failed\n"); | 3549 | MHD_PANIC ("close failed\n"); |
3550 | goto free_and_fail; | 3550 | goto free_and_fail; |
3551 | } | 3551 | } |
@@ -3559,7 +3559,7 @@ MHD_start_daemon_va (unsigned int flags, | |||
3559 | "Failed to listen for connections: %s\n", | 3559 | "Failed to listen for connections: %s\n", |
3560 | STRERROR (errno)); | 3560 | STRERROR (errno)); |
3561 | #endif | 3561 | #endif |
3562 | if (0 != CLOSE (socket_fd)) | 3562 | if (0 != MHD_socket_close_ (socket_fd)) |
3563 | MHD_PANIC ("close failed\n"); | 3563 | MHD_PANIC ("close failed\n"); |
3564 | goto free_and_fail; | 3564 | goto free_and_fail; |
3565 | } | 3565 | } |
@@ -3579,7 +3579,7 @@ MHD_start_daemon_va (unsigned int flags, | |||
3579 | socket_fd, | 3579 | socket_fd, |
3580 | FD_SETSIZE); | 3580 | FD_SETSIZE); |
3581 | #endif | 3581 | #endif |
3582 | if (0 != CLOSE (socket_fd)) | 3582 | if (0 != MHD_socket_close_ (socket_fd)) |
3583 | MHD_PANIC ("close failed\n"); | 3583 | MHD_PANIC ("close failed\n"); |
3584 | goto free_and_fail; | 3584 | goto free_and_fail; |
3585 | } | 3585 | } |
@@ -3592,7 +3592,7 @@ MHD_start_daemon_va (unsigned int flags, | |||
3592 | "MHD failed to initialize IP connection limit mutex\n"); | 3592 | "MHD failed to initialize IP connection limit mutex\n"); |
3593 | #endif | 3593 | #endif |
3594 | if ( (MHD_INVALID_SOCKET != socket_fd) && | 3594 | if ( (MHD_INVALID_SOCKET != socket_fd) && |
3595 | (0 != CLOSE (socket_fd)) ) | 3595 | (0 != MHD_socket_close_ (socket_fd)) ) |
3596 | MHD_PANIC ("close failed\n"); | 3596 | MHD_PANIC ("close failed\n"); |
3597 | goto free_and_fail; | 3597 | goto free_and_fail; |
3598 | } | 3598 | } |
@@ -3604,7 +3604,7 @@ MHD_start_daemon_va (unsigned int flags, | |||
3604 | #endif | 3604 | #endif |
3605 | pthread_mutex_destroy (&daemon->cleanup_connection_mutex); | 3605 | pthread_mutex_destroy (&daemon->cleanup_connection_mutex); |
3606 | if ( (MHD_INVALID_SOCKET != socket_fd) && | 3606 | if ( (MHD_INVALID_SOCKET != socket_fd) && |
3607 | (0 != CLOSE (socket_fd)) ) | 3607 | (0 != MHD_socket_close_ (socket_fd)) ) |
3608 | MHD_PANIC ("close failed\n"); | 3608 | MHD_PANIC ("close failed\n"); |
3609 | goto free_and_fail; | 3609 | goto free_and_fail; |
3610 | } | 3610 | } |
@@ -3618,7 +3618,7 @@ MHD_start_daemon_va (unsigned int flags, | |||
3618 | "Failed to initialize TLS support\n"); | 3618 | "Failed to initialize TLS support\n"); |
3619 | #endif | 3619 | #endif |
3620 | if ( (MHD_INVALID_SOCKET != socket_fd) && | 3620 | if ( (MHD_INVALID_SOCKET != socket_fd) && |
3621 | (0 != CLOSE (socket_fd)) ) | 3621 | (0 != MHD_socket_close_ (socket_fd)) ) |
3622 | MHD_PANIC ("close failed\n"); | 3622 | MHD_PANIC ("close failed\n"); |
3623 | pthread_mutex_destroy (&daemon->cleanup_connection_mutex); | 3623 | pthread_mutex_destroy (&daemon->cleanup_connection_mutex); |
3624 | pthread_mutex_destroy (&daemon->per_ip_connection_mutex); | 3624 | pthread_mutex_destroy (&daemon->per_ip_connection_mutex); |
@@ -3640,7 +3640,7 @@ MHD_start_daemon_va (unsigned int flags, | |||
3640 | pthread_mutex_destroy (&daemon->cleanup_connection_mutex); | 3640 | pthread_mutex_destroy (&daemon->cleanup_connection_mutex); |
3641 | pthread_mutex_destroy (&daemon->per_ip_connection_mutex); | 3641 | pthread_mutex_destroy (&daemon->per_ip_connection_mutex); |
3642 | if ( (MHD_INVALID_SOCKET != socket_fd) && | 3642 | if ( (MHD_INVALID_SOCKET != socket_fd) && |
3643 | (0 != CLOSE (socket_fd)) ) | 3643 | (0 != MHD_socket_close_ (socket_fd)) ) |
3644 | MHD_PANIC ("close failed\n"); | 3644 | MHD_PANIC ("close failed\n"); |
3645 | goto free_and_fail; | 3645 | goto free_and_fail; |
3646 | } | 3646 | } |
@@ -3783,7 +3783,7 @@ thread_failed: | |||
3783 | if (0 == i) | 3783 | if (0 == i) |
3784 | { | 3784 | { |
3785 | if ( (MHD_INVALID_SOCKET != socket_fd) && | 3785 | if ( (MHD_INVALID_SOCKET != socket_fd) && |
3786 | (0 != CLOSE (socket_fd)) ) | 3786 | (0 != MHD_socket_close_ (socket_fd)) ) |
3787 | MHD_PANIC ("close failed\n"); | 3787 | MHD_PANIC ("close failed\n"); |
3788 | pthread_mutex_destroy (&daemon->cleanup_connection_mutex); | 3788 | pthread_mutex_destroy (&daemon->cleanup_connection_mutex); |
3789 | pthread_mutex_destroy (&daemon->per_ip_connection_mutex); | 3789 | pthread_mutex_destroy (&daemon->per_ip_connection_mutex); |
@@ -4001,7 +4001,7 @@ MHD_stop_daemon (struct MHD_Daemon *daemon) | |||
4001 | pthread_mutex_destroy (&daemon->worker_pool[i].cleanup_connection_mutex); | 4001 | pthread_mutex_destroy (&daemon->worker_pool[i].cleanup_connection_mutex); |
4002 | #if EPOLL_SUPPORT | 4002 | #if EPOLL_SUPPORT |
4003 | if ( (-1 != daemon->worker_pool[i].epoll_fd) && | 4003 | if ( (-1 != daemon->worker_pool[i].epoll_fd) && |
4004 | (0 != CLOSE (daemon->worker_pool[i].epoll_fd)) ) | 4004 | (0 != MHD_socket_close_ (daemon->worker_pool[i].epoll_fd)) ) |
4005 | MHD_PANIC ("close failed\n"); | 4005 | MHD_PANIC ("close failed\n"); |
4006 | #endif | 4006 | #endif |
4007 | if ( (MHD_USE_SUSPEND_RESUME == (daemon->options & MHD_USE_SUSPEND_RESUME)) ) | 4007 | if ( (MHD_USE_SUSPEND_RESUME == (daemon->options & MHD_USE_SUSPEND_RESUME)) ) |
@@ -4032,7 +4032,7 @@ MHD_stop_daemon (struct MHD_Daemon *daemon) | |||
4032 | } | 4032 | } |
4033 | close_all_connections (daemon); | 4033 | close_all_connections (daemon); |
4034 | if ( (MHD_INVALID_SOCKET != fd) && | 4034 | if ( (MHD_INVALID_SOCKET != fd) && |
4035 | (0 != CLOSE (fd)) ) | 4035 | (0 != MHD_socket_close_ (fd)) ) |
4036 | MHD_PANIC ("close failed\n"); | 4036 | MHD_PANIC ("close failed\n"); |
4037 | 4037 | ||
4038 | /* TLS clean up */ | 4038 | /* TLS clean up */ |
@@ -4047,7 +4047,7 @@ MHD_stop_daemon (struct MHD_Daemon *daemon) | |||
4047 | #if EPOLL_SUPPORT | 4047 | #if EPOLL_SUPPORT |
4048 | if ( (0 != (daemon->options & MHD_USE_EPOLL_LINUX_ONLY)) && | 4048 | if ( (0 != (daemon->options & MHD_USE_EPOLL_LINUX_ONLY)) && |
4049 | (-1 != daemon->epoll_fd) && | 4049 | (-1 != daemon->epoll_fd) && |
4050 | (0 != CLOSE (daemon->epoll_fd)) ) | 4050 | (0 != MHD_socket_close_ (daemon->epoll_fd)) ) |
4051 | MHD_PANIC ("close failed\n"); | 4051 | MHD_PANIC ("close failed\n"); |
4052 | #endif | 4052 | #endif |
4053 | 4053 | ||