Dispatch mechanism for coordinating application and communication medium state

• US 8,719,841 B2
• Filed: 10/23/2009
• Issued: 05/06/2014
• Est. Priority Date: 11/16/2007
• Status: Expired due to Fees

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Pinto, Edmund Samuel Victor, Allen, Nicholas A., Raman, Karthik, Wolf, Kenneth D.
• Primary Examiner(s): Anya, Charles E
• Application Number:
  US12/605,236
• Publication Number:
  US 20100107177A1
• Time in Patent Office: 1,656 Days
• Field of Search: 707/705, 709/203, 719/313, 719/328
• US Class Current: 719/313
• CPC Class Codes: G06F 9/546 Message passing systems or structures, e.g. queues

Abstract

The present invention extends to methods, systems, and computer program products for coordinating application state and communication medium state. Embodiments of the invention provide mechanisms by which a dispatcher can enable application code to coordinate changes in application state with the consumption of messages from a communication medium. The coordination can be automatic where the dispatcher performs the coordination, or manual, where the coordination is performed more expressly by application code. Embodiments also include mechanisms by which applications targeting an execution (e.g., continuation based) runtime may compose alternative state transitions in the application with a peek lock protocol.

Claims

1. At a computer system including one or more processors and system memory, the computer system also including a communication medium, a dispatcher, and an application, the dispatcher and the communication medium supporting a peek lock state coordination pattern to coordinate state transitions between the communication medium and any accessible applications, a method for coordinating state between the communication medium and the application in accordance with the peek lock state coordination pattern, the method comprising:

an act of the dispatcher interposed between an application and a communication medium sending a message request to the communication medium, the message request requesting a next available message from the communication medium on behalf of the application and which initiates a lock of the next available message by the communication medium;

an act of the dispatcher receiving a view of content of a message comprising the next available message from the communication medium which has been locked by the communication medium following the response to the request from the dispatcher, wherein the dispatcher receiving the content view is indicative of the communication medium having locked the message at the communication medium for access by the dispatcher and such that the message will remain locked at the communication medium to prevent any additional access to the message directly from the communication medium until a dispatcher signal is sent to the communication medium from the dispatcher that indicates that the message is to be unlocked or deleted according to the peek lock state coordination pattern;

an act of the dispatcher offering the content view to the application, even though the message remains locked at the communication medium;

an act of the dispatcher observing an application signal, the application signal indicating whether the application successfully updated an application state for the application based on the content view;

wherein the application does not natively support communication state updates or is unaware of the peek and lock state coordination pattern of the communication medium, such that the application is unable to update the communication medium state; and

an act of the dispatcher sending a dispatcher signal to the communication medium, the dispatcher signal indicating how the communication medium is to update the communication medium state on behalf of the application, the dispatcher signal being based on the observed signal and in accordance with the peek lock state coordination pattern, the dispatcher signal indicating that the next available message is to be deleted when the application signal indicates the application state was successfully updated and the dispatcher signal indicating that the next available message is to be unlocked at the communication medium when the application signal indicates that updating the application state was unsuccessful.

2. The method as recited in claim 1, wherein the application is not aware of the supported state coordination pattern, and wherein the act of the dispatcher sending the dispatcher signal comprises an act of the dispatcher signaling the communication medium to delete the message.

3. The method as recited in claim 1, wherein the application is not aware of the supported state coordination pattern, and wherein the act of the dispatcher offering the content view to the application and the act of the dispatcher sending the dispatcher signal comprises an act of the application and communication medium participating in a transaction that delivers the content view to the application and signals the communication medium to delete the message.

4. The method as recited in claim 1, wherein the application is aware of the supported state coordination pattern, and wherein the act of the dispatcher sending the dispatcher signal comprises an act of the dispatcher sending a further signal to the communication medium indicating how to update communication medium state subsequent to offering the content view to the application;

and

wherein the act of the dispatcher sending the dispatcher signal to the communication medium indicating how to update communication medium state subsequent to offering the content view to the application comprises an act of the dispatcher signaling the communication medium how to update communication medium state based on the results of an attempt to update application state based on the content view.

5. The method as recited in claim 4, wherein the act of the dispatcher offering the content view to the application and the act of the dispatcher sending the dispatcher signal comprise an act of the application and communication medium participating in a transaction that delivers the content view to the application and signals the communication medium to update communication medium state.

6. The method as recited in claim 4, wherein an act of the dispatcher signaling the communication medium how to update communication medium state based on the results of an attempt to update application state based on the content view comprises an act of the dispatcher signaling the communication medium to delete the message in response to the dispatcher observing that the application successfully received the content view.

7. The method as recited in claim 4, wherein an act of the dispatcher signaling the communication medium how to update communication medium state based on the results of an attempt to update application state based on the content view comprises an act of the dispatcher signaling the communication medium to unlock the message in response to the dispatcher observing that the application did not successfully receive the content view, unlocking the message making the message available to the other software components.

