• Martin Sustrik's avatar
    Introduces bi-directional pipes · acf0b0e5
    Martin Sustrik authored
    So far, there was a pair of unidirectional pipes between a socket
    and a session (or an inproc peer). This resulted in complex
    problems with half-closed states and tracking which inpipe
    corresponds to which outpipe.
    
    This patch doesn't add any functionality in itself, but is
    essential for further work on features like subscription
    forwarding.
    Signed-off-by: 's avatarMartin Sustrik <sustrik@250bpm.com>
    acf0b0e5
Name
Last commit
Last update
..
Makefile.am Loading commit data...
array.hpp Loading commit data...
atomic_counter.hpp Loading commit data...
atomic_ptr.hpp Loading commit data...
blob.hpp Loading commit data...
clock.cpp Loading commit data...
clock.hpp Loading commit data...
command.cpp Loading commit data...
command.hpp Loading commit data...
config.hpp Loading commit data...
connect_session.cpp Loading commit data...
connect_session.hpp Loading commit data...
ctx.cpp Loading commit data...
ctx.hpp Loading commit data...
decoder.cpp Loading commit data...
decoder.hpp Loading commit data...
devpoll.cpp Loading commit data...
devpoll.hpp Loading commit data...
dist.cpp Loading commit data...
dist.hpp Loading commit data...
encoder.cpp Loading commit data...
encoder.hpp Loading commit data...
epoll.cpp Loading commit data...
epoll.hpp Loading commit data...
err.cpp Loading commit data...
err.hpp Loading commit data...
fd.hpp Loading commit data...
fq.cpp Loading commit data...
fq.hpp Loading commit data...
i_engine.hpp Loading commit data...
i_inout.hpp Loading commit data...
i_poll_events.hpp Loading commit data...
io_object.cpp Loading commit data...
io_object.hpp Loading commit data...
io_thread.cpp Loading commit data...
io_thread.hpp Loading commit data...
ip.cpp Loading commit data...
ip.hpp Loading commit data...
kqueue.cpp Loading commit data...
kqueue.hpp Loading commit data...
lb.cpp Loading commit data...
lb.hpp Loading commit data...
libzmq.pc.in Loading commit data...
likely.hpp Loading commit data...
mailbox.cpp Loading commit data...
mailbox.hpp Loading commit data...
msg.cpp Loading commit data...
msg.hpp Loading commit data...
mutex.hpp Loading commit data...
named_session.cpp Loading commit data...
named_session.hpp Loading commit data...
object.cpp Loading commit data...
object.hpp Loading commit data...
options.cpp Loading commit data...
options.hpp Loading commit data...
own.cpp Loading commit data...
own.hpp Loading commit data...
pair.cpp Loading commit data...
pair.hpp Loading commit data...
pgm_receiver.cpp Loading commit data...
pgm_receiver.hpp Loading commit data...
pgm_sender.cpp Loading commit data...
pgm_sender.hpp Loading commit data...
pgm_socket.cpp Loading commit data...
pgm_socket.hpp Loading commit data...
pipe.cpp Loading commit data...
pipe.hpp Loading commit data...
poll.cpp Loading commit data...
poll.hpp Loading commit data...
poller.hpp Loading commit data...
poller_base.cpp Loading commit data...
poller_base.hpp Loading commit data...
pub.cpp Loading commit data...
pub.hpp Loading commit data...
pull.cpp Loading commit data...
pull.hpp Loading commit data...
push.cpp Loading commit data...
push.hpp Loading commit data...
reaper.cpp Loading commit data...
reaper.hpp Loading commit data...
rep.cpp Loading commit data...
rep.hpp Loading commit data...
req.cpp Loading commit data...
req.hpp Loading commit data...
select.cpp Loading commit data...
select.hpp Loading commit data...
semaphore.hpp Loading commit data...
session.cpp Loading commit data...
session.hpp Loading commit data...
socket_base.cpp Loading commit data...
socket_base.hpp Loading commit data...
stdint.hpp Loading commit data...
sub.cpp Loading commit data...
sub.hpp Loading commit data...
tcp_connecter.cpp Loading commit data...
tcp_connecter.hpp Loading commit data...
tcp_listener.cpp Loading commit data...
tcp_listener.hpp Loading commit data...
tcp_socket.cpp Loading commit data...
tcp_socket.hpp Loading commit data...
thread.cpp Loading commit data...
thread.hpp Loading commit data...
transient_session.cpp Loading commit data...
transient_session.hpp Loading commit data...
trie.cpp Loading commit data...
trie.hpp Loading commit data...
uuid.cpp Loading commit data...
uuid.hpp Loading commit data...
windows.hpp Loading commit data...
wire.hpp Loading commit data...
xpub.cpp Loading commit data...
xpub.hpp Loading commit data...
xrep.cpp Loading commit data...
xrep.hpp Loading commit data...
xreq.cpp Loading commit data...
xreq.hpp Loading commit data...
xsub.cpp Loading commit data...
xsub.hpp Loading commit data...
ypipe.hpp Loading commit data...
yqueue.hpp Loading commit data...
zmq.cpp Loading commit data...
zmq_connecter.cpp Loading commit data...
zmq_connecter.hpp Loading commit data...
zmq_engine.cpp Loading commit data...
zmq_engine.hpp Loading commit data...
zmq_init.cpp Loading commit data...
zmq_init.hpp Loading commit data...
zmq_listener.cpp Loading commit data...
zmq_listener.hpp Loading commit data...
zmq_utils.cpp Loading commit data...