Remote Memory Ring Buffers in a Cluster of Data Processing Nodes

摘要

A data processing node has an inter-node messaging module including a plurality of sets of registers each defining an instance of a GET/PUT context and a plurality of data processing cores each coupled to the inter-node messaging module. Each one of the data processing cores includes a mapping function for mapping each one of a plurality of user level processes to a different one of the sets of registers and thereby to a respective GET/PUT context instance. Mapping each one of the user level processes to the different one of the sets of registers enables a particular one of the user level processes to utilize the respective GET/PUT context instance thereof for performing a GET/PUT action to a ring buffer of a different data processing node coupled to the data processing node through a fabric without involvement of an operating system of any one of the data processing cores.

主权项

1. A 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 sets of registers are on an inter-node messaging module of the first data processing node, and wherein each set of registers is configured to define a context instance such that the user level process is mapped to a respective context instance; assessing, by the user level process, a status of a previous action to a ring buffer in local memory of a second data processing node, wherein the previous action used the same respective context instance; populating, by the user level process, fields of the respective context instance with information for a current action to the ring buffer in response to determining that the previous action is completed; creating, by the inter-node messaging module of the first data processing node, a request based on the information that populates the fields of the respective 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 request to be transmitted for reception by the second data processing node.