diff options
Diffstat (limited to 'src')
| -rw-r--r-- | src/ip.cpp | 2 | ||||
| -rw-r--r-- | src/ipc_listener.cpp | 6 | ||||
| -rw-r--r-- | src/req.cpp | 6 | ||||
| -rw-r--r-- | src/session_base.cpp | 10 | ||||
| -rw-r--r-- | src/socket_base.cpp | 36 | ||||
| -rw-r--r-- | src/tcp_listener.cpp | 6 | ||||
| -rw-r--r-- | src/upoll.cpp | 2 |
7 files changed, 35 insertions, 33 deletions
@@ -84,7 +84,7 @@ void xs::tune_tcp_socket (fd_t s_, bool keepalive_) if (keepalive_) { int keepalive = 1; - int rc = setsockopt (s_, SOL_SOCKET, SO_KEEPALIVE, (char*) &keepalive, + rc = setsockopt (s_, SOL_SOCKET, SO_KEEPALIVE, (char*) &keepalive, sizeof (int)); #ifdef XS_HAVE_WINDOWS wsa_assert (rc != SOCKET_ERROR); diff --git a/src/ipc_listener.cpp b/src/ipc_listener.cpp index bd2e5c7..b3e5693 100644 --- a/src/ipc_listener.cpp +++ b/src/ipc_listener.cpp @@ -83,11 +83,11 @@ void xs::ipc_listener_t::in_event (fd_t fd_) // Choose I/O thread to run connecter in. Given that we are already // running in an I/O thread, there must be at least one available. - io_thread_t *io_thread = choose_io_thread (options.affinity); - xs_assert (io_thread); + io_thread_t *thread = choose_io_thread (options.affinity); + xs_assert (thread); // Create and launch a session object. - session_base_t *session = session_base_t::create (io_thread, false, socket, + session_base_t *session = session_base_t::create (thread, false, socket, options, NULL, NULL); errno_assert (session); session->inc_seqnum (); diff --git a/src/req.cpp b/src/req.cpp index 2e0e614..0094929 100644 --- a/src/req.cpp +++ b/src/req.cpp @@ -77,6 +77,8 @@ int xs::req_t::xsend (msg_t *msg_, int flags_) int xs::req_t::xrecv (msg_t *msg_, int flags_) { + int rc; + // If request wasn't send, we can't wait for reply. if (!receiving_reply) { errno = EFSM; @@ -92,7 +94,7 @@ int xs::req_t::xrecv (msg_t *msg_, int flags_) // TODO: This should also close the connection with the peer! if (unlikely (!(msg_->flags () & msg_t::more) || msg_->size () != 0)) { while (true) { - int rc = xreq_t::xrecv (msg_, flags_); + rc = xreq_t::xrecv (msg_, flags_); errno_assert (rc == 0); if (!(msg_->flags () & msg_t::more)) break; @@ -106,7 +108,7 @@ int xs::req_t::xrecv (msg_t *msg_, int flags_) message_begins = false; } - int rc = xreq_t::xrecv (msg_, flags_); + rc = xreq_t::xrecv (msg_, flags_); if (rc != 0) return rc; diff --git a/src/session_base.cpp b/src/session_base.cpp index 0c9428b..90fa071 100644 --- a/src/session_base.cpp +++ b/src/session_base.cpp @@ -395,14 +395,14 @@ void xs::session_base_t::start_connecting (bool wait_) // Choose I/O thread to run connecter in. Given that we are already // running in an I/O thread, there must be at least one available. - io_thread_t *io_thread = choose_io_thread (options.affinity); + io_thread_t *thread = choose_io_thread (options.affinity); xs_assert (io_thread); // Create the connecter object. if (protocol == "tcp") { tcp_connecter_t *connecter = new (std::nothrow) tcp_connecter_t ( - io_thread, this, options, address.c_str (), wait_); + thread, this, options, address.c_str (), wait_); alloc_assert (connecter); launch_child (connecter); return; @@ -411,7 +411,7 @@ void xs::session_base_t::start_connecting (bool wait_) #if !defined XS_HAVE_WINDOWS && !defined XS_HAVE_OPENVMS if (protocol == "ipc") { ipc_connecter_t *connecter = new (std::nothrow) ipc_connecter_t ( - io_thread, this, options, address.c_str (), wait_); + thread, this, options, address.c_str (), wait_); alloc_assert (connecter); launch_child (connecter); return; @@ -433,7 +433,7 @@ void xs::session_base_t::start_connecting (bool wait_) // PGM sender. pgm_sender_t *pgm_sender = new (std::nothrow) pgm_sender_t ( - io_thread, options); + thread, options); alloc_assert (pgm_sender); int rc = pgm_sender->init (udp_encapsulation, address.c_str ()); @@ -445,7 +445,7 @@ void xs::session_base_t::start_connecting (bool wait_) // PGM receiver. pgm_receiver_t *pgm_receiver = new (std::nothrow) pgm_receiver_t ( - io_thread, options); + thread, options); alloc_assert (pgm_receiver); int rc = pgm_receiver->init (udp_encapsulation, address.c_str ()); diff --git a/src/socket_base.cpp b/src/socket_base.cpp index 9d33348..fbb3b5e 100644 --- a/src/socket_base.cpp +++ b/src/socket_base.cpp @@ -325,17 +325,17 @@ int xs::socket_base_t::bind (const char *addr_) // Remaining trasnports require to be run in an I/O thread, so at this // point we'll choose one. - io_thread_t *io_thread = choose_io_thread (options.affinity); - if (!io_thread) { + io_thread_t *thread = choose_io_thread (options.affinity); + if (!thread) { errno = EMTHREAD; return -1; } if (protocol == "tcp") { tcp_listener_t *listener = new (std::nothrow) tcp_listener_t ( - io_thread, this, options); + thread, this, options); alloc_assert (listener); - int rc = listener->set_address (address.c_str ()); + rc = listener->set_address (address.c_str ()); if (rc != 0) { delete listener; return -1; @@ -347,9 +347,9 @@ int xs::socket_base_t::bind (const char *addr_) #if !defined XS_HAVE_WINDOWS && !defined XS_HAVE_OPENVMS if (protocol == "ipc") { ipc_listener_t *listener = new (std::nothrow) ipc_listener_t ( - io_thread, this, options); + thread, this, options); alloc_assert (listener); - int rc = listener->set_address (address.c_str ()); + rc = listener->set_address (address.c_str ()); if (rc != 0) { delete listener; return -1; @@ -407,14 +407,14 @@ int xs::socket_base_t::connect (const char *addr_) // Create a bi-directional pipe to connect the peers. object_t *parents [2] = {this, peer.socket}; - pipe_t *pipes [2] = {NULL, NULL}; + pipe_t *ppair [2] = {NULL, NULL}; int hwms [2] = {sndhwm, rcvhwm}; bool delays [2] = {options.delay_on_disconnect, options.delay_on_close}; - int rc = pipepair (parents, pipes, hwms, delays, options.protocol); + rc = pipepair (parents, ppair, hwms, delays, options.protocol); errno_assert (rc == 0); // Attach local end of the pipe to this socket object. - attach_pipe (pipes [0]); + attach_pipe (ppair [0]); // If required, send the identity of the local socket to the peer. if (options.send_identity) { @@ -423,36 +423,36 @@ int xs::socket_base_t::connect (const char *addr_) xs_assert (rc == 0); memcpy (id.data (), options.identity, options.identity_size); id.set_flags (msg_t::identity); - bool written = pipes [0]->write (&id); + bool written = ppair [0]->write (&id); xs_assert (written); } // Attach remote end of the pipe to the peer socket. Note that peer's // seqnum was incremented in find_endpoint function. We don't need it // increased here. - send_bind (peer.socket, pipes [1], false); + send_bind (peer.socket, ppair [1], false); return 0; } // Choose the I/O thread to run the session in. - io_thread_t *io_thread = choose_io_thread (options.affinity); - if (!io_thread) { + io_thread_t *thread = choose_io_thread (options.affinity); + if (!thread) { errno = EMTHREAD; return -1; } // Create session. - session_base_t *session = session_base_t::create (io_thread, true, this, + session_base_t *session = session_base_t::create (thread, true, this, options, protocol.c_str (), address.c_str ()); errno_assert (session); // Create a bi-directional pipe. object_t *parents [2] = {this, session}; - pipe_t *pipes [2] = {NULL, NULL}; + pipe_t *ppair [2] = {NULL, NULL}; int hwms [2] = {options.sndhwm, options.rcvhwm}; bool delays [2] = {options.delay_on_disconnect, options.delay_on_close}; - rc = pipepair (parents, pipes, hwms, delays, options.protocol); + rc = pipepair (parents, ppair, hwms, delays, options.protocol); errno_assert (rc == 0); // PGM does not support subscription forwarding; ask for all data to be @@ -462,10 +462,10 @@ int xs::socket_base_t::connect (const char *addr_) icanhasall = true; // Attach local end of the pipe to the socket object. - attach_pipe (pipes [0], icanhasall); + attach_pipe (ppair [0], icanhasall); // Attach remote end of the pipe to the session object later on. - session->attach_pipe (pipes [1]); + session->attach_pipe (ppair [1]); // Activate the session. Make it a child of this socket. launch_child (session); diff --git a/src/tcp_listener.cpp b/src/tcp_listener.cpp index c0ea564..5e1dcc9 100644 --- a/src/tcp_listener.cpp +++ b/src/tcp_listener.cpp @@ -94,11 +94,11 @@ void xs::tcp_listener_t::in_event (fd_t fd_) // Choose I/O thread to run connecter in. Given that we are already // running in an I/O thread, there must be at least one available. - io_thread_t *io_thread = choose_io_thread (options.affinity); - xs_assert (io_thread); + io_thread_t *thread = choose_io_thread (options.affinity); + xs_assert (thread); // Create and launch a session object. - session_base_t *session = session_base_t::create (io_thread, false, socket, + session_base_t *session = session_base_t::create (thread, false, socket, options, NULL, NULL); errno_assert (session); session->inc_seqnum (); diff --git a/src/upoll.cpp b/src/upoll.cpp index 3295bba..9dd13ea 100644 --- a/src/upoll.cpp +++ b/src/upoll.cpp @@ -125,7 +125,7 @@ int xs::upoll (xs_pollitem_t *items_, int nitems_, int timeout_) else if (timeout_ < 0) timeout = -1; else - timeout = end - now; + timeout = (int) (end - now); // Wait for events. while (true) { |