- 07 Feb, 2013 1 commit
-
-
montoyaedu authored
-
- 31 Jan, 2013 1 commit
-
-
Pieter Hintjens authored
-
- 04 Dec, 2012 1 commit
-
-
Stefan Radomski authored
- fixes LIBZMQ-476 and LIBZMQ-475
-
- 29 Oct, 2012 1 commit
-
-
Hardeep authored
- Created a new option ZMQ_ROUTER_RAW_SOCK - Added new raw_encoder and raw_decoder to receive and send messages in raw form to remote client - Added test case file tests/test_raw_sock.cpp o To create a raw router sock set the ZMQ_ROUTER_RAW_SOCK option o ZMQ_MSGMORE flag is ignored for non-id messages o To terminate a remote connection send id message followed by zero length data message
-
- 08 Oct, 2012 1 commit
-
-
Pieter Hintjens authored
-
- 16 Jun, 2012 1 commit
-
-
Kobolog authored
-
- 12 Jun, 2012 2 commits
-
-
Ian Barber authored
This patch, salvaged from a trainwreck accidental merge earlier, adds a new sockopt, ZMQ_DELAY_ATTACH_ON_CONNECT which prevents a end point being available to push messages to until it has fully connected, making connect work more like bind. This also applies to reconnecting sockets, which may cause message loss of in-queue messages, so it is sensible to use this in conjunction with a low HWM and potentially an alternative acknowledgement path. Notes on most of the individual commits can be found the repository log.
-
Ian Barber authored
Revert "After speaking with Ben Gray and the discussion on the mailing list, this is an attempt to create a sockopt to allow connecting pipes to not immediately be available for traffic. The problem is in a PUSH to many PULL situation, where there is a connect to a PULL which is not there. This connect will immediately create a pipe (unlike bind), and traffic will be load balanced to that pipe. This means if there is a persistently unavailable end point then the traffic will queue until HWM is hit, and older messages will be lost." This reverts commit fe3fb419.
-
- 01 Jun, 2012 1 commit
-
-
Ian Barber authored
After speaking with Ben Gray and the discussion on the mailing list, this is an attempt to create a sockopt to allow connecting pipes to not immediately be available for traffic. The problem is in a PUSH to many PULL situation, where there is a connect to a PULL which is not there. This connect will immediately create a pipe (unlike bind), and traffic will be load balanced to that pipe. This means if there is a persistently unavailable end point then the traffic will queue until HWM is hit, and older messages will be lost. This patch adds a sockopt ZMQ_DELAY_ATTACH_ON_CONNECT, which if set to 1 will attempt to preempt this behavior. It does this by extending the use of the session_base to include in the outbound as well as the inbound pipe, and only associates the pipe with the socket once it receives the connected callback via a process_attach message. This works, and a test has been added to show so, but may introduce unexpected complications. The shutdown logic in this class has become marginally more awkward because of this, requiring the session to serve as the sink for both pipes if shutdown occurs with a still-connecting pipe in place. It is also possible there could be issues around flushing the messages, but as I could not directly think how to create such an issue I have not written any code with regards to that. The documentation has been updated to reflect the change, but please do check over the code and test and review.
-
- 04 May, 2012 1 commit
-
-
Lourens Naudé authored
-
- 21 Apr, 2012 1 commit
-
-
Sergey KHripchenko authored
it works but rises very serious questions. Please add license header by your choice. This file for 99% resemble crossroads-io/tests/shutdown.cpp
-
- 18 Feb, 2012 1 commit
-
-
Mikko Koppanen authored
-
- 17 Feb, 2012 1 commit
-
-
skaller authored
-
- 16 Feb, 2012 1 commit
-
-
Staffan Gimåker authored
This allows us to actually report an error to the caller on resolve failure, rather than asserting later on in the io thread. Signed-off-by:
Staffan Gimåker <staffan@spotify.com>
-
- 04 Feb, 2012 1 commit
-
-
skaller authored
-
- 21 Nov, 2011 1 commit
-
-
Philip Kovacs authored
Signed-off-by:
Philip Kovacs <phil@philkovacs.com>
-
- 06 Nov, 2011 1 commit
-
-
Chuck Remes authored
The new function allows to retrieve options (flags) from zmq_msg_t. Signed-off-by:
Chuck Remes <cremes@mac.com> Renamed from zmq_msg_flags to zmq_getmsgopt Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 01 Nov, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 13 Sep, 2011 1 commit
-
-
Mikko Koppanen authored
Signed-off-by:
Mikko Koppanen <mkoppanen@php.net> Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 11 Jul, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 23 Jun, 2011 1 commit
-
-
Martin Sustrik authored
So far the requests in req/rep pattern were delivered to and processed by worker even though the original requester was dead. Thus, the worker processing replies with noone to deliver results to. This optimisation drops requests in two situations: 1. Queued inbound requests in XREP socket when peer disconnects. 2. Queued outbound requests in XREQ when socket is closed. Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 22 Jun, 2011 1 commit
-
-
Martin Sustrik authored
This patch introduces two changes: 1. 32-bit ID is used to identify the peer instead of UUID 2. REQ socket seeds the label stack with unique 32-bit request ID It also drops any replies with non-matching request ID Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 20 Jun, 2011 1 commit
-
-
Martin Sustrik authored
Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 17 Jun, 2011 1 commit
-
-
Fabien Ninoles authored
- Add doc and tests - Add options and setup - Wait using poll/select Signed-off-by:
Fabien Ninoles <fabien@tzone.org> Signed-off-by:
Martin Sustrik <sustrik@250bpm.com>
-
- 30 Jan, 2011 1 commit
-
-
Mikko Koppanen authored
Signed-off-by:
Mikko Koppanen <mkoppanen@php.net>
-
- 20 Jan, 2011 1 commit
-
-
Mikko Koppanen authored
Signed-off-by:
Mikko Koppanen <mkoppanen@php.net>
-
- 17 Nov, 2010 1 commit
-
-
Mikko Koppanen authored
MinGW32 defines __int64_t as long long, which causes the build to fail unless -Wno-long-long is used. In addition the shutdown_stress test isn't currently compatible with Win. Signed-off-by:
Mikko Koppanen <mkoppanen@php.net>
-
- 01 Oct, 2010 1 commit
-
-
Martin Sustrik authored
-
- 28 Aug, 2010 1 commit
-
-
Guido Goldstein authored
-
- 27 Aug, 2010 2 commits
-
-
Guido Goldstein authored
-
Martin Lucina authored
The test suite uses the standard automake support. Tests are always built, but run only when you do a "make check".
-