Method and apparatus for construction and aggregation of distributed computations

• US 8,745,121 B2
• Filed: 06/28/2010
• Issued: 06/03/2014
• Est. Priority Date: 06/28/2010
• Status: Active Grant

• Current Assignee: Nokia Technologies Oy (Nokia Corporation)
• Original Assignee: Nokia Corporation
• Inventors: Boldyrev, Sergey, Honkola, Jukka, Sovio, Sampo Juhani, Laine, Hannu, Oliver, Ian Justin, Brown, Ronald Stephen, Mannermaa, Mika Juhani, Luukkala, Vesa-Veikko, Silanto, Samuli
• Primary Examiner(s): Chan, Wing F
• Assistant Examiner(s): Yohannes, Tesfay
• Application Number:
  US12/825,043
• Publication Number:
  US 20110320516A1
• Time in Patent Office: 1,436 Days
• Field of Search: 709/201, 709/203, 709/217, 379/219, 219/219
• US Class Current: 709/201
• CPC Class Codes: G06F 9/461 Saving or restoring of program or task context

Abstract

An approach is provided for construction and aggregation of distributed computations. A distributed computation construction infrastructure identifies an execution context bound to a user context at a device, the execution context corresponding to one or more processes executing at the device. The distributed computation construction infrastructure further causes, at least in part, decomposition of the execution context into one or more closure primitives and respective process states, wherein the one or more closure primitives represent computation closures of the one or more processes. The distributed computation construction infrastructure also causes, at least in part, serialization of the one or more closure primitives, the process states, or a combination thereof. The distributed computation construction infrastructure further causes, at least in part, aggregation of the one or more primitives and the respective process states to reconstruct at least a portion of the execution context based, at least in part, on consistency determination.

Claims

1. A method comprising:

identifying an execution context bound to a user context at a device, the execution context corresponding to one or more processes executing at the device;

causing, at least in part, decomposition of the execution context into one or more closure primitives and respective process states, wherein the one or more closure primitives represent computation closures of the one or more processes;

causing, at least in part, serialization of the one or more closure primitives, the process states, or a combination thereof, into a resource description framework format;

identifying one or more run-time context groups;

determining one or more run-time environments associated with the one or more run-time context groups; and

causing, at least in part, serialization of the one or more run-time context groups and the one or more run-time environments, into the resource description framework format,

wherein the resource description framework format includes resource description framework graphs.

2. A method of claim 1, further comprising:

causing, at least in part, storage and distribution thereof of the serialized one or more closure primitives, the serialized process states, the serialized one or more run-time context groups, the serialized one or more run-time environments, or a combination thereof, wherein the distribution involves one or more other devices to share computation load of the device.

3. A method of claim 1, wherein the storage, the distribution, or the combination thereof is via an information space accessible by one or more other devices, one or more servers, one or more cloud computing components, or a combination thereof, and wherein access to the storage, the distribution, or the combination thereof is based, at least in part, on an authentication mechanism.

4. A method of claim 1, wherein the serialization of the one or more closure primitives, the process states, or the combination thereof is based, at least in part, on a level of granularity including resource description framework triples, the closure primitives represent simplest computation closures of the one or more processes, and at least one of the closure primitives is pre-computed and re-used as is.

5. A method of claim 1, further comprising:

determining to detect an event for specifying one or more of the computation closures for transfer among the device, another device, a back end, or a combination thereof,

wherein at least one of the identifying of the execution context, the decomposition of the execution context, and the serialization of the one or more closure primitives is based, at least in part, on the event.

6. An apparatus comprising:

at least one processor; and

at least one memory including computer program code for one or more programs,

the at least one memory and the computer program code configured to, with the at least one processor, cause the apparatus to perform at least the following,

identify an execution context bound to a user context at a device, the execution context corresponding to one or more processes executing at the device;

cause, at least in part, decomposition of the execution context into one or more closure primitives and respective process states, wherein the one or more closure primitives represent computation closures of the one or more processes;

cause, at least in part, serialization of the one or more closure primitives, the process states, or a combination thereof, into a resource description framework format;

identify one or more run-time context groups;