8. At a computer system including one or more processors and system memory, the computer system also including a communication medium, a dispatcher, and an application, the dispatcher, the application, and the communication medium supporting a peek lock state coordination pattern to coordinate state transitions between the communication medium and the applications, a method for coordinating state between the communication medium and the application in accordance with the peek lock state coordination pattern, the method comprising:

an act of the dispatcher interposed between an application and a communication medium sending a message request to the communication medium, the message request requesting a next available message from the communication medium on behalf of the application and which initiates a lock of the next available message by the communication medium;

an act of the dispatcher receiving a view of content of a message comprising the next available message from the communication medium which has been locked by the communication medium following the response to the request from the dispatcher, wherein the dispatcher receiving the content view is indicative of the communication medium having locked the message at the communication medium for access by the dispatcher in accordance with a peek lock state coordination pattern, and such that the message will remain locked at the communication medium to prevent any additional access to the message directly from the communication medium until an intended update is sent to the communication medium from a communication proxy that indicates that the message is to be unlocked or deleted according to the peek lock state coordination pattern;

an act of the dispatcher offering the content view along with the communication proxy to the application, the communication proxy providing sufficient information for the application to communicate with the communication medium in accordance with the peek lock state coordination pattern;

wherein the application attempts to update application state for the application based on the content view and thereafter communicates results of the attempted application state update to the communication proxy; and

wherein the communication proxy signals the communication medium with the intended update to a communication medium state based on the result of the attempted application state update, the intended update to the communication state being selected from among deleting the message from the communication medium and unlocking the message at the communication medium.

9. The method as recited in claim 8, wherein the method further includes the application and communication medium participating in a transaction that delivers the content view to the application and that results in the communication proxy signaling the communication medium to update communication medium state with the intended update.

10. The method as recited in claim 9, further comprising:

an act of the transaction subsequently being rolled back; and

wherein the application sends a new signal through the communication proxy with the intended update to the communication medium.

11. The method as recited in claim 8, wherein the results of the attempted application state update indicate that the application successfully received the content view of the message;

and

wherein the intended update indicates that the communication medium is to delete the message.

12. At a computer system including one or more processors and system memory, the computer system also including a communication medium, a dispatcher, and an application, the dispatcher, the application, and the communication medium supporting a state coordination pattern to coordinate state transitions between the communication medium and the applications, the application using a scheduler and shared storage to provide an execution runtime, a method for coordinating state between the communication medium and the application in accordance with the state coordination pattern, the method comprising:

an act of the application providing to the scheduler a plurality of executable activities, the plurality of executable activities including a receive activity and one or more state update activities;

an act of the scheduler scheduling the receive activity for execution;

an act of receiving a content view of a message along with a communication proxy at the receive activity, the content view and communication proxy received from the dispatcher, the message being a message the dispatcher accessed on behalf of the application in accordance with the state coordination pattern, the communication proxy providing sufficient information for the application to communicate with the communication medium in accordance with the state coordination pattern;

an act of initializing a shared storage location with a receive context to communicate with the communication medium based on the communication proxy, the shared storage location accessible by other activities of the application to communicate with the communication medium;

an act of initializing one or more of the plurality of executable activities configured to update the application state of the application from the content view, the initialized executable activities having access to the shared storage location with the receive context;

an act of the scheduler scheduling a first state update activity for execution, the first state update activity included in the plurality of executable activities;

an act of attempting to update the application state of the application from the content view through execution of the first state update activity;

an act of sending a signal to the receive context, the signal indicating how the communication medium state is to be updated based on the results of attempting to update the application state and in accordance with the state coordination pattern; and

an act of the receive context forwarding the signal for delivery to the communication medium.

13. The method as recited in claim 12, further comprising an act of detecting that the first state update activity successfully updated the application state from the content view.

14. The method as recited in claim 13, wherein the act of sending a signal to the receive context comprises an act of the first update state activity sending a signal to delete the message from the communication medium.

15. The method as recited in claim 12, further comprising:

an act of detecting that the first state update activity failed to successfully update the application state from the content view; and

an act of executing an alternate state update activity to attempt to update the application state from the content view in response to detecting the failure of the first state update activity to update the application state, the alternate state update activity included in the plurality of executable activities.

16. The method as recited in claim 15, further comprising an act of detecting that the alternate state update state activity successfully updated the application state;

and

wherein the act of sending a signal to the receive context comprises an act of the alternate update state activity sending a signal to delete the message from the communication medium.

17. The method as recited in claim 15, further comprising an act of detecting that the alternate state update activity failed to successfully update the application state.

18. The method as recited in claim 17, wherein the act of sending a signal to the receive context comprises an act of sending a signal to unlock the message at the communication medium.

19. The method as recited in claim 12, wherein the act of receiving a content view of a message along with a communication proxy and forwarding the signal for delivery to the communication medium comprise an act of the application and the communication medium participating in a transaction that delivers the content view to the application and signals the communication medium to update communication state in accordance with the state coordination pattern.

20. The method as recited in claim 19, further comprising:

an act of the receive context participating in the transaction that delivers the content view to the application and signals the communication medium to update communication medium state;

an act of the transaction subsequently being rolled back; and

an act of the application sending another signal to the receive context, possibly using a different transaction.