Processing model-based commands for distributed applications

• US 8,306,996 B2
• Filed: 05/18/2011
• Issued: 11/06/2012
• Est. Priority Date: 10/26/2007
• Status: Expired due to Fees

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Nanjangud Bhaskar, Karthik Arun, Christensen, Erik B., Kulkarni, Amol Sudhakar, Panditharadhya, Prasad Sripathi, Sahi, Sundeep, Sedukhin, Igor, Wu, Haoran Andy
• Primary Examiner(s): Trujillo, James
• Assistant Examiner(s): Black, Linh
• Application Number:
  US13/110,223
• Publication Number:
  US 20110219383A1
• Time in Patent Office: 538 Days
• Field of Search: 705/7.27, 705/301, 707/636, 707/770, 707/782, 707/797, 455/453, 718104-105
• US Class Current: 707/770
• CPC Class Codes: G06F 8/10 Requirements analysis; Specification techniques

Abstract

The present invention extends to methods, systems, and computer program products for processing model based commands for distributed applications. Embodiments facilitate execution of model-based commands, including software lifecycle commands, using model-based workflow instances. Data related to command execution is stored in a shared repository such that command processors can understand their status in relationship to workflow instances. Further, since the repository is shared, command execution can be distributed and balanced across a plurality of different executive services. Embodiments also include model-based error handling and error recovery mechanisms.

Claims

1. A method, implemented at computer system that includes a plurality of executive services and a repository that stores models, for distributing the implementation of a command, the method comprising:

an act of a first executive service receiving a model-based command request for a particular distributed application, the first executive service being configured to refine declarative application models, which include one or more sets of high-level instructions expressing application intent for distributed applications, into detailed application models for translation by technology-specific drivers, the model-based command request including a command reference to a particular command definition model defining a corresponding command, the model-based command request also including a reference to a particular declarative application model, the model-based command request indicating that the corresponding command is to be implemented for the particular declarative application model in connection with executing a particular distributed application;

an act of the first executive service determining that it is already running a plurality of other model-based commands;

an act of the first executive service querying the repository to determine if other executive services are available;

an act of the first executive service receiving an indication that a second executive service is available for processing model-based commands, the second executive service also being configured to refine declarative application models into detailed application models; and

an act of the first executive service passing the model-based command request to the second executive service in response to the indication that the second executive service is available, so as to balance the load of command processing across a plurality of executive services.

2. The method as recited in claim 1, wherein the act of the first executive service determining that it is already running a plurality of other model-based commands further includes an act of determining that the computer system lacks available resources to process the corresponding command or that processing of the corresponding command would negatively impact processing of the plurality of other model-based commands.

3. The method as recited in claim 1, wherein the act of a first executive service receiving a command request for a distributed application comprises an act of receiving a software lifecycle command request.

4. The method as recited in claim 1, the method further comprising:

an act of a third executive service receiving a request for a status of a workflow instance from a user tool, the status request including a command ID for the workflow instance.

5. The method as recited in claim 4, the method further comprising:

an act of the third executive service using the command ID to refer to a command record for the workflow instance in the repository.

6. The method as recited in claim 5, the method further comprising:

an act of the third executive service accessing a state of the workflow instance from the command record; and

an act of the third executive service returning the status to the user tool.

7. One or more storage medium having stored computer-executable instructions which, when executed by one or more processors of a computer system, implement a method for distributing the implementation of a command, the method comprising:

an act of a first executive service receiving a command request for a particular distributed application, the first executive service being configured to refine declarative application models, which include one or more sets of high-level instructions expressing application intent for distributed applications, into detailed application models for translation by technology-specific drivers, the command request including a command reference to a particular command definition model defining a corresponding command, the command request also including a reference to a particular declarative application model, the command request indicating that the corresponding command is to be implemented for the particular declarative application model in connection with executing a particular distributed application corresponding to the particular declarative application model;

an act of the first executive service determining that it is already running a plurality of other model-based commands;

an act of the first executive service querying the repository to determine if other executive services are available;

an act of the first executive service receiving an indication that a second executive service is available for processing model-based commands, the second executive service also being configured to refine declarative application models into details application models; and

an act of the first executive service passing the command request to the second executive service in response to the indication that the second executive service is available so as to balance the load of command processing across the plurality of executive services.

8. The one or more storage medium of claim 7, wherein the one or more storage medium comprise the computer system with the computer-executable instructions being stored on system memory of the computer system.

9. One or more storage medium having stored computer-executable instructions which, when executed by one or more processors of a computer system, implement a method for processing a model-based command for a distributed application, the method comprising:

