Merge pull request #433 from michelp/reject-no-fds-avail

Ported from libxs revision 123c0f5387ecef287dd11f4dc790fb76ee1c0f67
This commit is contained in:
Pieter Hintjens 2012-09-30 12:21:15 -07:00
commit 2440863292
2 changed files with 10 additions and 3 deletions

View File

@ -190,12 +190,14 @@ int zmq::ipc_listener_t::close ()
zmq::fd_t zmq::ipc_listener_t::accept ()
{
// Accept one connection and deal with different failure modes.
// The situation where connection cannot be accepted due to insufficient
// resources is considered valid and treated by ignoring the connection.
zmq_assert (s != retired_fd);
fd_t sock = ::accept (s, NULL, NULL);
if (sock == -1) {
errno_assert (errno == EAGAIN || errno == EWOULDBLOCK ||
errno == EINTR || errno == ECONNABORTED || errno == EPROTO ||
errno == ENOBUFS);
errno == ENFILE);
return retired_fd;
}
return sock;

View File

@ -235,6 +235,8 @@ error:
zmq::fd_t zmq::tcp_listener_t::accept ()
{
// The situation where connection cannot be accepted due to insufficient
// resources is considered valid and treated by ignoring the connection.
// Accept one connection and deal with different failure modes.
zmq_assert (s != retired_fd);
@ -249,7 +251,9 @@ zmq::fd_t zmq::tcp_listener_t::accept ()
#ifdef ZMQ_HAVE_WINDOWS
if (sock == INVALID_SOCKET) {
wsa_assert (WSAGetLastError () == WSAEWOULDBLOCK ||
WSAGetLastError () == WSAECONNRESET);
WSAGetLastError () == WSAECONNRESET ||
WSAGetLastError () == WSAEMFILE ||
WSAGetLastError () == WSAENOBUFS);
return retired_fd;
}
// On Windows, preventing sockets to be inherited by child processes.
@ -259,7 +263,8 @@ zmq::fd_t zmq::tcp_listener_t::accept ()
if (sock == -1) {
errno_assert (errno == EAGAIN || errno == EWOULDBLOCK ||
errno == EINTR || errno == ECONNABORTED || errno == EPROTO ||
errno == ENOBUFS);
errno == ENOBUFS || errno == ENOMEM || errno == EMFILE ||
errno == ENFILE);
return retired_fd;
}
#endif