Method and system for transmitting an application message between nodes of a clustered data processing system

A non-transitory computer storage medium including a computer program product for communicating an application message between a plurality of nodes of a data processing system cluster, the computer storage medium comprising:

• computer code for determining, at a first time, whether one or more application messages for transmittal from the sending node to the receiving may be currently transmitted, wherein the computer code for determining comprises:
• computer code for preparing, by a receiving node of the plurality of nodes, a first buffer associated with the receiving node for receiving application messages, and
• computer code for transmitting, by the receiving node, a read request to a sending node of the plurality of nodes, wherein:
• the read request is transmitted in response to the first buffer being prepared for receiving messages, and
• the read request comprises a reference to the first buffer and commanding the sending node to transmit one or more application messages to the first buffer;
• computer code for determining whether a second buffer associated with the sending node comprises the one or more application messages in response to a receipt, at the sending node, of the read request;
• computer code for determining whether the first buffer includes a sufficient amount of available memory for storing the one or more application messages;
• computer code for determining whether the read request has been received at the sending node;
• computer code for immediately processing the one or more application messages if the second buffer comprises the one or more application messages at the first time;
• computer code for recording, at the sending node, the read request until the second buffer comprises the one or more application messages if the second buffer does not comprise the one or more application messages at the first time;
• computer code for determining, at a second time, that the second buffer comprises the one or more application messages;
• and
• computer code for processing the read request in response to the determining at the second time.

A system for communicating an application message between a plurality of nodes, comprising:

• a first buffer;
• a second buffer;
• a sending node associated and in communication with the second buffer;
• and
• a receiving node in communication with the sending node and associated and in communication with the first buffer, the receiving node configured for:
• preparing the first buffer for receiving data,
• transmitting a read request to the sending node, wherein:
• the read request is transmitted in response to the first buffer being prepared for receiving data, and
• the read request comprises a reference to the first buffer and requesting the sending node to transmit data to the first buffer;
• the sending node configured for:
• receiving the read request,
• determining if the second buffer includes the requested data,
• immediately processing the read request at a first time if the second buffer includes the requested data,
• transmitting the requested data to the first buffer when the read request is processed at the first time,
• recording the read request if the second buffer does not comprise the requested data at the first time, and
• suspending processing of the read request, in the sending node, until the second buffer comprises the requested data if the second buffer does not comprise the requested data at the first time.