1. 05 Oct, 2015 1 commit
  2. 02 Jun, 2015 1 commit
  3. 22 Jan, 2015 1 commit
  4. 02 May, 2014 2 commits
  5. 02 Jan, 2014 1 commit
  6. 14 Jul, 2013 1 commit
    • Christian Kamm's avatar
      REQ sockets drop replies from unasked peers. · c56d797b
      Christian Kamm authored
      * Add lb_t::sendpipe() that returns the pipe that was used for sending,
        similar to fq_t::recvpipe().
      * Add forwarder functions to dealer_t to access these two.
      * Add logic to req_t to ignore replies on pipes that are not the one
        where the request was sent.
      * Enable test in test_spec_req.
      c56d797b
  7. 22 Jun, 2013 1 commit
  8. 06 Jun, 2013 1 commit
  9. 12 Mar, 2013 1 commit
    • Pieter Hintjens's avatar
      Removed corporate advertisements from source file headers · f0f16505
      Pieter Hintjens authored
      Copyrights had become ads for Sustrik's corporate sponsors, going against the original
      agreement to share copyrights with the community (that agreement was: one line stating
      iMatix copyright + one reference to AUTHORS file). The proliferation of corporate ads
      is also unfair to the many individual authors. I've removed ALL corporate title from
      the source files so the copyright statements can now be centralized in AUTHORS and
      source files can be properly updated on an annual basis.
      f0f16505
  10. 09 Nov, 2012 1 commit
  11. 27 Aug, 2012 1 commit
    • Arthur O'Dwyer's avatar
      Silence all "unused parameter" warnings from Clang. · 3b984d40
      Arthur O'Dwyer authored
      Compiling without warnings is a good goal, because it makes
      new warnings (which probably indicate bugs) stand out rather
      than getting lost in the spam.
      
      My fixes fall into two categories:
      
          - Adding (void) casts of unused parameters, where their
            unusedness seems like a TODO (or in some cases a bug?).
      
          - Removing parameter names altogether, where the function
            is clearly a stub that will never use its parameters.
      
      Should be no change in behavior.
      3b984d40
  12. 12 Jun, 2012 2 commits
    • Ian Barber's avatar
      Allow blocking while connect() is completing · e5904e63
      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.
      e5904e63
    • Ian Barber's avatar
      Revert "After speaking with Ben Gray and the discussion on the mailing list,… · 95cbad38
      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.
      95cbad38
  13. 01 Jun, 2012 1 commit
    • Ian Barber's avatar
      After speaking with Ben Gray and the discussion on the mailing list, this is an… · fe3fb419
      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.
      fe3fb419
  14. 31 May, 2012 2 commits
  15. 28 May, 2012 1 commit
  16. 28 Mar, 2012 1 commit
  17. 15 Feb, 2012 1 commit
  18. 10 Feb, 2012 1 commit
  19. 01 Nov, 2011 2 commits
  20. 31 Oct, 2011 1 commit
  21. 23 Jun, 2011 1 commit
  22. 20 Jun, 2011 1 commit
  23. 23 May, 2011 1 commit
  24. 22 May, 2011 1 commit
    • 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
  25. 15 May, 2011 1 commit
  26. 21 Apr, 2011 1 commit
  27. 20 Mar, 2011 1 commit
  28. 02 Mar, 2011 1 commit
  29. 15 Dec, 2010 1 commit
  30. 30 Oct, 2010 1 commit
  31. 18 Sep, 2010 2 commits
  32. 10 Sep, 2010 1 commit
  33. 07 Sep, 2010 1 commit
  34. 01 Sep, 2010 1 commit
  35. 25 Aug, 2010 1 commit