System for message traffic control utilizing prioritized message chaining for queueing control ensuring transmission/reception of high priority messages

• US 5,506,966 A
• Filed: 11/05/1992
• Issued: 04/09/1996
• Est. Priority Date: 12/17/1991
• Status: Expired due to Term

• Current Assignee: NEC Corporation
• Original Assignee: NEC Corporation
• Inventors: Ban, Takayuki
• Primary Examiner(s): Lee, Thomas C.
• Assistant Examiner(s): Kim, Sang Hui
• Application Number:
  US07/971,552
• Time in Patent Office: 1,251 Days
• Field of Search: 395/200, 395/275, 395/250, 395/600, 395/650
• US Class Current: 719/314
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

An on-line data processing system for providing a traffic control over the message queuing buffers that temporarily store the messages in order to absorb the difference in the message processing speed between the on-line program processing unit and the transmission/reception unit connected to a plurality of terminals. The traffic control is provided such that the message is stored or obtained in or from the message queuing buffer in accordance with the priority set on the messages. The priority of the messages is determined by using a character string in a predetermined position in each message.

Claims

1. An on-line data processing system connected to a plurality of terminals via communication lines, comprising:

transmitting/receiving means for transmitting and receiving messages to and from said terminals in accordance with predetermined transmission control protocols;

processing means responsive to said messages received from one of said terminals for processing said messages and producing resultant messages to be sent back to said one terminal;

storage means for temporarily storing said messages communicated between said transmitting/receiving means and said processing means, said storage means comprising a plurality of buffers for holding said messages, said plurality of buffers being assigned a priority corresponding to said messages stored therein;

priority determination means for determining said priority of said messages; and

traffic control means responsive to a request from one of said transmitting/receiving means and said processing means for providing a traffic control of messages communicated between said transmitting/receiving means and said processing means by storing and obtaining said messages into and from said storage means in accordance with said priority of said messages determined by said priority determination means, said traffic control means including means for determining on a basis of a priority of one of said messages and a number of available storage buffers for storing said one of said messages, whether said one of said messages is to be stored in one of said available storage buffers, said traffic control means further including a message queuing buffer control table configured to store information related to which of said plurality of buffers are linked to a receive message chain, which of said plurality of buffers are linked to a transmit message chain, and which of said plurality of buffers are linked to an idle message chain, said message queuing buffer control table also configured to store start link pointers and end link pointers for each of said plurality of buffers respectively linked to said receive message chain, said transmit message chain, and said idle message chain.

2. An on-line data processing system according to claim 1, wherein said storage means is comprised of a plurality of buffers.

3. An on-line data processing system according to claim 1, wherein said priority determination means determines the priority of said messages by using a character string in a predetermined location in each of said messages.

4. An on-line data processing system according to claim 1, wherein said priority determination means includes a priority definition table having priority definition data for determining the priority of said messages.

5. An on-line data processing system according to claim 4, wherein said priority determination means dynamically adds, changes, and deletes said data of the priority definition table by request from said processing means.

6. An on-line data processing system according to claim 1, wherein said traffic control means stores said message into said storage means and obtains said message from said storage means in order of priority as determined by said priority determination means.

7. An on-line data processing system according to claim 1, wherein said traffic control means discards said message having one of a predetermined priority and a priority less than said predetermined priority from said storage means according to a request from said processing means, said request including said predetermined priority.

8. An on-line data processing system according to claim 1, wherein said storage means comprises:

a link pointer section for storing a value used to link said plurality of buffers in a chain to provide queuing control;

a sent/received section for storing said messages and said resultant messages; and

a priority section for storing a priority of said messages.

9. An on-line data processing system according to claim 1, wherein said traffic control means comprises:

a queuing buffer count section for storing a number corresponding to said plurality of buffers of said storage means, each of said plurality of buffers of said storage means being assigned to one of a transmission chain, a received chain and an idle chain;

