summaryrefslogtreecommitdiff
path: root/src/io_thread.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-08-06 12:51:32 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-08-06 12:51:32 +0200
commit0b5cc026fbe7ccc6de66907be29471562a2d344d (patch)
treea6051f238152e2261ea48942f0c216a3984cc9fd /src/io_thread.cpp
parentb8b4acef4c2ba1a169ce84c1fb4c70a5676ebba3 (diff)
clean up - session/socket/engine stuff removed
Diffstat (limited to 'src/io_thread.cpp')
-rw-r--r--src/io_thread.cpp31
1 files changed, 0 insertions, 31 deletions
diff --git a/src/io_thread.cpp b/src/io_thread.cpp
index 162ed4c..f5261a6 100644
--- a/src/io_thread.cpp
+++ b/src/io_thread.cpp
@@ -30,9 +30,7 @@
#include "devpoll.hpp"
#include "kqueue.hpp"
#include "context.hpp"
-#include "session.hpp"
#include "simple_semaphore.hpp"
-#include "session.hpp"
zmq::io_thread_t::io_thread_t (context_t *context_, int thread_slot_) :
object_t (context_, thread_slot_)
@@ -76,15 +74,6 @@ zmq::io_thread_t::io_thread_t (context_t *context_, int thread_slot_) :
poller->set_pollin (signaler_handle);
}
-void zmq::io_thread_t::shutdown ()
-{
- // Deallocate all the sessions associated with the thread.
- while (!sessions.empty ())
- sessions [0]->shutdown ();
-
- delete this;
-}
-
zmq::io_thread_t::~io_thread_t ()
{
delete poller;
@@ -101,11 +90,6 @@ void zmq::io_thread_t::stop ()
send_stop ();
}
-void zmq::io_thread_t::join ()
-{
- poller->join ();
-}
-
zmq::i_signaler *zmq::io_thread_t::get_signaler ()
{
return &signaler;
@@ -149,21 +133,6 @@ void zmq::io_thread_t::timer_event ()
zmq_assert (false);
}
-void zmq::io_thread_t::attach_session (session_t *session_)
-{
- session_->set_index (sessions.size ());
- sessions.push_back (session_);
-}
-
-void zmq::io_thread_t::detach_session (session_t *session_)
-{
- // O(1) removal of the session from the list.
- sessions_t::size_type i = session_->get_index ();
- sessions [i] = sessions [sessions.size () - 1];
- sessions [i]->set_index (i);
- sessions.pop_back ();
-}
-
zmq::i_poller *zmq::io_thread_t::get_poller ()
{
zmq_assert (poller);