Workload management of stateful program entities

• US 7,349,970 B2
• Filed: 03/29/2001
• Issued: 03/25/2008
• Est. Priority Date: 03/29/2001
• Status: Expired due to Fees

• Current Assignee: Google LLC (Alphabet Inc.)
• Original Assignee: International Business Machines Corporation
• Inventors: Freund, Thomas James, Storey, R. Anthony, Lawrence, Jonathan Peter Hoare, Dickinson, Barry, Clement, Andrew Simon, Dalton, Ann Eleanor, Normington, Glyn, Powell, Steven, Mitchell, Ian James
• Primary Examiner(s): Jaroenchonwanit; Bunjob
• Assistant Examiner(s): HOANG, HIEU T
• Application Number:
  US10/469,563
• Publication Number:
  US 20040078782A1
• Time in Patent Office: 2,553 Days
• Field of Search: 709227-229, 709201-203
• US Class Current: 709/228
• CPC Class Codes: G06F 2209/5016 Session
• CPC Class Codes: G06F 9/5033 considering data affinity
• CPC Class Codes: G06F 9/505 considering the load

Abstract

In a workload managed system comprising a plurality of server processes each capable of supporting a given program entity, such as an Enterprise JavaBeans™ specified stateful session bean, a stateful session bean instance is passivated, by writing it to a bean store, on completion of a unit of work. On next use the session bean is reactivated, by reading it from the bean store, in any one of the plurality of servers thereby allowing workload management for stateful session beans. A routing table is maintained, in non-volatile mass storage, that contains location information for units of work and stateful session bean instances, used to maintain unit of work-server affinity for the lifetime of the unit of work Stateful session beans instances are associated with ID keys that include a flag that is used to indicate whether or not the routing table contains location information for the bean instance.

Claims

1. In a data processing system having a nonvolatile memory storage device and at least one server, capable of running a server process, a method of data processing a program entity, comprising the steps of:

maintaining program entity instance location information in a routing table on said nonvolatile memory storage device, wherein said routing table is used on receipt of a request to access an instance of said program entity to route said request to one of a plurality of server processes in which said instance of said program entity is currently active or to route said request to any of said plurality of server processes when said instance of said program entity is currently passive in a program entity store;

associating a key with said instance of said program entity for use in identifying said instance of said program entity as a target for said request, wherein said key includes a flag to indicate the presence of said location information for said instance of said program entity in said routing table, and wherein when said flag is not set in said key on receipt of said request, said routing table is not searched for said location information of said instance of said program entity to reduce routing table searches for performance optimization;

passivating, as part of a first server process, an instance of said program entity by writing it to a program entity store, on said nonvolatile memory storage device, and removing it from said first server process;

reactivating, as part of a second server process, said instance of said program entity by reading it from said program entity store and re-creating it in said second server process; and

selecting a server process from said plurality of server processes in which said instance of said program entity is reactivated according to a workload distribution algorithm using said routing table.

2. A method as claimed in claim 1 in which said first server process executes a unit of work on behalf of a client under which said program entity instance is accessed and said step of passivating passivates said program entity instance on completion of said unit of work.

3. A method as claimed in claim 2 wherein said unit of work comprises a transaction.

4. A method as claimed in claim 2 wherein said unit of work comprises a business method.

5. A method as claimed in any preceding claim wherein said program entity comprises a stateful session bean.

6. A method as claimed in claim 2 wherein said reactivating step reads and removes said instance of said program entity from said program entity store, thereby ensuring that if said program entity instance is reactivated under said unit of work it cannot be re-accessed outside said unit of work until said unit of work completes.

7. A computer program product stored on a computer readable storage medium, for use in a data processing system having a non-volatile memory storage device and at least one server, capable of running a server process, said product comprising instructions which, when executed, cause said system to process a program entity by carrying out the steps of:

maintaining program entity instance location information in a routing table on said nonvolatile memory storage device, wherein said routing table is used on receipt of a request to access an instance of said program entity to route said request to one of a plurality of server processes in which said instance of said program entity is currently active or to route said request to any of said plurality of server processes when said instance of said program entity is currently passive in a program entity store;

associating a key with said instance of said program entity for use in identifying said instance of said program entity as a target for said request, wherein said key includes a flag to indicate the presence of said location information for said instance of said program entity in said routing table, and wherein when said flag is not set in said key on receipt of said request, said routing table is not searched for said location information of said instance of said program entity to reduce routing table searches for performance optimization;

passivating, as part of a first server process, an instance of said program entity by writing it to a program entity store, on said nonvolatile memory storage device, and removing it from said first server process;

reactivating, as part of a second server process, said instance of said program entity by reading it from said program entity store and re-creating it in said second server process; and

selecting a server process from said plurality of server processes in which said instance of said program entity is reactivated according to a workload distribution algorithm using said routing table.

8. A computer program product as claimed in claim 7 in which said first server process executes a unit of work on behalf of a client under which said program entity instance is accessed and said step of passivating passivates said program entity instance on completion of said unit of work.

9. A computer program product as claimed in claim 8 wherein said unit of work comprises a transaction.

10. A computer program product as claimed in claim 8 wherein said unit of work comprises a business method.

11. A computer program product as claimed in claim 7 wherein said program entity comprises a stateful session bean.

12. A computer program product as claimed in claim 8 wherein said reactivating step reads and removes said instance of said program entity from said program entity store, thereby ensuring that if said program entity instance is reactivated under said unit of work it cannot be re-accessed outside said unit of work until said unit of work completes.

13. A data processing system comprising:

at least one server;

a plurality of server processes, capable of running on said at least one server, each with support for a program entity; and

a non-volatile memory storage device, accessible to each server process;

wherein each server process comprises;

means for maintaining program entity instance location information in a routing table on said nonvolatile memory storage device, wherein said routing table is used on receipt of a request to access an instance of said program entity to route said request to one of a plurality of server processes in which said instance of said program entity is currently active or to route said request to any of said plurality of server processes when said instance of said program entity is currently passive in a program entity store;

means for associating a key with said instance of said program entity for use in identifying said instance of said program entity as a target for said request, wherein said key includes a flag to indicate the presence of said location information for said instance of said program entity in said routing table, and wherein when said flag is not set in said key on receipt of said request, said routing table is not searched for said location information of said instance of said program entity to reduce routing table searches for performance optimization;

means for passivating an instance of said program entity by writing it to a program entity store on said nonvolatile memory storage device;

means for reactivating an instance of said program entity by reading it from said program entity store and using it to recreate said instance of said program entity;

said means for reactivating being capable of reactivating program entity instances that were passivated by the passivating means of a different server process; and

means for selecting a server process from said plurality of server processes in which said instance of said program entity is reactivated according to a workload distribution algorithm using said routing table.

14. A data processing system as claimed in claim 13, each of said plurality of server processes further comprising:

means to execute a unit of work on behalf of a client under which a first instance of said program entity is accessed;

wherein said means for passivating said instance of said program entity passivates said first instance of said program entity on completion of said unit of work.

15. A data processing system as claimed in claim 14, wherein said unit of work comprises a transaction.

16. A data processing system as claimed in claim 14, wherein said unit of work comprises a business method.

17. A data processing system as claimed in claim 13 wherein said program entity comprises a stateful session bean.

18. A data processing system as claimed in claim 14, wherein said reactivating means reads and removes an instance of said program entity from said program entity store, thereby ensuring that if said reactivating means reactivates said first program entity instance under said unit of work, said first program entity instance cannot be re-accessed outside said unit of work until said unit of work completes.