an idle queuing buffer head pointer section for storing an idle start pointer corresponding to one of said plurality of buffers of said storage means that is linked to a starting position of said idle chain;

an idle queuing buffer end pointer section for storing an idle end pointer corresponding to one of said plurality of buffers of said storage means that is linked to an ending position of said idle chain;

an idle queuing buffer count section for storing a number corresponding to said plurality of buffers of said storage means that are linked to said idle chain;

a reception queuing buffer head pointer section for storing a reception start pointer corresponding to one of said plurality of buffers of said storage means that is linked to a starting position of said received chain;

a reception queuing buffer end pointer section for storing a reception end pointer corresponding to one of said plurality of buffers of said storage means that is linked to an ending position of said received chain;

a reception queuing buffer count section for storing a number corresponding to said plurality of buffers of said storage means that are linked to said received chain;

a transmission queuing buffer head pointer section for storing a transmission start pointer corresponding to one of said plurality of buffers of said storage means that is linked to a starting position of said transmission chain;

a transmission queuing buffer end pointer section for storing a transmission end pointer corresponding to one of said plurality of buffers of said storage means that is linked to an ending position of said transmission chain; and

a transmission queuing buffer count section for storing a number corresponding to said plurality of buffers of said storage means that are linked to said transmission chain.

10. An on-line data processing system according to claim 1, wherein said plurality of buffers of said storage means are respectively assigned to a transmit queue, a receive queue, and an idle queue, said buffers assigned to said transmit queue holding said messages to be transmitted to said terminals, said buffers assigned to said receive queue holding said messages received from said terminal, and said buffers assigned to said idle queue not holding any of said messages, wherein each of said plurality of buffers in said transmit queue and said receive queue are assigned to said priority corresponding to said message stored therein,

and wherein said traffic control means includes means for determining a reception enable condition, a reception inhibit condition, a transmission enable condition, and a transmission inhibit condition for said priority corresponding to said messages according to a number of said buffers assigned to said idle queue.

11. An on-line data processing system connected to a plurality of terminals via communication lines, comprising:

transmitting/receiving means for transmitting or receiving messages to or from said terminals in accordance with predetermined transmission control protocols;

processing means responsive to said messages received from one of said terminals for processing said messages and producing resultant messages to be sent back to said one of said terminals;

storage means for temporarily storing said messages communicated between said transmitting/receiving means and said processing means, said storage means comprising a plurality of buffers, each of said plurality of buffers including;

a link pointer section for storing a value used to link said plurality of buffers in a chain to provide queuing control;

a sent/received section for storing said messages and said resultant messages; and

a priority section for storing a priority of said messages;

priority determination means for determining the priority of said messages and said resultant messages; and

traffic control means responsive to a request from said transmitting/receiving means and/or said processing means for providing a traffic control of messages communicated between said transmitting/receiving means and said processing means by storing or obtaining said messages into or from said storage means in accordance with the priority of said messages determined by said priority determination means, said traffic control means comprising;

a queuing buffer count section for storing a number corresponding to said plurality of buffers of said storage means, each of said plurality of buffers of said storage means being assigned to one of a transmission chain, a received chain and an idle chain;

an idle queuing buffer head pointer section for storing an idle start pointer corresponding to one of said plurality of buffers of said storage means that is linked to a starting position of said idle chain;

an idle queuing buffer end pointer section for storing an idle end pointer corresponding to one of said plurality of buffers of said storage means that is linked to an ending position of said idle chain;

an idle queuing buffer count section for storing a number corresponding to said plurality of buffers of said storage means that are linked to said idle chain;

a reception queuing buffer head pointer section for storing a reception start pointer corresponding to one of said plurality of buffers of said storage means that is linked to a starting position of said received chain;

a reception queuing buffer end pointer section for storing a reception end pointer corresponding to one of said plurality of buffers of said storage means that is linked to an ending position of said received chain;

