Man Page: rmr_rts_msg¶
RMR LIBRARY FUNCTIONS¶
#include <rmr/rmr.h> rmr_mbuf_t* rmr_rts_msg( void* vctx, rmr_mbuf_t* msg );
rmr_rts_msg function sends a message returning it to
the endpoint which sent the message rather than selecting an
endpoint based on the message type and routing table. Other
than this small difference, the behaviour is exactly the same
The send operations in RMR will retry soft send failures until one of three conditions occurs:
The message is sent without error
The underlying transport reports a hard failure
The maximum number of retry loops has been attempted
A retry loop consists of approximately 1000 send attempts without any intervening calls to sleep() or usleep(). The number of retry loops defaults to 1, thus a maximum of 1000 send attempts is performed before returning to the user application. This value can be set at any point after RMR initialisation using the rmr_set_stimeout() function allowing the user application to completely disable retires (set to 0), or to increase the number of retry loops.
Transport Level Blocking¶
The underlying transport mechanism used to send messages is configured in non-blocking mode. This means that if a message cannot be sent immediately the transport mechanism will not pause with the assumption that the inability to send will clear quickly (within a few milliseconds). This means that when the retry loop is completely disabled (set to 0), that the failure to accept a message for sending by the underlying mechanisms (software or hardware) will be reported immediately to the user application.
It should be noted that depending on the underlying transport mechanism being used, it is extremely likely that retry conditions will happen during normal operations. These are completely out of RMR’s control, and there is nothing that RMR can do to avoid or mitigate these other than by allowing RMR to retry the send operation, and even then it is possible (e.g., during connection reattempts), that a single retry loop is not enough to guarantee a successful send.
When crafting a response based on a received message, the user application must take care not to write more bytes to the message payload than the allocated message has. In the case of a received message, it is possible that the response needs to be larger than the payload associated with the inbound message. In order to use the return to sender function, the source information in the original message must be present in the response; information which cannot be added to a message buffer allocated through the standard RMR allocation function. To allocate a buffer with a larger payload, and which retains the necessary sender data needed by this function, the rmr_realloc_payload() function must be used to extend the payload to a size suitable for the response.
On success, a new message buffer, with an empty payload, is
returned for the application to use for the next send. The
state in this buffer will reflect the overall send operation
state and should be
If the state in the returned buffer is anything other than
RMR_OK, the user application may need to attempt a
retransmission of the message, or take other action depending
on the setting of
errno as described below.
In the event of extreme failure, a nil pointer is returned.
In this case the value of
errno might be of some use, for
documentation, but there will be little that the user
application can do other than to move on.
The following values may be passed back in the state field of the returned message buffer.
The message buffer pointer did not refer to a valid message.
The header in the message buffer was not valid or corrupted.
The message type in the message buffer did not map to a known endpoint.
The send failed;
errnohas the possible reason.
The following values may be assigned to
errno on failure.
Parameter(s) passed to the function were not valid, or the underlying message processing environment was unable to interpret the message.
The header information in the message buffer was invalid.
No known endpoint for the message could be found.
The underlying transport refused to accept the message because of a size value issue (message was not attempted to be sent).
The message referenced by the message buffer is corrupt (nil pointer or bad internal length).
Internal RMR error; information provided to the message transport environment was not valid.
Sending was not supported by the underlying message transport.
The device is not in a state that can accept the message.
The device is not able to accept a message for sending. The user application should attempt to resend.
The operation was interrupted by delivery of a signal before the message was sent.
The underlying message environment timed out during the send process.
The underlying message environment is in a shutdown state.
rmr_alloc_msg(3), rmr_call(3), rmr_free_msg(3), rmr_init(3), rmr_payload_size(3), rmr_send_msg(3), rmr_rcv_msg(3), rmr_rcv_specific(3), rmr_ready(3), rmr_fib(3), rmr_has_str(3), rmr_set_stimeout(3), rmr_tokenise(3), rmr_mk_ring(3), rmr_ring_free(3)