diff options
| author | Martin Lucina <martin@lucina.net> | 2012-01-23 08:53:35 +0100 | 
|---|---|---|
| committer | Martin Lucina <martin@lucina.net> | 2012-01-23 08:53:35 +0100 | 
| commit | e645fc2693acc796304498909786b7b47005b429 (patch) | |
| tree | 4118cd4c7b9eba3ba1d6892800c79669ea94c4e9 /src/poll.hpp | |
| parent | 2c416a793ea781273a5da6742211f5f01af13a2b (diff) | |
Imported Upstream version 2.1.3upstream/2.1.3
Diffstat (limited to 'src/poll.hpp')
| -rw-r--r-- | src/poll.hpp | 29 | 
1 files changed, 10 insertions, 19 deletions
| diff --git a/src/poll.hpp b/src/poll.hpp index f4ae35a..3a18d03 100644 --- a/src/poll.hpp +++ b/src/poll.hpp @@ -1,19 +1,20 @@  /* -    Copyright (c) 2007-2010 iMatix Corporation +    Copyright (c) 2007-2011 iMatix Corporation +    Copyright (c) 2007-2011 Other contributors as noted in the AUTHORS file      This file is part of 0MQ.      0MQ is free software; you can redistribute it and/or modify it under -    the terms of the Lesser GNU General Public License as published by +    the terms of the GNU Lesser General Public License as published by      the Free Software Foundation; either version 3 of the License, or      (at your option) any later version.      0MQ is distributed in the hope that it will be useful,      but WITHOUT ANY WARRANTY; without even the implied warranty of      MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the -    Lesser GNU General Public License for more details. +    GNU Lesser General Public License for more details. -    You should have received a copy of the Lesser GNU General Public License +    You should have received a copy of the GNU Lesser General Public License      along with this program.  If not, see <http://www.gnu.org/licenses/>.  */ @@ -34,7 +35,7 @@  #include "fd.hpp"  #include "thread.hpp" -#include "atomic_counter.hpp" +#include "poller_base.hpp"  namespace zmq  { @@ -42,7 +43,7 @@ namespace zmq      //  Implements socket polling mechanism using the POSIX.1-2001      //  poll() system call. -    class poll_t +    class poll_t : public poller_base_t      {      public: @@ -58,9 +59,6 @@ namespace zmq          void reset_pollin (handle_t handle_);          void set_pollout (handle_t handle_);          void reset_pollout (handle_t handle_); -        void add_timer (struct i_poll_events *events_); -        void cancel_timer (struct i_poll_events *events_); -        int get_load ();          void start ();          void stop (); @@ -79,7 +77,8 @@ namespace zmq          };          //  This table stores data for registered descriptors. -        std::vector <fd_entry_t> fd_table; +        typedef std::vector <fd_entry_t> fd_table_t; +        fd_table_t fd_table;          //  Pollset to pass to the poll function.          typedef std::vector <pollfd> pollset_t; @@ -88,22 +87,14 @@ namespace zmq          //  If true, there's at least one retired event source.          bool retired; -        //  List of all the engines waiting for the timer event. -        typedef std::vector <struct i_poll_events*> timers_t; -        timers_t timers; -          //  If true, thread is in the process of shutting down.          bool stopping;          //  Handle of the physical thread doing the I/O work.          thread_t worker; -        //  Load of the poller. Currently number of file descriptors -        //  registered with the poller. -        atomic_counter_t load; -          poll_t (const poll_t&); -        void operator = (const poll_t&); +        const poll_t &operator = (const poll_t&);      };  } | 
