Remote memory ring buffers in a cluster of data processing nodes

A data processing system, comprising:

• a target node including a ring buffer in local memory thereof;
• and
• a plurality of initiator nodes connected to each other and to the target node through a fabric, wherein each of the initiator nodes includes:
• an inter-node messaging module comprising a plurality of sets of registers, wherein each set of registers is configured to define a GET/PUT context instance;
• and
• a plurality of data processing cores each coupled to the inter-node messaging module, wherein each of the plurality of data processing cores is configured to map a user level process thereof to one of the sets of registers and thereby to a respective GET/PUT context instance;
• wherein the user level process is configured to utilize the respective GET/PUT context instance to perform a GET/PUT action to the ring buffer of the target node through the fabric;
• and
• wherein each of the plurality of the data processing cores is further configured to modify a memory management unit page table to include a virtual address page for the user level process that maps to a physical address page for the respective GET/PUT context instance.

A method for performing remote memory GET/PUT functionality between data processing nodes interconnected through a fabric, the method comprising:

• mapping, at a first data processing node, a user level process to a particular set of a plurality of sets of registers, wherein the plurality of set of registers are on an inter-node messaging module of the first data processing node, wherein each set of registers is configured to define a GET/PUT context instance such that the user level process is mapped to a respective GET/PUT context instance, and wherein said mapping the user level processes to the respective GET/PUT context instance includes modifying a memory management unit page table to include a virtual address page for the user level process that maps to a physical address page for the respective GET/PUT context instance;
• assessing, by the user level process, a status of a previous GET/PUT action to a ring buffer in local memory of a second data processing node, wherein the previous GET/PUT action used the same respective GET/PUT context instance;
• populating, by the user level process, fields of the respective GET/PUT context instance with information for a current GET/PUT action to the ring buffer in response to determining that the previous GET/RUT action is completed;
• creating, by the inter-node messaging module of the first data processing node, a GET/PUT request based on the information that populates the fields of the respective GET/PUT context instance, wherein the information includes an identifier for the second data processing node and a ring buffer identifier;
• and
• causing, by the inter-node messaging module of the first data processing node, the GET/PUT request to be transmitted for reception by the second data processing node.

A non-transitory computer-readable medium having instructions stored thereon that, upon execution by a processing system, cause the processing system to:

• map a user level process of a first data processing node to a particular set of a plurality of sets of registers of the first processing node, wherein each set of registers define a GET/PUT context instance such that the user level process is mapped to a respective GET/PUT context instance;
• assess a status of a previous GET/PUT action to a ring buffer in local memory of a second data processing node, wherein the previous GET/PUT action used the same respective GET/PUT context instance;
• populate fields of the respective GET/PUT context instance with information for a current GET/PUT action to the ring buffer in response to a determination that the previous GET/PUT action is completed;
• create a GET/PUT request based on the information that populates the fields of the respective GET/PUT context instance, wherein the information includes an identifier for the second data processing node and a ring buffer identifier;
• and
• cause the GET/PUT request to be transmitted for reception by the second data processing node.