generic-library/libzmq
1
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2024-12-13 18:55:10 +01:00
Code Issues Projects Releases Wiki Activity

issue 32 - poll_t poller broken

Browse Source
This commit is contained in:
Martin Sustrik 2010-06-09 17:49:08 +02:00
parent 7a29e8594f
commit 604f7475ec
1 changed files with 11 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/poll.cpp
View File

@ -165,22 +165,21 @@ void zmq::poll_t::loop ()
continue;
}
for (pollset_t::iterator it = pollset.begin ();
it != pollset.end (); it ++) {
for (pollset_t::size_type i = 0; i != pollset.size (); i++) {
zmq_assert (!(it->revents & POLLNVAL));
if (it->fd == retired_fd)
zmq_assert (!(pollset [i].revents & POLLNVAL));
if (pollset [i].fd == retired_fd)
continue;
if (it->revents & (POLLERR | POLLHUP))
fd_table [it->fd].events->in_event ();
if (it->fd == retired_fd)
if (pollset [i].revents & (POLLERR | POLLHUP))
fd_table [pollset [i].fd].events->in_event ();
if (pollset [i].fd == retired_fd)
continue;
if (it->revents & POLLOUT)
fd_table [it->fd].events->out_event ();
if (it->fd == retired_fd)
if (pollset [i].revents & POLLOUT)
fd_table [pollset [i].fd].events->out_event ();
if (pollset [i].fd == retired_fd)
continue;
if (it->revents & POLLIN)
fd_table [it->fd].events->in_event ();
if (pollset [i].revents & POLLIN)
fd_table [pollset [i].fd].events->in_event ();
}
// Clean up the pollset and update the fd_table accordingly.