public class QuorumReadImpl<S extends HAReadGlue> extends QuorumStateChangeListenerBase implements QuorumRead<S>
|Modifier and Type||Field and Description|
|Constructor and Description|
|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 final QuorumMember<S extends HAReadGlue> member
public QuorumReadImpl(QuorumMember<S> member)
protected UUID getNextBadReadServiceId(UUID joinedServiceIds)
UUIDof the joined service to which this service will direct a failover read. The default implementation uses a round-robin policy.
public byte readFromQuorum(UUID storeId, long addr) throws InterruptedException, 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–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.