src · 215cfc653e5c6155e231b213534739348152129d · submodule / libzmq

PGM transport reconciled with subscription forwarding · c7542981

Martin Sustrik authored 13 years ago

As PGM is not capable of passing subscriptions upstream,
subscriptions are ignored at sub side and engine subscribes
for all messages on pub side.
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>

c7542981

Name	Last commit	Last update
..
Makefile.am	Command are now stored in ypipes instead of in socketpairs	13 years ago
array.hpp	Add multi-array support to array_item_t.	13 years ago
atomic_counter.hpp	The copyrights in file headers updated.	14 years ago
atomic_ptr.hpp	The copyrights in file headers updated.	14 years ago
blob.hpp	The copyrights in file headers updated.	14 years ago
clock.cpp	The copyrights in file headers updated.	14 years ago
clock.hpp	The copyrights in file headers updated.	14 years ago
command.cpp	The copyrights in file headers updated.	14 years ago
command.hpp	Patches from sub-forward branch incorporated	13 years ago
config.hpp	VSM data are aligned to 32/64 bit boundary	13 years ago
connect_session.cpp	Patches from sub-forward branch incorporated	13 years ago
connect_session.hpp	Patches from sub-forward branch incorporated	13 years ago
ctx.cpp	Merge branch 'master' of github.com:zeromq/libzmq	13 years ago
ctx.hpp	Message-related functionality factored out into msg_t class.	13 years ago
dealer.cpp	Introduce ZMQ_ROUTER and ZMQ_DEALER sockets	13 years ago
dealer.hpp	Introduce ZMQ_ROUTER and ZMQ_DEALER sockets	13 years ago
decoder.cpp	Rename i_inout to i_engine_sink	13 years ago
decoder.hpp	Rename i_inout to i_engine_sink	13 years ago
devpoll.cpp	The copyrights in file headers updated.	14 years ago
devpoll.hpp	The copyrights in file headers updated.	14 years ago
dist.cpp	Fix MSVC build	13 years ago
dist.hpp	Publisher-side filtering for multi-part messages fixed	13 years ago
encoder.cpp	Rename i_inout to i_engine_sink	13 years ago
encoder.hpp	Rename i_inout to i_engine_sink	13 years ago
epoll.cpp	The copyrights in file headers updated.	14 years ago
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_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...
mtrie.cpp		Loading commit data...
mtrie.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...
random.cpp		Loading commit data...
random.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...
router.cpp		Loading commit data...
router.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...
signaler.cpp		Loading commit data...
signaler.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...