3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-09 07:16:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Whitespace fixes

Browse Source
This commit is contained in:
Pieter Hintjens 2015-10-30 10:19:46 +01:00
parent dc04c5bbd6
commit f38c11c063
1 changed files with 13 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
src/signaler.cpp
View File

@ -100,20 +100,15 @@ static int close_wait_ms (int fd_, unsigned int max_ms_ = 2000)
unsigned int step_ms = max_ms_ / 10; unsigned int step_ms = max_ms_ / 10;
if (step_ms < 1) if (step_ms < 1)
step_ms = 1; step_ms = 1;
if (step_ms > 100) if (step_ms > 100)
step_ms = 100; step_ms = 100;
int rc = 0; // do not sleep on first attempt int rc = 0; // do not sleep on first attempt
do {
do if (rc == -1 && errno == EAGAIN) {
{
if (rc == -1 && errno == EAGAIN)
{
sleep_ms (step_ms); sleep_ms (step_ms);
ms_so_far += step_ms; ms_so_far += step_ms;
} }
rc = close (fd_); rc = close (fd_);
} while (ms_so_far < max_ms_ && rc == -1 && errno == EAGAIN); } while (ms_so_far < max_ms_ && rc == -1 && errno == EAGAIN);
@ -187,7 +182,7 @@ void zmq::signaler_t::send ()
errno_assert (sz == sizeof (inc)); errno_assert (sz == sizeof (inc));
#elif defined ZMQ_HAVE_WINDOWS #elif defined ZMQ_HAVE_WINDOWS
unsigned char dummy = 0; unsigned char dummy = 0;
int nbytes = ::send (w, (char*) &dummy, sizeof (dummy), 0); int nbytes = ::send (w, (char *) &dummy, sizeof (dummy), 0);
wsa_assert (nbytes != SOCKET_ERROR); wsa_assert (nbytes != SOCKET_ERROR);
zmq_assert (nbytes == sizeof (dummy)); zmq_assert (nbytes == sizeof (dummy));
#else #else
@ -304,7 +299,7 @@ void zmq::signaler_t::recv ()
#else #else
unsigned char dummy; unsigned char dummy;
#if defined ZMQ_HAVE_WINDOWS #if defined ZMQ_HAVE_WINDOWS
int nbytes = ::recv (r, (char*) &dummy, sizeof (dummy), 0); int nbytes = ::recv (r, (char *) &dummy, sizeof (dummy), 0);
wsa_assert (nbytes != SOCKET_ERROR); wsa_assert (nbytes != SOCKET_ERROR);
#else #else
ssize_t nbytes = ::recv (r, &dummy, sizeof (dummy), 0); ssize_t nbytes = ::recv (r, &dummy, sizeof (dummy), 0);
@ -342,7 +337,7 @@ int zmq::signaler_t::recv_failable ()
#else #else
unsigned char dummy; unsigned char dummy;
#if defined ZMQ_HAVE_WINDOWS #if defined ZMQ_HAVE_WINDOWS
int nbytes = ::recv (r, (char*) &dummy, sizeof (dummy), 0); int nbytes = ::recv (r, (char *) &dummy, sizeof (dummy), 0);
if (nbytes == SOCKET_ERROR) { if (nbytes == SOCKET_ERROR) {
const int last_error = WSAGetLastError(); const int last_error = WSAGetLastError();
if (last_error == WSAEWOULDBLOCK) { if (last_error == WSAEWOULDBLOCK) {
@ -466,11 +461,11 @@ int zmq::signaler_t::make_fdpair (fd_t *r_, fd_t *w_)
// Set SO_REUSEADDR and TCP_NODELAY on listening socket. // Set SO_REUSEADDR and TCP_NODELAY on listening socket.
BOOL so_reuseaddr = 1; BOOL so_reuseaddr = 1;
int rc = setsockopt (listener, SOL_SOCKET, SO_REUSEADDR, int rc = setsockopt (listener, SOL_SOCKET, SO_REUSEADDR,
(char *)&so_reuseaddr, sizeof so_reuseaddr); (char *) &so_reuseaddr, sizeof so_reuseaddr);
wsa_assert (rc != SOCKET_ERROR); wsa_assert (rc != SOCKET_ERROR);
BOOL tcp_nodelay = 1; BOOL tcp_nodelay = 1;
rc = setsockopt (listener, IPPROTO_TCP, TCP_NODELAY, rc = setsockopt (listener, IPPROTO_TCP, TCP_NODELAY,
(char *)&tcp_nodelay, sizeof tcp_nodelay); (char *) &tcp_nodelay, sizeof tcp_nodelay);
wsa_assert (rc != SOCKET_ERROR); wsa_assert (rc != SOCKET_ERROR);
// Init sockaddr to signaler port. // Init sockaddr to signaler port.
@ -496,12 +491,12 @@ int zmq::signaler_t::make_fdpair (fd_t *r_, fd_t *w_)
} }
// Bind listening socket to signaler port. // Bind listening socket to signaler port.
rc = bind (listener, (const struct sockaddr*) &addr, sizeof addr); rc = bind (listener, (const struct sockaddr *) &addr, sizeof addr);
if (rc != SOCKET_ERROR && signaler_port == 0) { if (rc != SOCKET_ERROR && signaler_port == 0) {
// Retrieve ephemeral port number // Retrieve ephemeral port number
int addrlen = sizeof addr; int addrlen = sizeof addr;
rc = getsockname (listener, (struct sockaddr*) &addr, &addrlen); rc = getsockname (listener, (struct sockaddr *) &addr, &addrlen);
} }
// Listen for incoming connections. // Listen for incoming connections.
@ -510,7 +505,7 @@ int zmq::signaler_t::make_fdpair (fd_t *r_, fd_t *w_)
// Connect writer to the listener. // Connect writer to the listener.
if (rc != SOCKET_ERROR) if (rc != SOCKET_ERROR)
rc = connect (*w_, (struct sockaddr*) &addr, sizeof addr); rc = connect (*w_, (struct sockaddr *) &addr, sizeof addr);
// Accept connection from writer. // Accept connection from writer.
if (rc != SOCKET_ERROR) if (rc != SOCKET_ERROR)
@ -582,12 +577,12 @@ int zmq::signaler_t::make_fdpair (fd_t *r_, fd_t *w_)
rc = setsockopt (listener, IPPROTO_TCP, TCP_NODELACK, &on, sizeof on); rc = setsockopt (listener, IPPROTO_TCP, TCP_NODELACK, &on, sizeof on);
errno_assert (rc != -1); errno_assert (rc != -1);
rc = bind (listener, (struct sockaddr*) &lcladdr, sizeof lcladdr); rc = bind (listener, (struct sockaddr *) &lcladdr, sizeof lcladdr);
errno_assert (rc != -1); errno_assert (rc != -1);
socklen_t lcladdr_len = sizeof lcladdr; socklen_t lcladdr_len = sizeof lcladdr;
rc = getsockname (listener, (struct sockaddr*) &lcladdr, &lcladdr_len); rc = getsockname (listener, (struct sockaddr *) &lcladdr, &lcladdr_len);
errno_assert (rc != -1); errno_assert (rc != -1);
rc = listen (listener, 1); rc = listen (listener, 1);
@ -602,7 +597,7 @@ int zmq::signaler_t::make_fdpair (fd_t *r_, fd_t *w_)
rc = setsockopt (*w_, IPPROTO_TCP, TCP_NODELACK, &on, sizeof on); rc = setsockopt (*w_, IPPROTO_TCP, TCP_NODELACK, &on, sizeof on);
errno_assert (rc != -1); errno_assert (rc != -1);
rc = connect (*w_, (struct sockaddr*) &lcladdr, sizeof lcladdr); rc = connect (*w_, (struct sockaddr *) &lcladdr, sizeof lcladdr);
errno_assert (rc != -1); errno_assert (rc != -1);
*r_ = accept (listener, NULL, NULL); *r_ = accept (listener, NULL, NULL);