Modifier and Type | Field and Description |
---|---|
protected java.io.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 java.net.Socket |
sock |
Constructor and Description |
---|
Learner() |
Modifier and Type | Method and Description |
---|---|
protected void |
connectToLeader(java.net.InetSocketAddress addr)
Establish a connection with the Leader found by findLeader.
|
protected java.net.InetSocketAddress |
findLeader()
Returns the address of the node we think is the leader.
|
int |
getPendingRevalidationsCount() |
java.net.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 java.io.BufferedOutputStream bufferedOutput
protected java.net.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 java.net.Socket getSocket()
public int getPendingRevalidationsCount()
protected java.net.InetSocketAddress findLeader()
protected void connectToLeader(java.net.InetSocketAddress addr) throws java.io.IOException, java.net.ConnectException, java.lang.InterruptedException
addr
- - the address of the Leader to connect to.java.io.IOException
- - if the socket connection fails on the 5th attemptjava.net.ConnectException
java.lang.InterruptedException
protected long registerWithLeader(int pktType) throws java.io.IOException
pktType
- java.io.IOException
protected void syncWithLeader(long newLeaderZxid) throws java.io.IOException, java.lang.InterruptedException
newLeaderZxid
- java.io.IOException
java.lang.InterruptedException
protected void revalidate(QuorumPacket qp) throws java.io.IOException
java.io.IOException
protected void ping(QuorumPacket qp) throws java.io.IOException
java.io.IOException
public void shutdown()
Copyright © 2019 The Apache Software Foundation