Package org.apache.hadoop.hbase.replication.regionserver

Class PeerProcedureHandlerImpl

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.PeerProcedureHandlerImpl

All Implemented Interfaces:

PeerProcedureHandler

@Private
public class PeerProcedureHandlerImpl
extends Object
implements PeerProcedureHandler

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private final PeerActionListener	peerActionListener
private final KeyLocker<String>	peersLock
private final ReplicationSourceManager	replicationSourceManager

Constructor Summary

Constructors

Constructor	Description
PeerProcedureHandlerImpl(ReplicationSourceManager replicationSourceManager, PeerActionListener peerActionListener)

Method Summary

Modifier and Type	Method	Description
void	addPeer(String peerId)
void	claimReplicationQueue(ReplicationQueueId queueId)
void	disablePeer(String peerId)
void	enablePeer(String peerId)
private void	refreshPeerState(String peerId)
void	removePeer(String peerId)
void	transitSyncReplicationPeerState(String peerId, int stage, HRegionServer rs)
void	updatePeerConfig(String peerId)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

replicationSourceManager

private final ReplicationSourceManager replicationSourceManager

peerActionListener

private final PeerActionListener peerActionListener

peersLock

private final KeyLocker<String> peersLock

Constructor Details

PeerProcedureHandlerImpl

public PeerProcedureHandlerImpl(ReplicationSourceManager replicationSourceManager,
 PeerActionListener peerActionListener)

Method Details

addPeer

public void addPeer(String peerId)
             throws IOException

Specified by:

addPeer in interface PeerProcedureHandler

Throws:

IOException

removePeer

public void removePeer(String peerId)
                throws IOException

Specified by:

removePeer in interface PeerProcedureHandler

Throws:

IOException

refreshPeerState

private void refreshPeerState(String peerId)
                       throws ReplicationException,
IOException

Throws:

ReplicationException

IOException

enablePeer

public void enablePeer(String peerId)
                throws ReplicationException,
IOException

Specified by:

enablePeer in interface PeerProcedureHandler

Throws:

ReplicationException

IOException

disablePeer

public void disablePeer(String peerId)
                 throws ReplicationException,
IOException

Specified by:

disablePeer in interface PeerProcedureHandler

Throws:

ReplicationException

IOException

updatePeerConfig

public void updatePeerConfig(String peerId)
                      throws ReplicationException,
IOException

Specified by:

updatePeerConfig in interface PeerProcedureHandler

Throws:

ReplicationException

IOException

transitSyncReplicationPeerState

public void transitSyncReplicationPeerState(String peerId,
 int stage,
 HRegionServer rs)
                                     throws ReplicationException,
IOException

Specified by:

transitSyncReplicationPeerState in interface PeerProcedureHandler

Throws:

ReplicationException

IOException

claimReplicationQueue

public void claimReplicationQueue(ReplicationQueueId queueId)
                           throws ReplicationException,
IOException

Specified by:

claimReplicationQueue in interface PeerProcedureHandler

Throws:

ReplicationException

IOException