different fixes to req/rep

This commit is contained in:
Martin Sustrik
2009-09-21 17:20:13 +02:00
parent cb1b6fe32c
commit b15f695976
17 changed files with 79 additions and 129 deletions

View File

@@ -24,11 +24,13 @@
#include "pipe.hpp"
zmq::sub_t::sub_t (class app_thread_t *parent_) :
socket_base_t (parent_, ZMQ_SUB),
socket_base_t (parent_),
active (0),
current (0),
all_count (0)
{
options.requires_in = true;
options.requires_out = false;
}
zmq::sub_t::~sub_t ()
@@ -38,16 +40,6 @@ zmq::sub_t::~sub_t ()
in_pipes.clear ();
}
bool zmq::sub_t::xrequires_in ()
{
return true;
}
bool zmq::sub_t::xrequires_out ()
{
return false;
}
void zmq::sub_t::xattach_pipes (class reader_t *inpipe_,
class writer_t *outpipe_)
{