Package org.apache.hadoop.hbase.master.replication

Class SyncReplicationReplayWALManager.UsedReplayWorkersForPeer

java.lang.Object

org.apache.hadoop.hbase.master.replication.SyncReplicationReplayWALManager.UsedReplayWorkersForPeer

Enclosing class:

SyncReplicationReplayWALManager

private static final class SyncReplicationReplayWALManager.UsedReplayWorkersForPeer
extends Object

This class is used to record the used workers(region servers) for a replication peer. For balancing the replaying remote wal job, we will only schedule one remote replay procedure each time. So when acquiring a worker, we will first get all the region servers for this cluster, and then filter out the used ones.

The ProcedureEvent is used for notifying procedures that there are available workers now. We used to use sleeping and retrying before, but if the interval is too large, for example, exponential backoff, then it is not effective, but if the interval is too small, then we will flood the procedure wal.

The states are only kept in memory, so when restarting, we need to reconstruct these information, using the information stored in related procedures. See the afterReplay method in RecoverStandbyProcedure and SyncReplicationReplayWALProcedure for more details.

Field Summary

Fields

Modifier and Type	Field	Description
private final ProcedureEvent<?>	event
private final Set<ServerName>	usedWorkers

Constructor Summary

Constructors

Constructor	Description
UsedReplayWorkersForPeer(String peerId)

Method Summary

Modifier and Type	Method	Description
Optional<ServerName>	acquire(ServerManager serverManager)
void	release(ServerName worker)
void	suspend(Procedure<?> proc)
void	used(ServerName worker)
void	wake(MasterProcedureScheduler scheduler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

usedWorkers

private final Set<ServerName> usedWorkers

event

private final ProcedureEvent<?> event

Constructor Details

UsedReplayWorkersForPeer

public UsedReplayWorkersForPeer(String peerId)

Method Details

used

public void used(ServerName worker)

acquire

public Optional<ServerName> acquire(ServerManager serverManager)

release

public void release(ServerName worker)

suspend

public void suspend(Procedure<?> proc)

wake

public void wake(MasterProcedureScheduler scheduler)