Acknowledging incoming messages
Acknowledging incoming messages, including: determining, by an acknowledgement dispatching module, whether an incoming message has been received in an active message queue; responsive to determining that the incoming message has been received in the active message queue, resetting, by the acknowledgement dispatching module, an acknowledgment iteration counter; incrementing, by the acknowledgement dispatching module, the acknowledgment iteration counter; determining, by the acknowledgement dispatching module, whether the acknowledgment iteration counter has reached a predetermined threshold; and responsive to determining that the acknowledgment iteration counter has reached the predetermined threshold, processing, by the acknowledgement dispatching module, all messages in the active message queue.
1. A method of acknowledging incoming messages, the method comprising:
determining, by an acknowledgement dispatching module, whether an incoming message has been received in an active message queue;
responsive to determining that the incoming message has been received in the active message queue, resetting, by the acknowledgement dispatching module, an acknowledgment iteration counter, wherein the acknowledgment iteration counter represents a number of times that the acknowledgement dispatching module has checked the active message queue for new messages without finding a new message in the active message queue;
incrementing, by the acknowledgement dispatching module, the acknowledgment iteration counter if it is determined that the incoming message has not been received;
determining, by the acknowledgement dispatching module, whether the acknowledgment iteration counter has reached a predetermined threshold; and
responsive to determining that the acknowledgment iteration counter has reached the predetermined threshold, processing, by the acknowledgement dispatching module, all messages in the active message queue.
2. The method of claim 1 wherein processing all messages in the active message queue further comprises for each message in the active message queue:
sending, by the acknowledgement dispatching module, an acknowledgment message indicating that the message was received; and
moving, by the acknowledgement dispatching module, the message to a processed message queue.
3. The method of claim 2 wherein sending an acknowledgment message indicating that the message was received further comprises coalescing, by the acknowledgement dispatching module, acknowledgement messages directed to the same destination.
4. The method of claim 1 wherein the incoming message is received by a first compute node in a parallel computer from a second compute node in the parallel computer.
5. The method of claim 1 further comprising:
receiving, by the acknowledgement dispatching module, an incoming message;
determining, by the acknowledgement dispatching module, whether an acknowledgment for the incoming message can be coalesced with acknowledgments for one or more additional messages in the active message queue;
responsive to determining that an acknowledgment for the incoming message can be coalesced with acknowledgments for one or more additional messages in the active message queue, coalescing, by the acknowledgement dispatching module, into a single acknowledgment message acknowledgements for the incoming message and for the additional messages in the active message queue; and
moving, by the acknowledgement dispatching module, the incoming message and the additional messages in the active message queue from the active message queue to a processed message queue.