public abstract class PeerSocketHandler extends AbstractTimeoutHandler implements StreamParser
org.bitcoinj.net
classes and Peer
.Modifier and Type | Field and Description |
---|---|
protected PeerAddress |
peerAddress |
protected MessageWriteTarget |
writeTarget |
Constructor and Description |
---|
PeerSocketHandler(NetworkParameters params,
InetSocketAddress remoteIp) |
PeerSocketHandler(NetworkParameters params,
PeerAddress peerAddress) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the connection to the peer if one exists, or immediately closes the connection as soon as it opens
|
PeerAddress |
getAddress() |
int |
getMaxMessageSize()
Returns the maximum message size of a message on the socket.
|
protected abstract void |
processMessage(Message m)
Called every time a message is received from the network
|
int |
receiveBytes(ByteBuffer buff)
Called when new bytes are available from the remote end.
|
void |
sendMessage(Message message)
Sends the given message to the peer.
|
void |
setWriteTarget(MessageWriteTarget writeTarget)
Sets the
MessageWriteTarget used to write messages to the peer. |
protected void |
timeoutOccurred() |
resetTimeout, setSocketTimeout, setTimeoutEnabled
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
connectionClosed, connectionOpened
protected PeerAddress peerAddress
protected MessageWriteTarget writeTarget
public PeerSocketHandler(NetworkParameters params, InetSocketAddress remoteIp)
public PeerSocketHandler(NetworkParameters params, PeerAddress peerAddress)
public void sendMessage(Message message) throws NotYetConnectedException
NotYetConnectedException
public void close()
protected void timeoutOccurred()
timeoutOccurred
in class AbstractTimeoutHandler
protected abstract void processMessage(Message m) throws Exception
Exception
public int receiveBytes(ByteBuffer buff)
StreamParser
Called when new bytes are available from the remote end. This should only ever be called by the single writeTarget associated with any given StreamParser, multiple callers will likely confuse implementations.
Implementers/callers must follow the following conventions exactly:receiveBytes
in interface StreamParser
public void setWriteTarget(MessageWriteTarget writeTarget)
MessageWriteTarget
used to write messages to the peer. This should almost never be called, it is
called automatically by NioClient
or
NioClientManager
once the socket finishes initialization.setWriteTarget
in interface StreamParser
public int getMaxMessageSize()
StreamParser
getMaxMessageSize
in interface StreamParser
public PeerAddress getAddress()
Copyright © 2014. All rights reserved.