Information processing device and method

1. An information processing device comprising:

a memory; and

a processor coupled to the memory and configured to execute a process including:

selecting, from among a plurality of data processing sections that subject data blocks to a predetermined process, a data processing section to which one of first data block groups is allocated, wherein the data blocks are classified into a plurality of the first data block groups based on first identification information regarding the respective data blocks,

dividing, when a workload placed on the selected data processing section exceeds a first threshold, the one of the first data block groups allocated to the selected data processing section into a plurality of second data block groups based on second identification information regarding the respective data blocks, and selecting, from among the plurality of data processing sections, data processing sections to which the plurality of second data block groups are allocated,

acquiring the first identification information from flow information on flows to which the data blocks pertain,

acquiring the second identification information from information of the flow information which is different from the first identification information,

calculating a hash value from the flow information,

acquiring an N-diqit number (N: positive integer) from the hash value, as the first identification information, and

acquiring an M-diqit number (N <M≦the number of all the digits of the hash value) from the hash value, as the second identification information, the M-diqit number containing the N-digit number.

2. The information processing device according to claim 1 , wherein the process further includes:

re-creating the one of the first data block groups by aggregating the second data block groups when a total workload for the plurality of second data block groups becomes less than a second threshold and lower than a processing capacity of one of the plurality of data processing sections.

3. The information processing device according to claim 1 , wherein the process further includes:

storing, in a first storage section, a relationship between the first identification information and the data processing section to which the first data block group is allocated, and

storing, when creating the plurality of second data block groups from the one of the first data block groups, in a second storage section, a relationship between the second identification information and the data processing sections to which the plurality of second data block groups are allocated, the second storage section being independent of the first storage section.

4. The information processing device according to claim 1 , wherein the process further includes:

selecting, when receiving an entry of the flow information from a controller, the data processing section to which the one of the first data block groups is allocated, the controller being configured to acquire the flow information from a control data block transmitted before an arrival of the data blocks.

5. The information processing device according to claim 1 , wherein the process further includes:

deciding upon a value of M indicating the M-digit number of the hash value that is to be acquired and used as the second identification information when a new first data block group is divided into second data block groups, based on a first deviation of flows included in the respective second data blocks that have been created by dividing at least one first data block group and a second deviation of flows that have been allocated to the respective data processing sections.

6. The information processing device according to claim 5 , wherein the process further includes:

acquiring the first deviation, based on standard deviations of the numbers of flows included in the respective second data block groups that have been created by dividing the at least one first data block group, and

acquiring the second deviation, based on a standard deviation of the numbers of flows that have been allocated to the respective data processing sections.

7. The information processing device according to claim 6 , wherein the deciding upon the value of M includes multiplying an initial value of M with a sum of 1(one), a product of the first deviation and a first weight coefficient, and a product of the second deviation and a second weight coefficient.

8. The information processing device according to claim 7 , wherein the process further includes:

setting, when the largest value among the numbers of flows that have been allocated to the respective data processing sections is greater than or equal to a third threshold and the standard deviation of the numbers of flows that have been allocated to the respective data processing sections is greater than or equal to a fourth threshold, the second deviation to have a positive value of the standard deviation,

setting, when the largest value among the numbers of flows that have been allocated to the respective data processing sections is less than the third threshold and the standard deviation of the numbers of flows that have been allocated to the respective data processing sections is less than the fourth threshold, the second deviation to have a negative value of the standard deviation, and

setting the second deviation to 0 when the largest value among the numbers of flows that have been allocated to the respective data processing sections is greater than or equal to the third threshold and the standard deviation of the numbers of flows that have been allocated to the respective data processing sections is less than fourth threshold or when the largest value among the numbers of flows that have been allocated to the respective data processing sections is less than the third threshold and the standard deviation of the numbers of flows that have been allocated to the respective data processing sections is greater than or equal to the fourth threshold.

9. An information processing method comprising:

selecting, from among a plurality of data processing sections that subject data blocks to a predetermined process, a data processing section to which one of first data block groups is allocated, wherein the data blocks are classified into a plurality of the first data block groups based on first identification information regarding the respective data blocks; and

dividing, when a workload placed on the selected data processing section exceeds a first threshold, the one of the first data block groups allocated to the selected data processing section into a plurality of second data block groups based on second identification information regarding the respective data blocks, and selecting, from among the plurality of data processing sections, data processing sections to which the plurality of second data block groups are allocated;

acquiring the first identification information from flow information on flows to which the data blocks pertain;

acquiring the second identification information from information of the flow information which is different from the first identification information;

calculating a hash value from the flow information;

acquiring an N-digit number (N: positive integer) from the hash value, as the first identification information; and

acquiring an M-digit number (N <M≦the number of all the digits of the hash value) from the hash value, as the second identification information, the M-digit number containing the N-digit number,

wherein the selecting and the dividing are performed by a processor.