1 files changed, 0 insertions, 189 deletions
diff --git a/src/connecter.cpp b/src/connecter.cpp
deleted file mode 100644
index 970dcf7..0000000
--- a/src/connecter.cpp
+++ /dev/null
@@ -1,189 +0,0 @@
-/*
-    Copyright (c) 2007-2009 FastMQ Inc.
-
-    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 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.
-
-    You should have received a copy of the Lesser GNU General Public License
-    along with this program.  If not, see <http://www.gnu.org/licenses/>.
-*/
-
-#include "connecter.hpp"
-#include "io_thread.hpp"
-#include "session.hpp"
-#include "err.hpp"
-#include "simple_semaphore.hpp"
-#include "zmq_tcp_engine.hpp"
-
-zmq::connecter_t::connecter_t (io_thread_t *thread_, const char *addr_,
-      session_t *session_) :
-    io_object_t (thread_),
-    state (idle),
-    poller (NULL),
-    session (session_),
-    addr (addr_),
-    identity ("abcde"),
-    engine (NULL)
-{
-}
-
-void zmq::connecter_t::terminate ()
-{
-    delete this;
-}
-
-void zmq::connecter_t::shutdown ()
-{
-    delete this;
-}
-
-zmq::connecter_t::~connecter_t ()
-{
-}
-
-void zmq::connecter_t::process_reg (simple_semaphore_t *smph_)
-{
-    //  Fet poller pointer for further use.
-    zmq_assert (!poller);
-    poller = get_poller ();
-
-    //  Ask the session to register itself with the I/O thread. Note that
-    //  the session is living in the same I/O thread, thus this results
-    //  in a synchronous call.
-    session->inc_seqnum ();
-    send_reg (session, NULL);
-
-    //  Unlock the application thread that created the connecter.
-    if (smph_)
-        smph_->post ();
-
-    //  Manually trigger timer event which will launch asynchronous connect.
-    state = waiting;
-    timer_event ();
-}
-
-void zmq::connecter_t::process_unreg (simple_semaphore_t *smph_)
-{
-    //  Unregister connecter/engine from the poller.
-    zmq_assert (poller);
-    if (state == connecting)
-        poller->rm_fd (handle);
-    else if (state == waiting)
-        poller->cancel_timer (this);
-    else if (state == sending)
-        engine->terminate ();
-
-    //  Unlock the application thread closing the connecter.
-    if (smph_)
-        smph_->post ();
-}
-
-void zmq::connecter_t::in_event ()
-{
-    //  Error occured in asynchronous connect. Retry to connect after a while.
-    if (state == connecting) {
-        fd_t fd = tcp_connecter.connect ();
-        zmq_assert (fd == retired_fd);
-        poller->rm_fd (handle);
-        poller->add_timer (this);
-        state = waiting;
-        return;
-    }
-
-    zmq_assert (false);
-}
-
-void zmq::connecter_t::out_event ()
-{
-    if (state == connecting) {
-
-        fd_t fd = tcp_connecter.connect ();
-        if (fd == retired_fd) {
-            poller->rm_fd (handle);
-            poller->add_timer (this);
-            state = waiting;
-            return;
-        }
-
-        poller->rm_fd (handle);
-        engine = new zmq_tcp_engine_t (fd);
-        zmq_assert (engine);
-        engine->attach (poller, this);
-        state = sending;
-        return;
-    }
-
-    zmq_assert (false);
-}
-
-void zmq::connecter_t::timer_event ()
-{
-    zmq_assert (state == waiting);
-
-    //  Initiate async connect and start polling for its completion. If async
-    //  connect fails instantly, try to reconnect after a while.
-    int rc = tcp_connecter.open (addr.c_str ());
-    if (rc == 0) {
-        state = connecting;
-        in_event ();
-    }
-    else if (rc == 1) {
-        handle = poller->add_fd (tcp_connecter.get_fd (), this);
-        poller->set_pollout (handle);
-        state = connecting;
-    }
-    else {
-        poller->add_timer (this);
-        state = waiting;
-    }
-}
-
-void zmq::connecter_t::set_engine (struct i_engine *engine_)
-{
-    engine = engine_;
-}
-
-bool zmq::connecter_t::read (zmq_msg *msg_)
-{
-    zmq_assert (state == sending);
-
-    //  Deallocate old content of the message just in case.
-    zmq_msg_close (msg_);
-
-    //  Send the identity.
-    zmq_msg_init_size (msg_, identity.size ());
-    memcpy (zmq_msg_data (msg_), identity.c_str (), identity.size ());
-
-    //  Ask engine to unregister from the poller.
-    i_engine *e = engine;
-    engine->detach ();
-
-    //  Attach the engine to the session. (Note that this is actually
-    //  a synchronous call.
-    session->inc_seqnum ();
-    send_engine (session, e);
-
-    state = idle;
-
-    return true;    
-}
-
-bool zmq::connecter_t::write (struct zmq_msg *msg_)
-{
-    //  No incoming messages are accepted till identity is sent.
-    return false;
-}
-
-void zmq::connecter_t::flush ()
-{
-    //  No incoming messages are accepted till identity is sent.
-}