Optimistic reads in a multi-node environment
A method, system, computer system, and computer program produce to support a distributed environment in which changes to data shared by multiple nodes are logged using private logs and managed by a coordinator. The coordinator recognizes invalidating operations and informs a reader when data need to be read again after an invalidating operation corrupted and/or caused the copy of the data read by the reader to be out-of-date. The coordinator can provide a location from which current valid data can be read. The coordinator can use an operations history to detect invalidating operations and operations trackers to determine when a node is not synchronized with the coordinator.
1. A method comprising:
receiving a request to perform a first read operation to read data from a first location, wherein the request comprises a first tracker value;
transmitting a notification to perform a second read operation to read the data from the first location, if the first tracker value is less than a second tracker value, wherein the second tracker value is associated with the first location; and
transmitting a notification of permission to perform the first read operation to read the data from the first location, if the first and second tracker values are equal.
2. The method of claim 1 further comprising:
transmitting a notification to read the data from a second location, if a lock is associated with the first location.
3. The method of claim 2 , wherein the second location is a log comprising a version of the data.
4. The method of claim 3 further comprising:
performing said transmitting the notification to read the data from the second location, if reading from the log is permitted.
5. The method of claim 1 further comprising:
transmitting a notification to wait to read the data from the first location, if a lock is associated with the first location;
determining when the lock associated with the first location is unlocked; and
transmitting a notification to read the data from the first location, in response to said determining when the lock associated with the first location is unlocked.
6. The method of claim 5 further comprising:
performing said transmitting the notification to wait, if reading from a log comprising a version of the data is not permitted.
7. The method of claim 1 , wherein
the request to perform the first read operation to read data from the first location originates from a first node, and
the first tracker value is associated with a time of an immediately previous instance in which the first node communicated with a node performing said receiving the request to perform the first read operation to read data.
8. The method of claim 1 , wherein
the second tracker value is associated with a time of an invalidating operation associated with data stored at the first location.
9. The method of claim 8 , wherein an invalidating operation comprises at least one of
a write operation to the data stored at the first location,
a configuration of storage in which the data are stored,
a configuration of a cluster managing the data, and
a partition of the cluster.
10. A system comprising:
a processor;
a memory, coupled to the processor, storing instructions executable by the processor, said instructions configured to cause the processor to
receive a request to perform a first read operation to read data from a first location, wherein the request comprises a first tracker value;
transmit a notification to perform a second read operation to read the data from the first location, if the first tracker value is less than a second tracker value, wherein the second tracker value is associated with the first location; and
transmit a notification of permission to perform the first read operation to read the data from the first location, if the first and second tracker values are equal.
11. The system of claim 10 wherein the memory stores additional instructions executable by the processor, said instructions configured to cause the processor to
transmit a notification to read the data from a second location, if a lock is associated with the first location.
12. The system of claim 10 wherein the memory stores additional instructions executable by the processor, said instructions configured to cause the processor to:
transmit a notification to wait to read the data from the first location, if a lock is associated with the first location;
determine when the lock associated with the first location is unlocked; and
transmit a notification to read the data from the first location, in response to said determining when the lock associated with the first location is unlocked.
13. An apparatus comprising:
means for receiving a request to perform a first read operation to read data from a first location, wherein the request comprises a first tracker value;
means for transmitting a notification to perform a second read operation to read the data from the first location, if the first tracker value is less than a second tracker value, wherein the second tracker value is associated with the first location; and
means for transmitting a notification of permission to perform the first read operation to read the data from the first location, if the first and second tracker values are equal.
14. The apparatus of claim 13 further comprising:
means for transmitting a notification to read the data from a second location, if a lock is associated with the first location.
15. The apparatus of claim 13 further comprising:
means for transmitting a notification to wait to read the data from the first location, if a lock is associated with the first location;
means for determining when the lock associated with the first location is unlocked; and
means for transmitting a notification to read the data from the first location, in response to said means for determining when the lock associated with the first location is unlocked.
16. A computer-readable storage medium comprising:
a first set of instructions, executable by a processor, configured to receive a request to perform a first read operation to read data from a first location, wherein the request comprises a first tracker value;
a second set of instructions, executable by the processor, configured to transmit a notification to perform a second read operation to read the data from the first location, if the first tracker value is less than a second tracker value, wherein the second tracker value is associated with the first location; and
a third set of instructions, executable by the processor, configured to transmit a notification of permission to perform the first read operation to read the data from the first location, if the first and second tracker values are equal.
17. The computer-readable storage medium of claim 16 further comprising:
a forth set of instructions, executable by the processor, configured to transmit a notification to read the data from a second location, if a lock is associated with the first location.
18. The computer-readable storage medium of claim 16 further comprising:
a fourth set of instructions, executable by the processor, configured to transmit a notification to wait to read the data from the first location, if a lock is associated with the first location;
a fifth set of instructions, executable by the processor, configured to determine when the lock associated with the first location is unlocked; and
a sixth set of instructions, executable by the processor, configured to transmit a notification to read the data from the first location, in response to said determining when the lock associated with the first location is unlocked.