Modifier and Type | Field and Description |
---|---|
protected BufferedOutputStream |
bufferedOutput |
protected org.apache.jute.InputArchive |
leaderIs |
protected org.apache.jute.OutputArchive |
leaderOs |
protected int |
leaderProtocolVersion
the protocol version of the leader
|
protected static org.slf4j.Logger |
LOG |
protected Socket |
sock |
Constructor and Description |
---|
Learner() |
Modifier and Type | Method and Description |
---|---|
protected void |
connectToLeader(InetSocketAddress addr)
Establish a connection with the Leader found by findLeader.
|
protected InetSocketAddress |
findLeader()
Returns the address of the node we think is the leader.
|
int |
getPendingRevalidationsCount() |
Socket |
getSocket()
Socket getter
|
protected void |
ping(QuorumPacket qp) |
protected long |
registerWithLeader(int pktType)
Once connected to the leader, perform the handshake protocol to
establish a following / observing connection.
|
protected void |
revalidate(QuorumPacket qp) |
void |
shutdown()
Shutdown the Peer
|
protected void |
syncWithLeader(long newLeaderZxid)
Finally, synchronize our history with the Leader.
|
protected BufferedOutputStream bufferedOutput
protected Socket sock
protected org.apache.jute.InputArchive leaderIs
protected org.apache.jute.OutputArchive leaderOs
protected int leaderProtocolVersion
protected static final org.slf4j.Logger LOG
public Socket getSocket()
public int getPendingRevalidationsCount()
protected InetSocketAddress findLeader()
protected void connectToLeader(InetSocketAddress addr) throws IOException, ConnectException, InterruptedException
addr
- - the address of the Leader to connect to.IOException
- - if the socket connection fails on the 5th attemptConnectException
InterruptedException
protected long registerWithLeader(int pktType) throws IOException
pktType
- IOException
protected void syncWithLeader(long newLeaderZxid) throws IOException, InterruptedException
newLeaderZxid
- IOException
InterruptedException
protected void revalidate(QuorumPacket qp) throws IOException
IOException
protected void ping(QuorumPacket qp) throws IOException
IOException
public void shutdown()
Copyright © 2014 The Apache Software Foundation