Signaling communication events in a computer network

• US 6,070,189 A
• Filed: 08/26/1997
• Issued: 05/30/2000
• Est. Priority Date: 08/26/1997
• Status: Expired due to Term

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Nieplocha, Jaroslaw, Govindaraju, Rama K., Kim, Chulho, Bender, Carl A., Gildea, Kevin J., DiNicola, Paul D., Shah, Gautam H., Mirza, Jamshed H.
• Primary Examiner(s): Meky, Moustafa M.
• Application Number:
  US08/921,757
• Time in Patent Office: 1,008 Days
• Field of Search: 709/200, 709/201, 709/217, 709/218, 709/219, 709/224, 709/234, 709/236, 709/237
• US Class Current: 709/224
• CPC Class Codes: G06F 15/17375 One dimensional, e.g. linear array, ring
• CPC Class Codes: G06F 9/542 Event management; Broadcasting; Multicasting; Notifications

Abstract

A method, apparatus and program product for detecting a communication event in a distributed parallel data processing system in which a message is sent from an origin to a target. A low-level application programming interface (LAPI) is provided which has an operation for associating a counter with a communication event to be detected. The LAPI increments the counter upon the occurrence of the communication event. The number in the counter is monitored, and when the number increases, the event is detected. A completion counter in the origin is associated with the completion of a message being sent from the origin to the target. When the message is completed, LAPI increments the completion counter such that monitoring the completion counter detects the completion of the message. The completion counter may be used to insure that a first message has been sent from the origin to the target and completed before a second message is sent.

Claims

1. In a data processing system having a communication system for sending messages from a sender to a receiver, a method for enabling a user to detect the occurrence of communication events, said method comprising:

assigning a user readable counter to a communication event to be monitored;

incrementing the user readable counter when the communication event occurs; and

monitoring by the user, the count in said user readable counter to determine when the count has been incremented, thereby detecting the occurrence of the event.

2. The method of claim 1 further comprising sending multiple messages between said sender and said receiver, said multiple messages grouped together to form an event to be detected by the user.

3. The method of claim 1 wherein said monitoring comprises polling said user readable counter to ascertain its value.

4. The method of claim 1 wherein said monitoring comprises sending a signal to the user when the count in said counter reaches a specified value.

5. The method of claim 1 said user readable counter is also user modifiable, said method further comprising before said incrementing step, decrementing by said user, the number in said user readable counter by a specific value, thereby providing to the user, a wait for waiting an indicated number of events.

6. The method of claim 1 further comprising assigning each event of multiple events to respective ones of multiple user readable counters, and monitoring said multiple user readable counters for detecting the occurrence of any of said multiple events.

7. In a data processing system having an origin, an origin buffer, a target, and a target buffer, and a message handling system for sending a message from the origin buffer to the target buffer to be completed at the target, a method of enabling a user to detect the occurrence of events, said method comprising:

selectively associating a user readable origin counter with the origin buffer;

incrementing the user readable origin counter when the message is sent from the origin buffer to the target buffer; and

monitoring the count in the user readable origin counter for an increase, thereby enabling the user to detect that the origin buffer is available.

8. The method of claim 7 further comprising:

selectively associating a user readable target counter with the target buffer;

incrementing the user readable target counter when the message is received by the target buffer from the origin buffer; and

monitoring the count in said user readable target counter for an increase, thereby enabling the user to detect that the operation on the target buffer is complete.

9. In a data processing system having an origin, an origin buffer, a target, and a target buffer, and a message handling system for sending a message from the origin buffer to the target buffer to be completed at the target, a method comprising:

associating an origin counter with the origin buffer;

incrementing the origin counter when the message is sent from the origin buffer to the target buffer;

monitoring the count in the origin counter for an increase, thereby detecting that the origin buffer is available;

associating a target counter with the target buffer;

incrementing the target counter when the message is received by the target buffer from the origin buffer; and

monitoring the count in said target counter for an increase, thereby detecting that the operation on the target buffer is complete;

associating a completion counter with the completion of the message;

sending an increment message from the target to the completion counter when the message is completed at the target;

incrementing the number in the completion counter responsive to said increment message; and

monitoring the number in the completion counter to detect an increase, thereby detecting the completion of the message.

10. The method of claim 9 further comprising:

waiting for the increase in the count in said completion counter; and

after detecting said increase in the count in said completion counter, sending an additional message from said origin to said target, thereby insuring that the first sent message is complete before sending the additional message.

11. In a data processing system having a communication system for sending messages from a sender to a receiver, an apparatus enabling a user to detect the occurrence of communication events, said apparatus comprising:

a user readable counter;

a low-level application programming interface (LAPI) is programmable by the user, said LAPI having a first operation for associating said user readable counter with an event to be detected, and a second operation for incrementing the user readable counter when the communication event occurs; and

a monitoring apparatus for monitoring the count in said counter to determine when the count has been incremented, thereby enabling the user to detect the occurrence of the event.

12. The apparatus of claim 11 further wherein said LAPI associates sending a set number of multiple messages between said sender and said receiver to said user readable counter as a single event to be detected by the user.

13. The apparatus of claim 11 wherein said monitoring apparatus polls said user readable counter to ascertain its value.

14. The apparatus of claim 11 wherein said monitoring apparatus registers a handler associated with the user readable counter which will be invoked when the user readable counter reaches a specified value, said handler raising an interrupt when the count in said user readable counter reaches a specified value.

