public class QuorumReadImpl<S extends HAReadGlue> extends QuorumStateChangeListenerBase implements QuorumRead<S>
|Modifier and Type||Method and Description|
Used by any service joined with the quorum to read a record from another service joined with the quorum in order to work around a "bad read" as identified by a checksum error on the local service.
consensus, lostConsensus, memberAdd, memberRemove, pipelineAdd, pipelineChange, pipelineElectedLeader, pipelineRemove, pipelineUpstreamChange, quorumBreak, quorumMeet, serviceJoin, serviceLeave
protected java.util.UUID getNextBadReadServiceId(java.util.UUID joinedServiceIds)
UUIDof the joined service to which this service will direct a failover read. The default implementation uses a round-robin policy.
UUIDs of the services currently joined with the quorum.
UUIDof the service to which the failover read will be directed.
public byte readFromQuorum(java.util.UUID storeId, long addr) throws java.lang.InterruptedException, java.io.IOException
Note: This is NOT the normal path for reading on a record from a service. This is used to handle bad reads (when a checksum or IO error is reported by the local disk) by reading the record from another member of the quorum.
QuorumRead<S extends HAReadGlue>
IRawStorefrom which the record should be read.
addr- The address of a record on that store.
Copyright © 2006-2014 SYSTAP, LLC. All Rights Reserved.