Communications pacing

• US 9,407,669 B1
• Filed: 07/02/2013
• Issued: 08/02/2016
• Est. Priority Date: 05/16/2013
• Status: Active Grant

• Current Assignee: CA, Inc. (d/b/a CA Technologies) (Broadcom, Inc.)
• Original Assignee: CA, Inc. (d/b/a CA Technologies) (Broadcom, Inc.)
• Inventors: Schaefer, Bruce A.
• Primary Examiner(s): Joo, Joshua
• Application Number:
  US13/933,431
• Time in Patent Office: 1,127 Days
• Field of Search: None
• US Class Current: 1/1
• CPC Class Codes: G06F 9/505 considering the load
• CPC Class Codes: G06F 9/54 Interprogram communication
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues
• CPC Class Codes: G06F 9/547 Remote procedure calls [RPC]; Web services
• CPC Class Codes: H04L 47/10 Flow control; Congestion control
• CPC Class Codes: H04L 47/50 Queue scheduling
• CPC Class Codes: H04L 51/00 User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
• CPC Class Codes: H04L 51/08 Annexed information, e.g. attachments
• CPC Class Codes: H04L 65/1016 IP multimedia subsystem [IMS]
• CPC Class Codes: H04L 67/06 specially adapted for file transfer, e.g. file transfer protocol [FTP]
• CPC Class Codes: H04L 67/1008 based on parameters of servers, e.g. available memory or workload monitoring of computer activity G06F11/30

Abstract

Pacing communications between a message sending computer and a message receiving computer that are both members of a message group of a sysplex includes receiving, by the message receiving computer, a message comprising data sent by the message sending computer; determining, by the message receiving computer, to stop receiving a subsequent message from the message sending computer; and transmitting, by the message receiving computer to the message sending computer, a first control message instructing the message sending computer to not send any more messages. Pacing further includes determining, by the message receiving computer, to resume receiving the subsequent message from the message sending computer; and transmitting, by the message receiving computer to the message sending computer, a second control message instructing the message sending computer to resume sending messages.

Claims

1. A method for pacing communications between a message sending computer and a message receiving computer that are both members of a message group of a sysplex, comprising:

sending, by the message receiving computer to the message sending computer, a predetermined message queue depth value,

wherein the predetermined message queue depth value is encoded in a control information portion of a signaling service message;

receiving, by the message receiving computer, a plurality of data messages comprising data sent by the message sending computer;

when a number of the plurality of messages equals the predetermined message queue depth value, receiving, by the message receiving computer from the message sending computer, a first control message comprising data which indicates that the message sending computer will wait for instructions from the message receiving computer before sending any subsequent messages to the message receiving computer;

determining, by the message receiving computer, to resume receiving the subsequent messages from the message sending computer; and

transmitting, by the message receiving computer to the message sending computer, a second control message comprising data which specifies instructions for the message sending computer to resume sending messages to the message receiving computer.

2. The method of claim 1, wherein the first control message is received, and the second control message is transmitted, using a signaling service that couples the message sending computer and the message receiving computer.

3. The method of claim 2, wherein the plurality of data messages are received via the signaling service.

4. The method of claim 1, wherein:

the message sending computer comprises a first data transfer module; and

the message receiving computer comprises a second data transfer module, wherein the first and second data transfer modules communicate using a signaling service of the sysplex.

5. The method of claim 4, wherein:

the first data transfer module comprises a first control block data structure local to the message sending computer; and

the second data transfer module comprises a second control block data structure local to the message receiving computer.

6. The method of claim 4, wherein the second control message comprises the second control block data structure.

7. The method of claim 4, wherein the first control message received by the message receiving computer comprises the first control block data structure.

8. A system for pacing communications between a message sending computer and a message receiving computer that are both members of a message group of a sysplex, comprising:

a processor and a memory coupled to the processor, the memory storing program code executable by the processor;

the program code, when executed by the processor, configured to send, by the message receiving computer to the message sending computer, a predetermined message queue depth value,

wherein the predetermined message queue depth value is encoded in a control information portion of a signaling service message;

the program code, when executed by the processor, configured to receive, by the message receiving computer, a plurality of data messages comprising data sent by the message sending computer;

the program code, when executed by the processor, configured to, when a number of the plurality of messages equals the predetermined message queue depth, receive, by the message receiving computer from the message sending computer, a first control message comprising data which indicates that the message sending computer will wait for instructions from the message receiving computer before sending any subsequent messages to the message receiving computer;

the program code, when executed by the processor, configured to determine to resume receiving the subsequent messages from the message sending computer; and

the program code, when executed by the processor, configured to transmit to the message sending computer, a second control message comprising data which specifies instructions for the message sending computer to resume sending messages to the message receiving computer.

9. The system of claim 8, wherein the first control message is received, and the second control message is transmitted, using a signaling service that couples the message sending computer and the message receiving computer.

10. The system of claim 9, wherein the plurality of data messages are received via the signaling service.

11. The system of claim 8, wherein:

the message sending computer comprises a first data transfer module; and

the message receiving computer comprises a second data transfer module, wherein the first and second data transfer modules communicate using a signaling service of the sysplex.

12. The system of claim 11, wherein:

the first data transfer module comprises a first control block data structure local to the message sending computer; and

the second data transfer module comprises a second control block data structure local to the message receiving computer.

13. The system of claim 11, wherein the second control message comprises the second control block data structure.

14. The system of claim 11, wherein the first control message received by the message receiving computer comprises the first control block data structure.

15. A computer program product for pacing communications between a message sending computer and a message receiving computer that are both members of a message group of a sysplex, comprising:

a non-transitory computer readable storage medium having computer readable program code embodied therewith, the computer readable program code comprising;

computer readable program code configured to send, by the message receiving computer to the message sending computer, a predetermined message queue depth value,

wherein the predetermined message queue depth value is encoded in a control information portion of a signaling service message;

computer readable program code configured to receive a plurality of data messages comprising data sent by the message sending computer;

computer readable program code configured to, when a number of the plurality of messages equals the predetermined message queue depth, receive, by the message receiving computer from the message sending computer, a first control message comprising data which indicates that the message sending computer will wait for instructions from the message receiving computer before sending any subsequent messages to the message receiving computer;

computer readable program code configured to determine to resume receiving the subsequent messages from the message sending computer; and

computer readable program code configured to transmit to the message sending computer, a second control message comprising data which specifies instructions for the message sending computer to resume sending messages to the message receiving computer.

16. The computer program product of claim 15, wherein the first control message is received and the second control message is transmitted, using a signaling service that couples the message sending computer and the message receiving computer.

17. The computer program product of claim 16, wherein the plurality of data messages are received via the signaling service.

18. The computer program product of claim 15, wherein:

the message sending computer comprises a first data transfer module; and

the message receiving computer comprises a second data transfer module, wherein the first and second data transfer modules communicate using a signaling service of the sysplex.

19. The computer program product of claim 18, wherein:

the first data transfer module comprises a first control block data structure local to the message sending computer; and

the second data transfer module comprises a second control block data structure local to the message receiving computer.

20. The computer program product of claim 18, wherein the second control message comprises the second control block data structure.

21. The computer program product of claim 18, wherein the first control message received by the message receiving computer comprises the first control block data structure.