an act of receiving a command request for a distributed application, wherein the command request includes a command reference to a command definition model that defines a corresponding command and that identifies a workflow model, wherein the command request also includes a reference to an application model for the distributed application that is a declarative model that describes the structure and behavior of the distributed application by defining general operations of one or more modules in the distributed application, and wherein the command request indicates that the corresponding command is to be implemented for the application model;

an act of creating a command record for the received command request in the repository, wherein the command record stores information related to implementing the command request;

an act of identifying the workflow model from the command definition model, wherein the workflow model describes how to implement the received command request for the application model by defining a set of pre-defined activities configured to interoperate to implement the command request for the application model;

an act of accessing the workflow model from the repository;

an act of creating an instance of the workflow from the workflow model, wherein the workflow instance has a command ID and includes the set of pre-defined activities configured to interoperate to implement the command request for the application model;

an act of storing the command ID in the command record;

an act of submitting the application model reference to the workflow instance to initiate the workflow instance for the distributed application; and

an act of recording information related to the behavior of the workflow instance within the command record as the workflow instance implements the command request for the application model and for the distributed application.

10. The one or more storage medium of claim 9, wherein the one or more storage medium comprise the computer system with the computer-executable instructions being stored on system memory of the computer system.

11. The one or more storage medium as recited in claim 9, wherein the act of receiving a command request comprises an act of receiving a software lifecycle command request selected from among:

verify, clean, check, fix, deploy, start, stop, undeploy.

12. The one or more storage medium as recited in claim 9, wherein the act of creating an instance of the workflow comprises an act creating a workflow that includes one or more driver-related activities and one or more state-related activities.

13. The one or more storage medium as recited in claim 9, wherein the method further comprises:

an act of locking the application model while the workflow instance implements the command request for the application model.

14. The one or more storage medium as recited in claim 9, wherein the method further comprises:

an act of receiving a request for the status of the workflow instance from a user tool, the status request include the command ID for the workflow instance;

an act of using the command ID to refer to the command record for the workflow instance;

an act of accessing the state of the workflow instance from the command record; and

an act of returning the status to the user tool.

15. The one or more storage medium as recited in claim 9, wherein the method further comprises:

an act of detecting that the workflow instance has completed; and

an act of updating the command record to indicate the workflow instance completed such that completion of the workflow can be reflected in response to subsequent queries.

16. The one or more storage medium as recited in claim 9, wherein the method further comprises:

an act of recording error information related to execution of the command in the repository;

an act of user tools subsequently accessing the error information to reason about problems with the application model; and

an act of the user tools acting upon the problems to correct the problems.

19. The one or more storage medium as recited in claim 13, wherein the act of determining that the workflow instance is to be stopped comprises:

an act of receiving a subsequent cancel call requesting that the workflow instance be stopped prior to the workflow instance completing implementation of the command request for the model application; and

an act of issuing a stop request to the workflow instance.

20. The one or more storage medium as recited in claim 16, wherein the act of receiving a subsequent request to stop the workflow instance comprises:

an act of determining that the cancel call is not responding; and

an act of receiving a terminate call requesting that the workflow be terminated in response to the determination that he cancel call is not responding.

17. One or more storage medium having stored computer-executable instructions which, when executed by one or more processors of a computer system, implement a method for releasing a command definition model for further use, the method comprising:

an act of receiving a command request for a distributed application, wherein the command request includes a command reference to a command definition model that defines a corresponding command and that identifies a corresponding workflow model, wherein the command request also includes a reference to an application model for the distributed application that is a declarative model that describes the structure and behavior of the distributed application by defining general operations of one or more modules in the distributed application, and wherein the command request indicates that the corresponding command is to be implemented for the application model and for the distributed application;

an act of creating a command record for the received command request in the repository, wherein the command record stores information related to implementing the command request;

an act of creating an instance of the workflow from the corresponding workflow model, wherein the workflow model describes how to implement the received command request for the application model, and wherein the workflow instance includes a set of pre-defined activities configured to interoperate to implement the command request for the application model;

an act of locking the application model to prevent further access to the application model while the workflow instance implements the command request for the application model;

an act of submitting the application model reference to the workflow instance to initiate the workflow instance for the application model;

an act of recording information related to the behavior of the workflow instance within the command record as the workflow instance implements the command request for the application model for the application model;

an act of determining that the workflow instance is to be stopped;

an act of determining that the workflow instance is stopped; and

an act of releasing the lock on the application model such that other commands can be implemented for the application model.

18. The one or more storage medium of claim 17, wherein the one or more storage medium comprise the computer system with the computer-executable instructions being stored on system memory of the computer system.