Patent application number | Description | Published |
20130042307 | COMMUNICATION METHOD AND INFORMATION PROCESSING SYSTEM - A communication method in an information processing system including a group of first information processing apparatuses that transmit data and a group of second information processing apparatuses that receive the data is disclosed. The communication method includes storing data subject to being transmitted to one of the second information processing apparatuses in a data storage by associating the data with identifier information of the second information processing apparatus, and performing transmission processing to transmit the stored data to the second information processing apparatus in response to reception of a first token generated by the second information processing apparatus serving as a generating source of the first token, the first tokens indicating a transmission right to transmit the data to the second information processing apparatus and being transferred between the group of the first information processing apparatuses and between the group of the second information processing apparatuses. | 02-14-2013 |
20130138689 | SERVER DEVICE, COMPUTER-READABLE STORAGE MEDIUM AND MOVEMENT CONTROL METHOD - A specification unit specifies a cycle in which data to be processed by queries is distributed, the queries being arranged at a node and movable between the nodes and performing a processing when the data matches with a set condition. An instruction unit instructs a node as a movement source to move the queries during a period when the data to be processed by the queries to be moved is not distributed on the basis of the specified cycle. | 05-30-2013 |
20130138834 | SERVER DEVICE, COMPUTER-READABLE STORAGE MEDIUM, AND METHOD OF ASSURING DATA ORDER - A stop unit stops transmitting data to a plurality of nodes for every predetermined period. An acquisition unit acquires versions of routing tables, which are updated in accordance with movement of a query, from the plurality of nodes when the transmission of the data is stopped. A comparison unit compares the versions of the routing tables of the plurality of nodes that are acquired. when there is a node in which the routing table of an old version is stored as a result of the comparison, an update unit updates the routing table of the node. | 05-30-2013 |
20130204941 | METHOD AND SYSTEM FOR DISTRIBUTED PROCESSING - Nodes at first, second, and third locations have the same first-axis coordinates, while nodes at the first, fourth, and fifth locations have the same second-axis coordinates. First transmission transmits data elements from the node at the first location to nodes at the second and fourth locations, as well as to the node at either the third location or the fifth location. Second transmission transmits data elements from nodes at the second locations to nodes at the first, fourth, and fifth locations. Third transmission transmits data elements from nodes at the third locations to nodes at the first, second, and fourth locations. These three transmissions are performed with each node location selected as the base point on a diagonal line. The nodes execute a data processing operation by using the data elements assigned thereto and the data elements received as a result of the first to third transmissions. | 08-08-2013 |
20150100616 | DATA PROCESSING MANAGEMENT METHOD AND INFORMATION PROCESSING APPARATUS - First and second machines execute a plurality of distributed processes. A storing unit stores therein progress information of a process executed by the first machine. A calculating unit transmits the progress information to the second machine upon receiving a reassignment instruction indicating reassignment of the process to the second machine. The calculating unit transmits data to be used in the process to the second machine together with the progress information upon receiving the data during the transmission of the progress information. Upon receiving the progress information and the data, the second machine executes the process reassigned from the first machine using the progress information and the data. | 04-09-2015 |
20150281345 | DISTRIBUTED PROCESSING SYSTEM AND CONTROL METHOD - A control method for controlling a distributed processing system that performs distributed processing using a plurality of devices is executed by a processor. The method including acquiring load information from each of the plurality of devices, identifying a source device and a destination device based on the acquired load information, the source device being a device of a migration source of an allocated processing operation and the destination device being a device of a migration destination of the allocated processing operation. The method further including selecting as a processing operation of a migration target from among a plurality of processing operations allocated to the source device, a processing operation with which a rate that data used by the processing operation at the source device is to be used at the destination device is relatively high or higher than a predetermined rate. | 10-01-2015 |
20150301872 | PROCESS COOPERATION METHOD, PROCESS COOPERATION PROGRAM, AND PROCESS COOPERATION SYSTEM - A process cooperation method includes storing in a first storage device a first process result as a result of execution of a first process by a first processor and transmitting the first process result to a second processor, storing in a second storage device a second process result as a result of execution of a second process by the second processor based on the first process result received from the first processor, and transmitting the second process result to a third processor, and moreover transmitting the second process result and an identifier identifying the third processor to the first processor, and storing in the first storage device the second process result and the identifier received from the second processor by the first processor in association with the first process result. | 10-22-2015 |
20160142472 | SYSTEM, METHOD, AND MEDIUM - A system that includes circuitry configured to receive a plurality of pieces of data; store, for each of the plurality of pieces of data in a first memory area, a first identifier and associated node information identifying a node that processes associated piece of data; delete one of the first identifiers from the first memory area in a case that a number of first identifiers stored in the first memory area reaches a threshold; generate a second identifier based on deleted first identifier by applying a predetermined calculation on the deleted first identifier, the second identifier being shorter than the first identifier; store, in a second memory area, the second identifier and the associated node information; cause a node, associated with one of the first identifier and the second identifier stored in one of the first and second memory area, to process one of the plurality of pieces of data. | 05-19-2016 |