From 5f7289e1f8e1427c9214c8e3e96ad56b1f868d53 Mon Sep 17 00:00:00 2001 From: Garrett D'Amore Date: Wed, 4 Apr 2018 13:36:54 -0700 Subject: fixes #334 Separate context for state machines from sockets This provides context support for REQ and REP sockets. More discussion around this is in the issue itself. Optionally we would like to extend this to the surveyor pattern. Note that we specifically do not support pollable descriptors for non-default contexts, and the results of using file descriptors for polling (NNG_OPT_SENDFD and NNG_OPT_RECVFD) is undefined. In the future, it might be nice to figure out how to factor in optional use of a message queue for users who want more buffering, but we think there is little need for this with cooked mode. --- docs/man/nng_req.7.adoc | 28 ++++++++++++++++++++++------ 1 file changed, 22 insertions(+), 6 deletions(-) (limited to 'docs/man/nng_req.7.adoc') diff --git a/docs/man/nng_req.7.adoc b/docs/man/nng_req.7.adoc index 9b956172..221023c4 100644 --- a/docs/man/nng_req.7.adoc +++ b/docs/man/nng_req.7.adoc @@ -53,23 +53,37 @@ The _req_ protocol is the requester side, and the === Socket Operations The <> functions create a requester socket. -This socket may be used to send messages (requests), -and then to receive replies. +This socket may be used to send messages (requests), and then to receive replies. + Generally a reply can only be received after sending a request. (Attempts to receive a message will result in `NNG_ESTATE` if there is no outstanding request.) +Furthermore, only a single receive operation may be pending at a time. +Attempts to post more receive operations concurrently will result in +`NNG_ESTATE`. + Requests may be canceled by sending a different request. This will cause the requester to discard any reply from the earlier request, but it will not stop a replier from processing a request it has already received or terminate a request that has already been placed on the wire. -Attempts to receive on a socket with no outstanding requests will result -in `NNG_ESTATE`. - <> mode sockets ignore all these restrictions. +=== Context Operations + +This protocol supports the creation of <> for concurrent +use cases using <>. +The `NNG_OPT_REQ_RESENDTIME` value may be configured differently +on contexts created this way. + +Each context may have at most one outstanding request, and operates +independently from the others. +The restrictions for order of operations with sockets apply equally +well for contexts, except that each context will be treated as if it were +a separate socket. + === Protocol Versions Only version 0 of this protocol is supported. @@ -82,7 +96,7 @@ The following protocol-specific option is available. ((`NNG_OPT_REQ_RESENDTIME`)):: This read/write option is a duration (32-bit unsigned integer) representing - a relative number of milliseconds. + a relative number of milliseconds. When a new request is started, a timer of this duration is also started. If no reply is received before this timer expires, then the request will be resent. (Requests are also automatically resent if the peer to whom @@ -129,7 +143,9 @@ request ID it originally used for the request. == SEE ALSO +<>, <>, <>, +<>, <>, <> -- cgit v1.2.3-70-g09d2