15. The apparatus of claim 11 wherein said readable counter is modifiable by the user, and said LAPI is programmed by the user to decrement the number in said user readable counter by a specific value, thereby providing to the user, a wait for waiting an indicated number of events.

16. The apparatus of claim 11 further comprising:

multiple user readable counters;

said LAPI assigns a separate event from multiple events to respective ones of said multiple user readable counters; and

said monitoring apparatus monitors said multiple user readable counters for enabling a user to detect the occurrence of any of said multiple events.

17. An apparatus for enabling a user to detect the occurrence of communication events in a data processing system, said apparatus comprising:

an origin;

a target;

an origin buffer in said origin;

a target buffer in said target;

a message handling system for sending a message from the origin buffer to the target buffer to be completed at the target;

user readable origin counter;

a low-level application programming interface (LAPI) having an operation for selectively associating said user readable origin counter to said origin buffer, and an incrementing operation for incrementing the count in the user readable origin counter when a message is sent from said origin buffer to said target buffer; and

a monitoring apparatus for monitoring the count in said user readable origin counter for an increase, thereby enabling the user to detect that the origin buffer is available.

18. The apparatus of claim 17 further comprising:

a user readable target counter;

said LAPI further having an operation for selectively associating said user readable target counter with said target buffer, and an operation for incrementing said user readable target counter when the message is received by said target buffer from the origin buffer; and

said monitoring apparatus monitors the count in said target counter for an increase, thereby enabling the user to detect that the operation on the target buffer is complete.

19. An apparatus for detecting communication events in a data processing system, said apparatus comprising:

an origin;

a target;

an origin buffer in said origin;

a target buffer in said target;

a message handling system for sending a message from the origin buffer to the target buffer to be completed at the target;

an origin counter;

a low-level application programming interface (LAPI) having an operation for associating said origin counter to said origin buffer, and an incrementing operation for incrementing the count in the origin counter when a message is sent from said origin buffer to said target buffer;

a monitoring apparatus for monitoring the count in said origin counter for an increase, thereby detecting that the origin buffer is available,

a target counter;

said LAPI further having an operation for associating said target counter with said target buffer, and an operation for incrementing said target counter when the message is received by said target buffer from the origin buffer; and

said monitoring apparatus monitors the count in said target counter for an increase, thereby detecting that the operation on the target buffer is complete;

a completion counter;

said LAPI further having an operation for associating said completion counter with the completion of the message, and an operation for sending an increment message from the target to the completion counter when the message is completed at the target; and

said monitoring apparatus monitors the number in the completion counter to detect an increase, thereby detecting the completion of the message.

20. A program product recorded on a computer readable media for use in a data processing system having a communication system for sending messages from a sender to a receiver, the program product including a method for enabling a user to detect the occurrence of communication events comprising:

assigning a user readable counter to a communication event to be monitored;

incrementing the user readable counter when the communication event occurs; and

monitoring the count in said user readable counter to determine when the count has been incremented, thereby enabling the user to detect the occurrence of the event.

21. The program product of claim 20 further comprising sending multiple messages between said sender and said receiver, said multiple messages grouped together to form an event to be detected.

22. The program product of claim 20 wherein said monitoring comprises polling said user readable counter to ascertain its value.

23. The program product of claim 20 wherein said monitoring comprises sending a signal to the user when the count in said counter reaches a specified value.

24. The program product of claim 20 further comprising before said incrementing step, decrementing the number in said user readable counter by a specific value, thereby providing to the user, a wait for waiting an indicated number of events.

25. The program product of claim 20 further comprising assigning each event of multiple events to respective ones of multiple user readable counters, and monitoring said multiple user readable counters for enabling the user to detect the occurrence of any of said multiple events.

26. A program product recorded on a computer readable media for use in a data processing system having an origin, an origin buffer, a target, and a target buffer, and a message handling system for sending a message from the origin buffer to the target buffer to be completed at the target, the program product including a method enabling a user to detect the occurrence of events comprising:

selectively associating a user readable origin counter with the origin buffer;

incrementing the user readable origin counter when the message is sent from the origin buffer to the target buffer; and

monitoring the count in the user readable origin counter for an increase, thereby enabling the user to detect that the origin buffer is available.

27. The program product of claim 26 further comprising:

selectively associating a user readable target counter with the target buffer;

incrementing the user readable target counter when the message is received by the target buffer from the origin buffer; and

monitoring the count in said user readable target counter for an increase, thereby enabling a user to detect that the operation on the target buffer is complete.

28. A program product recorded on a computer readable media for use in a data processing system having an origin, an origin buffer, a target, and a target buffer, and a message handling system for sending a message from the origin buffer to the target buffer to be completed at the target, the program product including a method comprising:

associating an origin counter with the origin buffer;

incrementing the origin counter when the message is sent from the origin buffer to the target buffer; and

monitoring the count in the origin counter for an increase, thereby detecting that the origin buffer is available;

associating a target counter with the target buffer;

incrementing the target counter when the message is received by the target buffer from the origin buffer; and

monitoring the count in said target counter for an increase, thereby detecting that the operation on the target buffer is complete;

associating a completion counter with the completion of the message;

sending an increment message from the target to the completion counter when the message is completed at the target;

incrementing the number in the completion counter responsive to said increment message; and

monitoring the number in the completion counter to detect an increase, thereby detecting the completion of the message.

29. The program product of claim 28 further comprising:

waiting for the increase in the count in said completion counter; and

after detecting said increase in the count in said completion counter, sending an additional message from said origin to said target, thereby insuring that the first sent message is complete before sending the additional message.