diff options
| author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-08-06 12:51:32 +0200 | 
|---|---|---|
| committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-08-06 12:51:32 +0200 | 
| commit | 0b5cc026fbe7ccc6de66907be29471562a2d344d (patch) | |
| tree | a6051f238152e2261ea48942f0c216a3984cc9fd /src/epoll.cpp | |
| parent | b8b4acef4c2ba1a169ce84c1fb4c70a5676ebba3 (diff) | |
clean up - session/socket/engine stuff removed
Diffstat (limited to 'src/epoll.cpp')
| -rw-r--r-- | src/epoll.cpp | 10 | 
1 files changed, 4 insertions, 6 deletions
diff --git a/src/epoll.cpp b/src/epoll.cpp index c4c8fdb..15278c6 100644 --- a/src/epoll.cpp +++ b/src/epoll.cpp @@ -41,8 +41,11 @@ zmq::epoll_t::epoll_t () :  zmq::epoll_t::~epoll_t ()  { -    close (epoll_fd); +    //  Make sure there are no fds registered on shutdown. +    zmq_assert (load.get () == 0); +    worker.stop (); +    close (epoll_fd);      for (retired_t::iterator it = retired.begin (); it != retired.end (); it ++)          delete *it;  } @@ -144,11 +147,6 @@ void zmq::epoll_t::stop ()      stopping = true;  } -void zmq::epoll_t::join () -{ -    worker.stop (); -} -  void zmq::epoll_t::loop ()  {      epoll_event ev_buf [max_io_events];  | 
