Asynchronous server synchronously storing persistent data batches

• US 20070094336A1
• Filed: 10/24/2005
• Published: 04/26/2007
• Est. Priority Date: 10/24/2005
• Status: Abandoned Application

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Pearson, Malcolm
• Application Number:
  US11/256,751
• Publication Number:
  US 20070094336A1
• Time in Patent Office: Days
• US Class Current: 709/206
• CPC Class Codes: H04L 51/42 Mailbox-related aspects, e.g. synchronisation of mailboxes

Abstract

An asynchronous conversation state machine asynchronously sends and asynchronously receives messages for storing in batches in an intermediate storage. A synchronous storage engine receives the batches of messages from the intermediate storage. Particular batches of messages are stored in the storage engine based on their parameters.

Claims

1. A system comprising:

An intermediate storage;

An asynchronous conversation state machine for asynchronously sending and asynchronously receiving messages, said machine storing said received messages in batches in the intermediate storage;

A synchronous storage engine for receiving the batches of messages from the intermediate storage;

Wherein the intermediate storage causes a particular one of the batches of messages to be stored in the storage engine.

2. The system of claim 1 wherein the intermediate storage causes a particular one of the batches of messages to be stored in the storage engine as a function of a parameter of the particular batch.

3. The system of claim 2 wherein the parameters comprises at least one of an age of the messages of the particular batch, a number of messages in the particular batch, and an amount of I/O associated with the particular batch.

4. The system of claim 3 wherein the state machine comprises an SMTP server having a protocol latency and a transaction size and wherein the intermediate storage causes a particular one of the batches of messages to be stored in the storage engine as function of the protocol latency and the transaction size of the SMTP server.

5. The system of claim 1 wherein the state machine comprises an SMTP server having a protocol latency and a transaction size and wherein the intermediate storage causes a particular one of the batches of messages to be stored in the storage engine as function of the protocol latency and the transaction size of the SMTP server.

6. The system of claim 1 wherein the intermediate storage evaluates the batches stored in the intermediate storage to identify batches to be stored in the storage engine and wherein the intermediate storage engine causes the identified batches to be stored in the storage engine.

7. The system of claim 6 wherein the intermediate storage evaluates the batches according to a parameter of each of the batches and wherein the intermediate storage engine causes a particular one of the identified batches to be stored in the storage engine as a function of the parameter of the particular identified batch.

8. The system of claim 7 wherein the parameters comprises at least one of an age of the messages of the particular identified batch, a number of messages in the particular identified batch, and an amount of I/O associated with the particular identified batch.

9. The system of claim 7 wherein the state machine comprises an SMTP server having a protocol latency and a transaction size and wherein the intermediate storage causes the particular identified batch to be stored in the storage engine as function of the protocol latency and the transaction size of the SMTP server.

10. The system of claim 1 wherein the intermediate storage deletes or recycles batches transferred to the storage engine.

11. A computerized method comprising:

asynchronously receiving messages,

storing 308 said received messages in batches in an intermediate storage;

receiving 314 the batches of messages from the intermediate storage; and

storing a particular one of the batches of messages in a synchronous storage engine.

12. The method of claim 11 wherein storing comprises storing a particular one of the batches of messages in the storage engine as a function of a parameter of the particular batch.

13. The method of claim 12 wherein the parameters comprises at least one of an age of the messages of the particular batch, a number of messages in the particular batch, and an amount of I/O associated with the particular batch.

14. The method of claim 12 wherein asynchronously receiving comprises receiving via an SMTP protocol and wherein the parameters are a function of a protocol latency and a transaction size of the receiving.

15. The method of claim 11, wherein one or more computer-readable media have computer-executable instructions for performing the method of claim 11.

16. The method of claim 11 wherein at least one of the following strategies may be used to schedule a thread to execute the transmission of a particular batch for storing into the storage engine:

hijacking a thread that was used to pass the last item into the particular batch, identifying and using a single background thread, employing multiple asynchronously scheduled background threads, and selecting a thread to avoid context switching and locks.

17. The method of claim 11 further comprising transmitting a batch from the batch point to the storage engine as soon as a message which triggers the batch transfer is received by the batch point.

18. In a system comprising:

An asynchronous conversation state machine for asynchronously sending and asynchronously receiving messages; and

A synchronous storage engine for storing batches of messages;

the improvement comprising an intermediate storage 106 for storing in batches messages received from the state machine and for causing a particular one of the batches of messages to be stored in the storage engine.

19. The system of claim 18 wherein the intermediate storage causes a particular one of the batches of messages to be stored in the storage engine as a function of a parameter of the particular batch.

20. The system of claim 19 wherein the parameters comprises at least one of an age of the messages of the particular batch, a number of messages in the particular batch, and an amount of I/O associated with the particular batch.