Completion processing for data communications instructions

• US 8,751,595 B2
• Filed: 11/19/2012
• Issued: 06/10/2014
• Est. Priority Date: 01/06/2011
• Status: Expired due to Fees

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Blocksome, Michael A., Kumar, Sameer, Parker, Jeffrey J.
• Primary Examiner(s): Etienne, Ario
• Assistant Examiner(s): MENDAYE, KIDEST H
• Application Number:
  US13/680,772
• Publication Number:
  US 20130097263A1
• Time in Patent Office: 568 Days
• Field of Search: 709/206, 709/250, 709232-235, 712/200
• US Class Current: 709/206
• CPC Class Codes: G06F 15/17306 Intercommunication techniques
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

Completion processing of data communications instructions in a distributed computing environment with computers coupled for data communications through communications adapters and an active messaging interface (‘AMI’), injecting for data communications instructions into slots in an injection FIFO buffer a transfer descriptor, at least some of the instructions specifying callback functions; injecting a completion descriptor for each instruction that specifies a callback function into an injection FIFO buffer slot having a corresponding slot in a pending callback list; listing in the pending callback list callback functions specified by data communications instructions; processing each descriptor in the injection FIFO buffer, setting a bit in a completion bit mask corresponding to the slot in the FIFO where the completion descriptor was injected; and calling by the AMI any callback functions in the pending callback list as indicated by set bits in the completion bit mask.

Claims

1. A method of completion processing for data communications instructions in a distributed computing environment, the distributed computing environment including a plurality of computers coupled for data communications through communications adapters and an active messaging interface (‘

AMI’

), the method comprising;

injecting, by the AMI for each of a sequence of data communications instructions into a slot in an injection FIFO buffer of a data communication adapter, a transfer descriptor specifying to the communications adapter a transfer of payload data according to each data communications instruction, at least some of the instructions specifying callback functions;

injecting by the AMI a completion descriptor for each instruction that specifies a callback function into the next slot after that instruction'"'"'s transfer descriptor in the injection FIFO buffer, the slot in which the completion descriptor is injected having a corresponding slot in a pending callback list;

listing, by the AMI in the corresponding slot in the pending callback list for each data communications instruction that specifies a callback function, the callback function specified by that instruction;

processing by the communications adapter each descriptor in the injection FIFO buffer, including transferring payload data as specified by each transfer descriptor and setting, as payload data for each completion descriptor, a bit that corresponds in a completion bit mask to the slot in the FIFO where the completion descriptor was injected, the completion bit mask comprising a plurality of bits, each bit corresponding to a slot in the injection FIFO buffer; and

calling by the AMI any callback functions in the pending callback list for which transfers of payload data have been completed as indicated by set bits in the completion bit mask.

2. The method of claim 1 further comprising determining by the AMI for each data communications instruction that space is available in the injection FIFO buffer of the communications adapter for that instruction'"'"'s injection descriptor, including determining that a slot is open in the injection FIFO buffer and that a corresponding slot contains a null value in the pending callback list.

3. The method of claim 1 wherein calling callback functions further comprises calling each callback function whose position in the pending callback list corresponds to a set bit in the completion bit mask, including resetting each such bit after calling the corresponding callback function.

4. The method of claim 1 wherein injecting a completion descriptor further comprises:

copying a predefined model completion descriptor from a position in an array of predefined model completion descriptors that corresponds to the slot in which the completion descriptor is injected in the injection FIFO buffer, the array of predefined model completion descriptors comprising predefined model completion descriptors for all slots in the injection FIFO buffer.

5. The method of claim 1 wherein setting a bit that corresponds in a completion bit mask to the slot in the FIFO where the completion descriptor was injected further comprises:

copying a predefined completion payload bit mask from a position in an array of predefined completion payload bit masks that corresponds to the slot in which the completion descriptor is injected in the injection FIFO buffer, the array of predefined completion payload bit masks comprising predefined completion payload bit masks corresponding to each slot in the injection FIFO buffer.

6. The method of claim 1 wherein setting a bit that corresponds in a completion bit mask to the slot in the FIFO where the completion descriptor was injected further comprises:

copying a predefined completion payload bit mask from a position in an array of predefined completion payload bit masks that corresponds to the slot in which the completion descriptor is injected in the injection FIFO buffer; and

combining the completion bit mask and the copied completion payload bit mask with a logical OR operation.

7. The method of claim 1 wherein each completion descriptor specifies:

as payload data for a data transfer a predefined completion payload bit mask in an array of predefined completion payload bit masks;

the completion bit mask as a target of a data transfer; and

a store-OR memory operation as a mode of a data transfer.

8. The method of claim 1 wherein:

listing the callback function further comprises incrementing a pending callback counter for each listed callback function; and

calling callback functions further comprises calling callback functions only when the pending callback counter value is greater than zero and decrementing the pending callback counter for each callback function called.