DATA PROCESSING METHOD

• US 20140082041A1
• Filed: 11/20/2013
• Published: 03/20/2014
• Est. Priority Date: 05/20/2011
• Status: Abandoned Application

• Current Assignee: Fujitsu Limited
• Original Assignee: Fujitsu Limited
• Inventors: Kurihara, Koji, Yamashita, Koichiro, Suzuki, Takahisa, Yamauchi, Hiromasa, Otomo, Toshiya, Odate, Naoki
• Application Number:
  US14/085,131
• Publication Number:
  US 20140082041A1
• Time in Patent Office: Days
• US Class Current: 709/201
• CPC Class Codes: G06F 9/5072 Grid computing
• CPC Class Codes: H04L 43/00 Arrangements for monitoring or testing data switching networks
• CPC Class Codes: H04L 67/1097 for distributed storage of data in networks, e.g. transport arrangements for network file system [NFS], storage area networks [SAN] or network attached storage [NAS]
• CPC Class Codes: H04W 8/005 Discovery of network devices, e.g. terminals

Abstract

A data processing method is executed by a processor, and includes detecting an addition request to add a first device to a first group that includes a plurality of devices; registering the first device into a main group in which devices of the first group are registered, the first device being registered when the first device does not belong to a second group that is different from the first group; registering the first device into a subgroup, when the first device belongs to the second group; and performing by the devices registered in the main group, distributed processing that includes a plurality of tasks.

Claims

1. A data processing method that is executed by a processor, the data processing method comprising:

detecting an addition request to add a first device to a first group that includes a plurality of devices;

registering the first device into a main group in which devices of the first group are registered, the first device being registered when the first device does not belong to a second group that is different from the first group;

registering the first device into a subgroup, when the first device belongs to the second group; and

performing by the devices registered in the main group, distributed processing that includes a plurality of tasks.

2. The data processing method according to claim 1, wherein

the detecting includes detecting an addition request to add a second device to the first group,

the data processing method further comprises comparing a first count that is a count of the devices and a second count that is a count of the tasks, and

registering based on a comparison result, the second device into any one among the main group and the subgroup.

3. The data processing method according to claim 2, wherein

the registering of the second device includes registering the second device into the subgroup, when the first count is at least equal to the second count, and

the registering of the second device includes registering the second device into the main group, when the first count is less than the second count.

4. The data processing method according to claim 1, further comprising

registering in a master terminal of the subgroup, a synchronization request that is for the first device and from another device included in the second group, when the first device is registered in the subgroup.

5. The data processing method according to claim 1, further comprising

notifying a base station of registration or no-registration to the main group.

6. The data processing method according to claim 1, further comprising

deleting from the main group and when the first count is greater than the second count, registration of a third device to which no task among the tasks has been assigned.

7. The data processing method according to claim 6, wherein

the deleting includes refraining from deleting from the main group, the registration of the third device, when a memory area that is set in the third device and is part of shared memory that is shared by the devices is being used.

8. The data processing method according to claim 6, further comprising

releasing setting of the shared memory, when a size of memory used by tasks among the tasks is greater than a size of shared memory that is shared by the devices.

9. The data processing method according to claim 1, wherein

the deleting includes deleting from any one among the main group and the subgroup, registration of a fourth device, when any one among deterioration of a communication capability of the fourth device that is registered in the main group is detected and execution results of a task of the fourth device is acquired.

10. The data processing method according to claim 9, further comprising

collecting data that is in the memory area, when the memory area that is set in the fourth device and part of shared memory that is shared by the devices, is being used.

11. The data processing method according to claim 9, further comprising

releasing setting of the shared memory, when a size of memory used by tasks among the tasks is greater than a size of shared memory that is shared by the devices.

12. The data processing method according to claim 6, further comprising

notifying a base station of deletion of registration from the main group.

13. A data processing method that is executed by a processor, the data processing method comprising:

detecting a synchronization request that is to a first device and from a second device among devices included in a first group; and

when the first device is included in a second group that is different from the first group and is registered in a subgroup that corresponds to a main group in which a plurality of devices that execute distributed processing that includes a plurality of tasks is registered,

notifying each device that manages the main group and the subgroup, of the synchronization request to register the first device into the subgroup.

14. The data processing method according to claim 13, further comprising:

receiving a deletion request from the first group; and

migrating a task to one device among the devices included in the first group, when the task is assigned to the first device and included among the tasks included in distributed processing that is executed by the devices included in the first group.

15. The data processing method according to claim 13, further comprising

migrating to one device among the devices included in the first group, data in a memory area that is part of shared memory that is shared by the devices included in the first group, when the memory area is being used.

16. The data processing method according to claim 13, further comprising:

receiving an execution request for a task that is included in distributed processing that is executed by the devices included in the first group; and

migrating a task to one device among devices included in the second group, when the task is assigned to the first device and included in the distributed processing that is executed by the devices included in the second group.

17. The data processing method according to claim 13, further comprising

migrating to one device among devices included in the second group, a task that is assigned to the first device and included in the distributed processing that is executed by the devices included in the second group, the task being migrated when execution of a task that is included in the distributed processing that is executed by the devices of the first group is started.