a reception queuing buffer count section for storing a number corresponding to said plurality of buffers of said storage means that are linked to said received chain;

a transmission queuing buffer head pointer section for storing a transmission start pointer corresponding to one of said plurality of buffers of said storage means that is linked to a starting position of said transmission chain;

a transmission queuing buffer end pointer section for storing a transmission end pointer corresponding to one of said plurality of buffers of said storage means that is linked to an ending position of said transmission chain; and

a transmission queuing buffer count section for storing a number corresponding to said plurality of buffers of said storage means that are linked to said transmission chain.

12. An on-line data processing system according to claim 11, wherein said traffic control means includes a queuing buffer traffic control area, which comprises:

a priority section for storing a priority level assigned to each of said plurality of buffers of said storage means;

a reception inhibition releasing section for storing a reception inhibition releasing value;

a reception inhibition starting section for storing a reception inhibition starting value;

a transmission inhibition releasing section for storing a transmission inhibition releasing value; and

a transmission inhibition starting section for storing a transmission inhibition starting value,

wherein when said idle start pointer stored in said idle queuing buffer head pointer section is equal to or less than said reception inhibition starting value, said traffic control means inhibits reception of any of said messages into said storage means, and when said idle start pointer stored in said idle queuing buffer head pointer section is equal to or greater than said reception inhibition releasing value, said traffic control means enables reception of any of said messages into said storage means, and when said idle start pointer stored in said idle queuing buffer head pointer section is equal to or less than said transmission inhibition starting value, said traffic control means inhibits transmission of any of said messages from said storage means, and when said idle start pointer stored in said idle queuing buffer head pointer section is equal to or greater than said transmission inhibition releasing value, said traffic control means enables transmission of any of said message from said storage means,

and wherein said reception inhibition starting value is greater than said reception inhibition releasing value, said reception inhibition releasing value is greater than said transmission inhibition starting value, and said transmission inhibition starting value is greater than transmission inhibition releasing value.

13. An on-line data processing system according to claim 11, wherein said priority determination means determines the priority of said messages by using a character string in a predetermined location in each of said messages.

14. An on-line data processing system according to claim 11, wherein said priority determination means includes a priority definition table having priority definition data for determining the priority of said messages.

15. An on-line data processing system according to claim 14, wherein said priority determination means dynamically adds, changes, and deletes the data of said priority definition table by request from said processing means.

16. An on-line data processing system according to claim 11, wherein said traffic control means stores said message into said storage means and obtains said message from said storage means in order of priority as determined by said priority determination means.

17. An on-line data processing system according to claim 11, wherein said traffic control means discards said message having one of a predetermined priority and a priority less than said predetermined priority from said storage means according to a request from said processing means, said request including said predetermined priority.

18. An on-line data processing system according to claim 14, wherein said priority definition data includes:

a key starting position field to indicate a starting position of a key word character string that is indicative of the priority of one of said messages;

a key length field for storing a length of the key word character string;

a key word name field for storing the key word character string; and

a priority field for storing a priority level corresponding to said key word character string.

19. An on-line data processing system for transmitting a received message from one of a plurality of terminals to another of said plurality of terminals, comprising:

a plurality of memory elements, each of said plurality of memory elements being used to temporarily store messages, said plurality of memory elements being assigned to a priority level corresponding to a message stored therein;

priority determination means for determining the priority level corresponding to said received message; and

traffic control means for providing a traffic control of said received message and for determining whether to store said received message into an available one of said plurality of memory elements based on the priority level of said received message and a number of said memory elements available for storing said received message, said traffic control means including a message queuing buffer control table configured to store information related to which of said plurality of memory elements are linked to a receive message chain, which of said plurality of memory elements are linked to a transmit message chain, and which of said plurality of memory elements are linked to an idle message chain, said message queuing buffer control table also configured to store start link pointers and end link pointers for each of said plurality of buffers respectively linked to said receive message chain, said transmit message chain, and said idle message chain.