System and method of expedited message processing using a first-in-first-out transport mechanism

Patent metadata

Field	Value
Publication number	US-9423976-B2
Application number	US-201314424283-A
Country	US
Kind code	B2
Filing date	Sep 12, 2013
Priority date	Sep 13, 2012
Publication date	Aug 23, 2016
Grant date	Aug 23, 2016

Abstract

A method and system are provided for processing a reply message out of order from a first-in-first-out (FIFO) storage, and processing other messages in an order as received in the FIFO storage. The system provides a second FIFO storage for storing any messages that have been retrieved from the first FIFO while searching for the reply message.

First claim

The invention claimed is:

1. A method for retrieving and processing messages using a communication link with a first first-in-first-out (FIFO) storage, comprising:
(a) retrieving a message from the first FIFO storage;
(b) adding the retrieved message to a second FIFO storage if the retrieved message is not a reply message and not a notification message;
(c) discarding the retrieved message if the retrieved message is a notification message,
(d) processing the reply message before processing any other messages retrieved from the first FIFO storage,
(e) processing the other retrieved messages in an order as received in the first FIFO storage,
(f) repeating steps (a) to (c) until the reply message is retrieved
(g) upon retrieving the reply message, and determining that the first FIFO storage is empty and the second FIFO storage contains at least one message, sending a notification message to the first FIFO storage; and
(h) resuming retrieving and processing of the other messages after sending the notification message.

2. The method of claim 1 , wherein upon retrieving the reply message, and upon determining at least one of: the first FIFO storage at least one message, and the second FIFO storage being empty, resuming retrieving and processing of the other messages.

3. A system for retrieving messages for processing, comprising:
a message router;
a first storage configured for receiving messages from the message router;
a message processor configured for retrieving messages from the first storage; the message processor further configured for storing messages to, and retrieving messages from, a second storage, wherein both the first storage and the second storage are first-in-first-out (FIFO) storage; wherein the message processor is configured for retrieving at least one message from the first storage to determine if the at least one message is a reply to a previously sent synchronous message, and if the at least one message is not the reply and not a notification message, then storing the at least one message in the second storage for subsequent retrieval and processing.

4. The system according to claim 3 , wherein the message processor is further configured for sending a notification message to the first storage upon retrieving the reply and upon determining that the first storage is empty and the second storage is not empty.

5. The system according to claim 3 , wherein the message processor is further configured for discarding the at least one message retrieved from the first storage if the at least one message is the notification message.

6. The system according to claim 3 , wherein all messages stored in the second storage are messages that have been retrieved from the first storage by the message processor during a time period when the message processor is searching for the reply to the previously sent synchronous message.

7. The system of claim 3 , wherein the first FIFO storage is further configured to provide a signal to the message processor to notify that other messages are ready to be retrieved from either of the first FIFO storage and the FIFO storage.

Assignees

• Thomson Licensing

Inventors

• Clevenger Brian Duane

Classifications

• G06F13/4059

  where the synchronisation uses buffers, e.g. for speed matching between buses · CPC title

• G06F3/0656 Primary

  Data buffering arrangements · CPC title

• G06F3/0608

  Saving storage space on storage systems · CPC title

• G06F3/067

  Distributed or networked storage systems, e.g. storage area networks [SAN], network attached storage [NAS] · CPC title

• G06F13/1642

  with request queuing · CPC title