org.apache.hadoop.hbase.replication.regionserver

Class PeerProcedureHandlerImpl

java.lang.Object

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

All Implemented Interfaces:

PeerProcedureHandler

@InterfaceAudience.Private
public class PeerProcedureHandlerImpl
extends Object
implements PeerProcedureHandler

Field Summary

Fields

Modifier and Type	Field and Description
private KeyLocker<String>	peersLock
private ReplicationSourceManager	replicationSourceManager

Constructor Summary

Constructors

Constructor and Description
PeerProcedureHandlerImpl(ReplicationSourceManager replicationSourceManager)

Method Summary

Modifier and Type	Method and Description
void	addPeer(String peerId)
void	claimReplicationQueue(ServerName crashedServer, String queue)
void	disablePeer(String peerId)
void	enablePeer(String peerId)
private void	refreshPeerState(String peerId)
void	removePeer(String peerId)
void	updatePeerConfig(String peerId)

Methods inherited from class java.lang.Object

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

Field Detail

replicationSourceManager

private final ReplicationSourceManager replicationSourceManager

peersLock

private final KeyLocker<String> peersLock

Constructor Detail

PeerProcedureHandlerImpl

public PeerProcedureHandlerImpl(ReplicationSourceManager replicationSourceManager)

Method Detail

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

claimReplicationQueue

public void claimReplicationQueue(ServerName crashedServer,
                                  String queue)
                           throws ReplicationException,
                                  IOException

Specified by:

claimReplicationQueue in interface PeerProcedureHandler

Throws:

ReplicationException

IOException