-
Notifications
You must be signed in to change notification settings - Fork 58
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
zmq4: implement proper REQ and REP socket #76
Conversation
This fixes problems with REP sending messages to all connected peers rather than to the originating peer. The REQ/REP semantics now matches the recommended implementation behavior as specified in the ZMQ RFC. In particular: * REQ shall route outgoing messages to connected peers using a round-robin strategy * REQ shall block on sending, or return a suitable error, when it has no connected peers. * REP shall not block on sending Thus, this changes the behavior a bit as REP no longer blocks on Send. resolves go-zeromq#70
Codecov Report
@@ Coverage Diff @@
## master #76 +/- ##
=========================================
- Coverage 68.36% 67.86% -0.5%
=========================================
Files 27 27
Lines 2023 2247 +224
=========================================
+ Hits 1383 1525 +142
- Misses 546 621 +75
- Partials 94 101 +7
Continue to review full report at Codecov.
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
thanks for tackling this issue.
This fixes problems with REP sending messages to all connected peers
rather than to the originating peer.
The REQ/REP semantics now matches the recommended implementation behavior as specified in the ZMQ RFC.
In particular:
round-robin strategy
connected peers.
Thus, this changes the behavior a bit as REP no longer blocks on Send.
resolves #70