Steven McCoy
667b247e32
Cancel pending timers when decoder for PGM stalls
...
Otherwise the timer event can raise an input event
causing assertion on unprocessed data.
Signed-off-by: Steven McCoy <steven.mccoy@miru.hk>
2011-01-17 14:45:24 +01:00
Martin Sustrik
b358df9fff
Name of "GNU Lesser Public License" corrected.
...
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
2010-10-30 15:08:28 +02:00
Martin Sustrik
b64b50ae21
Timers correctly canceled by PGM engines on shutdown.
...
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
2010-10-15 10:58:19 +02:00
Martin Sustrik
b7386f5b50
To insert to associateive STL containers value_type used instead of make_pair
...
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
2010-10-14 12:13:52 +02:00
Steven McCoy
5b8af52efc
Fix assertion in PGM transports on cancel_timer
...
Signed-off-by: Steven McCoy <steven.mccoy@miru.hk>
2010-10-11 17:59:58 +02:00
Steven McCoy
d14be62499
more fixes to (e)pgm transport
2010-09-30 09:11:51 +02:00
Steven McCoy
96d85b2098
* Add assertions to check for OpenPGM calls with invalid parameters.
...
* Assertion to check that pgm_getaddrinfo is actually returning something.
* Missing pgm_connect call.
* Typo on TOS causing immediate abort.
* Placeholder calls for timeouts whilst continuing spin loop functionality.
* OpenPGM v5 now supports reference counting so remove init checks.
* Duplicate UDP unicast port setting, requires one unicast and one multicast.
* Incorrectly set socket rcvbuf size with sndbuf.
* Replace std::lexicographical_compare of TSI's with long word integer comparisons.
* pgm_socket_t::receive returns -1 on no data.
2010-09-30 09:11:19 +02:00
Martin Sustrik
f5acbb5095
naming cleanup: zmq_encoder->encoder, zmq_decoder->decoder
2010-08-31 07:01:40 +02:00
Martin Sustrik
43e34d0281
engine leak fixed; pgm compilation fixed
2010-08-25 15:39:20 +02:00
Martin Sustrik
77cbd18e9c
issue 11 - Assertion failed: it != peers.end () (pgm_receiver.cpp:161)
2010-04-08 11:07:22 +02:00
Martin Sustrik
dfdaff5eba
XREP-style prefixing/trimming messages removed
2010-03-20 10:58:59 +01:00
Martin Hurton
f9521c6b6a
PGM: implement flow control
2010-03-12 11:07:38 +01:00
Martin Hurton
61ee6fae53
Implement flow control
...
This commit introduces the necessary changes necessary
for implementing flow control. None of the socket types
implements the flow control yet. The code will crash when
the flow control is enabled and the thw lwm is reached.
The following commits will add flow-control support for
individual socket types.
2010-03-12 11:07:38 +01:00
Martin Sustrik
b9caa319e2
Multi-hop REQ/REP, part XI., finalise the XREQ/XREP functionality
2010-02-16 18:30:38 +01:00
Martin Sustrik
f5ce81f289
Multi-hop REQ/REP, part VIII., new blob_t type used for holding identity
2010-02-13 14:07:30 +01:00
Martin Sustrik
36a576370c
Multi-hop REQ/REP, part I., tracerouting switched on on XREP socket
2010-02-12 15:57:54 +01:00
Martin Sustrik
9cee8f9c3e
problem with PGM messages larger than 1 MTU fixed
2010-02-02 15:11:25 +01:00
Martin Sustrik
4f6baf4dde
Copyrights transferred from FastMQ to iMatix
2010-01-05 08:29:35 +01:00
malosek
9bda63cd63
fixed minor gcc warning in src/pgm_receiver.cpp
2009-12-31 16:35:04 +01:00
Martin Sustrik
5852db451a
PGM code cleanup
2009-12-28 11:51:06 +01:00
Martin Sustrik
aebff623f3
ZMQII-28: Bidirectional introduction on TCP connection establishment
2009-12-23 19:37:56 +01:00
Martin Sustrik
8aa0908635
all news converted to nothrow variant
2009-12-15 23:49:55 +01:00
Martin Sustrik
e49115224a
zmq_encoder/decoder are able to add/trim prefixes from messages; fair queueing and load balancing algorithms factorised into separate classes
2009-12-15 09:09:19 +01:00
Martin Sustrik
c43aded531
debug code removed from PGM engines
2009-12-13 11:27:43 +01:00
Martin Sustrik
f4ac8d7a44
OpenPGM v1 support removed
2009-12-13 09:56:02 +01:00
Martin Sustrik
73b765e4b4
PGM transport fixed
2009-12-13 09:11:08 +01:00
malosek
7afc61ae7c
0MQ compilable on winXP mingw with --with-pgm2 option
2009-10-06 12:57:24 +02:00
malosek
64e68e7486
detecting data loss for PGM2 receiver
2009-09-29 13:56:19 +02:00
malosek
39d915ded8
PGM2 sender
2009-09-28 18:06:06 +02:00
malosek
72c5c5fff4
--with-pgm2 compilable
2009-09-24 16:23:49 +02:00
malosek
33afdcd1ad
added --with-pgm2 into build system
2009-09-24 12:43:35 +02:00
malosek
85cbd7f83c
added PGM bus functionality
2009-09-22 15:12:51 +02:00
malosek
03d494d4f0
added udp:// transport prefix for PGM UDP encapsulation
2009-09-16 15:36:38 +02:00
malosek
9fbdcc7940
removed reset method from zmq_decoder_t
2009-09-16 10:35:23 +02:00
malosek
969522bbf5
added OpenPGM receiver - ZMQ_SUB
2009-09-16 10:11:01 +02:00
