Data processing apparatus, data processing method, and computer program product, and entry processing apparatus
View Patent ↗According to an embodiment, an update request reception unit receives a data update request to update data stored in a storage. A read request unit makes a read request to read data from the storage. A data reception unit receives the data from the storage. An update value calculator calculates an update value of the received data. A write request unit makes a write request to write the calculated update value into the storage. A data processing execution unit executes reading and writing on the storage. A history processing unit generates a history of the reading and deletes a history of reading corresponding to the writing. An update information estimator estimates, from the generated history, update information indicating how the data is to be updated. A data update unit updates the data read according to the estimated update information and output new updated data to the data reception unit.
1. A data processing apparatus comprising:
at least one memory having computer executable components stored therein; and
at least one processor communicatively coupled to the memory, the processor is configured to
receive a data update request to update data stored in a storage unit;
when the data update request is received, execute reading and writing of data from and to the storage unit corresponding to the data update request received,
when reading corresponding to a first data update request is executed, generate a history indicating the first data update request is made,
when reading corresponding to a second data update request is executed before writing corresponding to the first data update request is completed, the second data update request being received after receiving the first data update request, update data read by the reading corresponding to the second data update request to data that is written to the storage unit by the writing corresponding to the first data update request and that is indicated by the history generated, and
decide data that is written to the storage unit on the basis of the data updated by the updating and information according to writing corresponding to the second data update request.
2. The apparatus according to claim 1 , wherein
the receiving includes receiving the data update request including address information of data to be updated,
the executing includes executing reading and writing the data on the basis of the address information,
the generating includes generating the history including the address information used in the reading corresponding to the first data update request, and
when reading corresponding to the second data update request including address information identical to address information included in the first data update request is executed before writing corresponding to the address information included in the first data update request is completed, the updating includes updating data read by the reading corresponding to the second data update request to data that is written to the storage unit by the writing corresponding to the first data update request and that is indicated by the history generated.
3. The apparatus according to claim 1 , wherein
the receiving includes receiving the data update request including information of arithmetic performed on data to be updated,
the generating includes generating the history including the information of arithmetic corresponding to the first data update request,
the updating includes updating, based on the information of arithmetic included in the history generated, data read by the reading corresponding to the second data update request to data that is written to the storage unit by the writing corresponding to the first data update request and that is indicated by the history generated, and
the deciding includes deciding data that is written to the storage unit on the basis of the data updated by the updating and the information of arithmetic corresponding to the second data update request.
4. The apparatus according to claim 1 ,
wherein the processor is further configured to
when the second data update request is received while waiting for the reading data from the storage unit corresponding to the first data update request upon queuing the first data update request, queue the second data update request after the first data update request.
5. The apparatus according to claim 1 , wherein the processor is further configured to, when writing is executed by the executing, delete the history of the data update request corresponding to the writing.
6. A data processing method comprising:
receiving a data update request to update data stored in a storage unit;
when the data update request is received, executing reading and writing of data from and to the storage unit corresponding to the data update request received;
when reading corresponding to a first data update request is executed, generating a history indicating the first data update request is made;
when reading corresponding to a second data update request is executed before writing corresponding to the first data update request is completed, the second data update request being received after receiving the first data update request, updating data read by the reading corresponding to the second data update request to data that is written to the storage unit by the writing corresponding to the first data update request and that is indicated by the history generate; and
deciding data that is written to the storage unit on the basis of the data updated and information according to writing corresponding to the second data update request.
7. A computer program product comprising a non-transitory computer-readable medium containing programmed instructions, the instructions causing a computer to execute:
receiving a data update request to update data stored in a storage unit;
when the data update request is received, executing reading and writing of data from and to the storage unit corresponding to the data update request received;
when reading corresponding to a first data update request is executed, generating a history indicating the first data update request is made;
when reading corresponding to a second data update request is executed before writing corresponding to the first data update request is completed, the second data update request being received after receiving the first data update request, updating data read by the reading corresponding to the second data update request to data that is written to the storage unit by the writing corresponding to the first data update request and that is indicated by the history generate; and
deciding data that is written to the storage unit on the basis of the data updated and information according to writing corresponding to the second data update request.
8. An entry processing apparatus comprising:
at least one memory having computer executable components stored therein; and
at least one processor communicatively coupled to the memory, the processor is configured to
receive an update request, the update request being either an addition request to add an entry to a storage unit for storing therein an entry that includes a key and a value or a deletion request to delete an entry from the storage unit,
when the update request is received, specify an address of a bucket having a plurality of entries stored therein and execute reading and writing of the bucket,
when reading corresponding to a first update request is executed, generate as a history processing information indicating which request the first update request is, an addition request to add an entry to a bucket read or a deletion request to delete an entry from the bucket read,
when reading corresponding to a second update request is executed before writing corresponding to the first update request is completed, the second update request being received after receiving the first update request, update a bucket read by the reading corresponding to the second update request to a bucket that is written to the storage unit by the writing corresponding to the first update request and that is indicated by the history generated on the basis of the processing information included in the history, and
decide a bucket that is written to the storage unit on the basis of the bucket updated by the updating and the processing information corresponding to the second update request.