diff options
author | Pixel <pixel@nobis-crew.org> | 2011-11-15 12:16:30 -0800 |
---|---|---|
committer | Pixel <pixel@nobis-crew.org> | 2011-11-15 14:12:29 -0800 |
commit | 7a237c6b197ffa7a48d220863ded6a6ea0c3e5ae (patch) | |
tree | 5ecea404d8c6c8c18313a23331dafd9a04b0424c /src | |
parent | 1a5dacb93f2c3f2cfc8f4a9da6599beaebcc6845 (diff) |
Moving code around for the Listener, in order to avoid too much template code.
Diffstat (limited to 'src')
-rw-r--r-- | src/Socket.cc | 39 |
1 files changed, 39 insertions, 0 deletions
diff --git a/src/Socket.cc b/src/Socket.cc index 6b1f551..344fcf7 100644 --- a/src/Socket.cc +++ b/src/Socket.cc @@ -566,3 +566,42 @@ ssize_t Balau::Socket::write(const void * buf, size_t count) throw (GeneralExcep return -1; } + +Balau::ListenerBase::ListenerBase(int port, const char * local, void * opaque) : m_listener(new Socket()), m_stop(false), m_local(local), m_port(port), m_opaque(opaque) { + m_name = String("Listener for something - Starting on ") + local + ":" + port; + waitFor(&m_evt); + setOkayToEAgain(true); + Printer::elog(E_SOCKET, "Created a listener task at %p (%s)", this, m_name.to_charp()); +} + +const char * Balau::ListenerBase::getName() { + return m_name.to_charp(); +} + +void Balau::ListenerBase::stop() { + Printer::elog(E_SOCKET, "Listener task at %p (%s) is asked to stop.", this, m_name.to_charp()); + m_stop = true; + m_evt.trigger(); +} + +void Balau::ListenerBase::Do() { + bool r = m_listener->setLocal(m_local.to_charp(), m_port); + Assert(r); + r = m_listener->listen(); + Assert(r); + setName(); + while (!m_stop) { + IO<Socket> io; + try { + io = m_listener->accept(); + } + catch (EAgain) { + Printer::elog(E_SOCKET, "Listener task at %p (%s) got an EAgain - stop = %s", this, m_name.to_charp(), m_stop ? "true" : "false"); + if (m_stop) + return; + yield(); + continue; + } + factory(io, m_opaque); + } +} |