[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[GNUnet-SVN] r38118 - libmicrohttpd/src/microhttpd
From: |
gnunet |
Subject: |
[GNUnet-SVN] r38118 - libmicrohttpd/src/microhttpd |
Date: |
Tue, 11 Oct 2016 17:21:23 +0200 |
Author: Karlson2k
Date: 2016-10-11 17:21:23 +0200 (Tue, 11 Oct 2016)
New Revision: 38118
Modified:
libmicrohttpd/src/microhttpd/connection.c
libmicrohttpd/src/microhttpd/daemon.c
libmicrohttpd/src/microhttpd/mhd_itc.h
Log:
Renamed 'MHD_INVALID_PIPE_' -> 'MHD_ITC_IS_INVALID_', added 'MHD_ITC_IS_VALID_'
Modified: libmicrohttpd/src/microhttpd/connection.c
===================================================================
--- libmicrohttpd/src/microhttpd/connection.c 2016-10-11 15:21:20 UTC (rev
38117)
+++ libmicrohttpd/src/microhttpd/connection.c 2016-10-11 15:21:23 UTC (rev
38118)
@@ -521,7 +521,7 @@
thread-per-connection mode, signal the main thread
to resume accepting connections */
if ( (0 != (daemon->options & MHD_USE_THREAD_PER_CONNECTION)) &&
- (! MHD_INVALID_PIPE_ (daemon->itc)) &&
+ (MHD_ITC_IS_VALID_ (daemon->itc)) &&
(! MHD_itc_activate_ (daemon->itc, "c")) )
{
#ifdef HAVE_MESSAGES
Modified: libmicrohttpd/src/microhttpd/daemon.c
===================================================================
--- libmicrohttpd/src/microhttpd/daemon.c 2016-10-11 15:21:20 UTC (rev
38117)
+++ libmicrohttpd/src/microhttpd/daemon.c 2016-10-11 15:21:23 UTC (rev
38118)
@@ -1374,7 +1374,7 @@
goto exit;
}
#if WINDOWS
- if (! MHD_INVALID_PIPE_(daemon->itc) )
+ if (MHD_ITC_IS_VALID_(daemon->itc) )
{
if (! MHD_add_to_fd_set_ (MHD_itc_r_fd_ (daemon->itc),
&rs,
@@ -1413,7 +1413,7 @@
}
#if WINDOWS
/* drain signaling pipe before other processing */
- if ( (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ if ( (MHD_ITC_IS_VALID_(daemon->itc)) &&
(FD_ISSET (MHD_itc_r_fd_ (daemon->itc),
&rs)) )
MHD_itc_clear_ (daemon->itc);
@@ -1458,7 +1458,7 @@
}
#if WINDOWS
extra_slot = 0;
- if (! MHD_INVALID_PIPE_(daemon->itc))
+ if (MHD_ITC_IS_VALID_(daemon->itc))
{
p[1].events |= POLLIN;
p[1].fd = MHD_itc_r_fd_ (daemon->itc);
@@ -1485,7 +1485,7 @@
}
#if WINDOWS
/* drain signaling pipe before other processing */
- if ( (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ if ( (MHD_ITC_IS_VALID_(daemon->itc)) &&
(0 != (p[1].revents & (POLLERR | POLLHUP | POLLIN))) )
MHD_itc_clear_ (daemon->itc);
#endif
@@ -2028,7 +2028,7 @@
}
else
if ( (MHD_YES == external_add) &&
- (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ (MHD_ITC_IS_VALID_(daemon->itc)) &&
(! MHD_itc_activate_ (daemon->itc, "n")) )
{
#ifdef HAVE_MESSAGES
@@ -2209,7 +2209,7 @@
MHD_mutex_lock_chk_ (&daemon->cleanup_connection_mutex);
connection->resuming = MHD_YES;
daemon->resuming = MHD_YES;
- if ( (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ if ( (MHD_ITC_IS_VALID_(daemon->itc)) &&
(! MHD_itc_activate_ (daemon->itc, "r")) )
{
#ifdef HAVE_MESSAGES
@@ -2704,7 +2704,7 @@
/* drain signaling pipe to avoid spinning select */
/* Do it before any other processing so new signals
will trigger select again and will be processed */
- if ( (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ if ( (MHD_ITC_IS_VALID_(daemon->itc)) &&
(FD_ISSET (MHD_itc_r_fd_ (daemon->itc),
read_fd_set)) )
MHD_itc_clear_ (daemon->itc);
@@ -2840,7 +2840,7 @@
return MHD_NO;
}
}
- if ( (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ if ( (MHD_ITC_IS_VALID_(daemon->itc)) &&
(! MHD_add_to_fd_set_ (MHD_itc_r_fd_ (daemon->itc),
&rs,
&maxsock,
@@ -2877,7 +2877,7 @@
only do this optimization if we have a signaling pipe in
place. */
if ( (MHD_INVALID_SOCKET != daemon->socket_fd) &&
- (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ (MHD_ITC_IS_VALID_(daemon->itc)) &&
(0 != (daemon->options & MHD_USE_PIPE_FOR_SHUTDOWN)) &&
( (daemon->connections == daemon->connection_limit) ||
(MHD_YES == daemon->at_limit) ) )
@@ -3002,7 +3002,7 @@
poll_server++;
}
poll_pipe = -1;
- if (! MHD_INVALID_PIPE_(daemon->itc))
+ if (MHD_ITC_IS_VALID_(daemon->itc))
{
p[poll_server].fd = MHD_itc_r_fd_ (daemon->itc);
p[poll_server].events = POLLIN;
@@ -3183,7 +3183,7 @@
poll_listen = poll_count;
poll_count++;
}
- if (! MHD_INVALID_PIPE_(daemon->itc))
+ if (MHD_ITC_IS_VALID_(daemon->itc))
{
p[poll_count].fd = MHD_itc_r_fd_ (daemon->itc);
p[poll_count].events = POLLIN;
@@ -3492,7 +3492,7 @@
pointer with the same numeric value as the itc.fd[0] can
be expected to be rare... FIXME (a construction similar
to what we did with the `upgrade_marker` should do) */
- if ( (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ if ( (MHD_ITC_IS_VALID_(daemon->itc)) &&
(MHD_itc_r_fd_ (daemon->itc) == events[i].data.fd) )
{
/* It's OK to drain pipe here as all external
@@ -3760,7 +3760,7 @@
ret = daemon->socket_fd;
if (MHD_INVALID_SOCKET == ret)
return MHD_INVALID_SOCKET;
- if ( (MHD_INVALID_PIPE_(daemon->itc)) &&
+ if ( (MHD_ITC_IS_INVALID_(daemon->itc)) &&
(0 != (daemon->options & (MHD_USE_SELECT_INTERNALLY |
MHD_USE_THREAD_PER_CONNECTION))) )
{
#ifdef HAVE_MESSAGES
@@ -3788,7 +3788,7 @@
}
else
#endif
- if (! MHD_INVALID_PIPE_(daemon->worker_pool[i].itc))
+ if (MHD_ITC_IS_VALID_(daemon->worker_pool[i].itc))
{
if (! MHD_itc_activate_ (daemon->worker_pool[i].itc, "q"))
MHD_PANIC (_("Failed to signal quiesce via pipe"));
@@ -3809,7 +3809,7 @@
}
else
#endif
- if (! MHD_INVALID_PIPE_(daemon->itc))
+ if (MHD_ITC_IS_VALID_(daemon->itc))
{
if (! MHD_itc_activate_ (daemon->itc, "q"))
MHD_PANIC (_("failed to signal quiesce via pipe"));
@@ -4322,7 +4322,7 @@
#endif
return MHD_NO;
}
- if ( (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ if ( (MHD_ITC_IS_VALID_(daemon->itc)) &&
(MHD_USE_SUSPEND_RESUME == (daemon->options & MHD_USE_SUSPEND_RESUME)) )
{
event.events = EPOLLIN | EPOLLET;
@@ -5111,7 +5111,7 @@
if (0 != (flags & MHD_USE_SSL))
gnutls_priority_deinit (daemon->priority_cache);
#endif
- if (! MHD_INVALID_PIPE_(daemon->itc))
+ if (MHD_ITC_IS_VALID_(daemon->itc))
MHD_itc_destroy_chk_ (daemon->itc);
free (daemon);
return NULL;
@@ -5179,7 +5179,7 @@
shutdown (pos->socket_fd, SHUT_RDWR);
#if MHD_WINSOCK_SOCKETS
if ( (0 != (daemon->options & MHD_USE_THREAD_PER_CONNECTION)) &&
- (! MHD_INVALID_PIPE_(daemon->itc)) &&
+ (MHD_ITC_IS_VALID_(daemon->itc)) &&
(! MHD_itc_activate_ (daemon->itc, "e")) )
MHD_PANIC (_("Failed to signal shutdown via pipe"));
#endif
@@ -5229,7 +5229,7 @@
{
struct epoll_event event;
- if (MHD_INVALID_PIPE_(daemon->itc))
+ if (MHD_ITC_IS_INVALID_(daemon->itc))
{
/* itc was required in this mode, how could this happen? */
MHD_PANIC (_("Internal error\n"));
@@ -5281,7 +5281,7 @@
#endif
}
}
- if (! MHD_INVALID_PIPE_(daemon->itc))
+ if (MHD_ITC_IS_VALID_(daemon->itc))
{
if (! MHD_itc_activate_ (daemon->itc, "e"))
MHD_PANIC (_("Failed to signal shutdown via pipe"));
@@ -5317,7 +5317,7 @@
/* MHD_USE_NO_LISTEN_SOCKET disables thread pools, hence we need to
check */
for (i = 0; i < daemon->worker_pool_size; ++i)
{
- if (! MHD_INVALID_PIPE_(daemon->worker_pool[i].itc))
+ if (MHD_ITC_IS_VALID_(daemon->worker_pool[i].itc))
{
if (! MHD_itc_activate_ (daemon->worker_pool[i].itc, "e"))
MHD_PANIC (_("Failed to signal shutdown via pipe."));
@@ -5337,7 +5337,7 @@
/* Individual pipes are always used */
if (1)
{
- if (! MHD_INVALID_PIPE_ (daemon->worker_pool[i].itc) )
+ if (MHD_ITC_IS_VALID_ (daemon->worker_pool[i].itc) )
{
MHD_itc_destroy_chk_ (daemon->worker_pool[i].itc);
}
@@ -5394,7 +5394,7 @@
MHD_mutex_destroy_chk_ (&daemon->per_ip_connection_mutex);
MHD_mutex_destroy_chk_ (&daemon->cleanup_connection_mutex);
- if (! MHD_INVALID_PIPE_(daemon->itc))
+ if (MHD_ITC_IS_VALID_(daemon->itc))
MHD_itc_destroy_chk_ (daemon->itc);
free (daemon);
}
Modified: libmicrohttpd/src/microhttpd/mhd_itc.h
===================================================================
--- libmicrohttpd/src/microhttpd/mhd_itc.h 2016-10-11 15:21:20 UTC (rev
38117)
+++ libmicrohttpd/src/microhttpd/mhd_itc.h 2016-10-11 15:21:23 UTC (rev
38118)
@@ -115,9 +115,15 @@
#define MHD_itc_destroy_(itc) ((0 != close (itc)) || (EBADF != errno))
/**
- * Check if we have an uninitialized pipe
+ * Check whether ITC has valid value.
+ *
+ * Macro check whether @a itc value is valid (allowed),
+ * macro does not check whether @a itc was really initialised.
+ * @param itc the itc to check
+ * @return boolean true if @a itc has valid value,
+ * boolean false otherwise.
*/
-#define MHD_INVALID_PIPE_(pip) (-1 == pip)
+#define MHD_ITC_IS_VALID_(itc) (-1 != (itc))
/**
* Setup uninitialized @a pip data structure.
@@ -205,9 +211,15 @@
((close ((itc).fd[1])), 0) )
/**
- * Check if we have an uninitialized pipe
+ * Check whether ITC has valid value.
+ *
+ * Macro check whether @a itc value is valid (allowed),
+ * macro does not check whether @a itc was really initialised.
+ * @param itc the itc to check
+ * @return boolean true if @a itc has valid value,
+ * boolean false otherwise.
*/
-#define MHD_INVALID_PIPE_(pip) (-1 == (pip).fd[0])
+#define MHD_ITC_IS_VALID_(itc) (-1 != (itc).fd[0])
/**
* Setup uninitialized @a pip data structure.
@@ -290,10 +302,17 @@
MHD_socket_close_((itc).sk[1]) : \
((void)MHD_socket_close_((itc).sk[1]), 0) )
+
/**
- * Check for uninitialized pipe @a pip
+ * Check whether ITC has valid value.
+ *
+ * Macro check whether @a itc value is valid (allowed),
+ * macro does not check whether @a itc was really initialised.
+ * @param itc the itc to check
+ * @return boolean true if @a itc has valid value,
+ * boolean false otherwise.
*/
-#define MHD_INVALID_PIPE_(pip) (MHD_INVALID_SOCKET == (pip).sk[0])
+#define MHD_ITC_IS_VALID_(itc) (MHD_INVALID_SOCKET != (itc).sk[0])
/**
* Setup uninitialized @a pip data structure.
@@ -317,4 +336,15 @@
MHD_PANIC(_("Failed to destroy ITC.\n")); \
} while(0)
+/**
+ * Check whether ITC has invalid value.
+ *
+ * Macro check whether @a itc value is invalid,
+ * macro does not check whether @a itc was destroyed.
+ * @param itc the itc to check
+ * @return boolean true if @a itc has invalid value,
+ * boolean false otherwise.
+ */
+#define MHD_ITC_IS_INVALID_(itc) (! MHD_ITC_IS_VALID_(itc))
+
#endif /* MHD_ITC_H */
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [GNUnet-SVN] r38118 - libmicrohttpd/src/microhttpd,
gnunet <=