determine one or more run-time environments associated with the one or more run-time context groups; and

cause, at least in part, serialization of the one or more run-time context groups and the one or more run-time environments, into the resource description framework format,

wherein the resource description framework format includes resource description framework graphs.

7. An apparatus of claim 6, wherein the apparatus is further caused to:

cause, at least in part, storage, distribution, or a combination thereof of the serialized one or more closure primitives, the serialized process states, the serialized one or more run-time context groups, the serialized one or more run-time environments, or a combination thereof.

8. An apparatus of claim 6, wherein the storage, the distribution, or the combination thereof is via an information space accessible by one or more other devices, one or more servers, one or more cloud computing components, or a combination thereof, and wherein access to the storage, the distribution, or the combination thereof is based, at least in part, on an authentication mechanism.

9. A method comprising:

retrieving one or more closure primitives and respective process states from a storage, the one or more closure primitives representing computation closures of one or more processes corresponding to an execution context bound to a user context at a device, and the one or more closure primitives are serialized into a resource description framework format;

causing, at least in part, locking of the one or more closure primitives in the storage;

determining a consistency of the one or more closure primitives before and after the serialization;

causing, at least in part, aggregation of the one or more closure primitives and the respective process states to reconstruct at least a portion of the execution context based, at least in part, on the consistency determination;

identifying one or more run-time context groups;

determining one or more run-time environments associated with the one or more run-time context groups; and

causing, at least in part, serialization of the one or more run-time context groups and the one or more run-time environments, into the resource description framework format.

10. A method of claim 9, further comprising:

causing, at least in part, resumption of execution of the at least a portion of the execution context,

wherein the consistency determination includes checking logical relationship among the one or more closure primitives, the respective process states, data flows among the one or more closure primitives, parameter exchange among the one or more closure primitives, or a combination thereof.

11. A method of claim 10,

wherein the resumption of the execution of the at least a portion of the execution context is based, at least in part, on the one or more run-time context groups, the one or more run-time environments, or the combination thereof.

12. A method of claim 9, wherein results of the resumption of the execution are combined with one or more other results of other executions of at least a portion of the execution state.

13. A method of claim 9, wherein the storage is an information space accessible by one or more other devices, one or more servers, one or more cloud computing components, or a combination thereof, and wherein access to the storage is based, at least in part, on an authentication mechanism.

14. A method of claim 9, further comprising:

determining to detect an event for specifying the execution context for transfer among a device, another device, a back end, or a combination thereof,

wherein at least one of the retrieving of the one or more closure primitives, the locking of the one or more closure primitives, the determining of the consistency of the one or more closure primitives, and the aggregation of the one or more primitives and the respective process states is based, at least in part, on the event.

15. An apparatus comprising:

at least one processor; and

at least one memory including computer program code,

the at least one memory and the computer program code configured to, with the at least one processor, cause the apparatus to perform at least the following,

retrieve one or more closure primitives and respective process states from a storage, the one or more closure primitives representing computation closures of one or more processes corresponding to an execution context bound to a user context at a device, and the one or more closure primitives are serialized into a resource description framework format;

cause, at least in part, locking of the one or more closure primitives in the storage;

determine a consistency of the one or more closure primitives before and after the serialization;

cause, at least in part, aggregation of the one or more closure primitives and the respective process states to reconstruct at least a portion of the execution context based, at least in part, on the consistency determination;

identify one or more run-time context groups;

determine one or more run-time environments associated with the one or more run-time context groups; and

cause, at least in part, serialization of the one or more run-time context groups and the one or more run-time environments, into the resource description framework format,

wherein the resource description framework format includes resource description framework graphs.

16. An apparatus of claim 15, wherein the apparatus is further caused to:

cause, at least in part, resumption of execution of the at least a portion of the execution context.

17. An apparatus of claim 16,

wherein the resumption of the execution of the at least a portion of the execution context is based, at least in part, on the one or more run-time context groups, the one or more run-time environments, or the combination thereof.

18. An apparatus of claim 15, wherein results of the resumption of the execution are combined with one or more other results of other executions of at least a portion of the execution state.