bt.net

Class SocketPeerConnection

java.lang.Object

bt.net.SocketPeerConnection

All Implemented Interfaces:

PeerConnection, Closeable, AutoCloseable

public class SocketPeerConnection
extends Object
implements PeerConnection

Since:

1.0

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeQuietly() Close the connection without throwing an IOException.
long	getLastActive()
Peer	getRemotePeer()
int	getRemotePort()
TorrentId	getTorrentId()
boolean	isClosed()
void	postMessage(Message message) Send a message to remote peer.
Message	readMessage(long timeout) Attempt to read an incoming message within a specified time interval.
Message	readMessageNow() Attempt to read an incoming message.
TorrentId	setTorrentId(TorrentId torrentId) Associate this connection with the given torrent ID.
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

setTorrentId

public TorrentId setTorrentId(TorrentId torrentId)

Description copied from interface: PeerConnection

Associate this connection with the given torrent ID.

Specified by:

setTorrentId in interface PeerConnection

Parameters:

torrentId - Torrent ID to associate this connection with

Returns:

Torrent ID, that this connection was previously associated with, or null

Since:

1.0

getTorrentId

public TorrentId getTorrentId()

Specified by:

getTorrentId in interface PeerConnection

Returns:

Torrent ID, that this connection is associated with, or null

readMessageNow

public Message readMessageNow()
                       throws IOException

Description copied from interface: PeerConnection

Attempt to read an incoming message. Note that implementation may buffer all received data and try to read next message from the buffer, so calling this method does not necessarily imply I/O access.

Specified by:

readMessageNow in interface PeerConnection

Returns:

Message, or null if there isn't any

Throws:

IOException

readMessage

public Message readMessage(long timeout)
                    throws IOException

Description copied from interface: PeerConnection

Attempt to read an incoming message within a specified time interval. Invocation blocks the calling thread until either a message is read or the limit of waiting time is reached. Note that implementation may buffer all received data and try to read next message from the buffer, so calling this method does not necessarily imply I/O access.

Specified by:

readMessage in interface PeerConnection

Returns:

Message, or null if there isn't any

Throws:

IOException

postMessage

public void postMessage(Message message)

Description copied from interface: PeerConnection

Send a message to remote peer.

Specified by:

postMessage in interface PeerConnection

getRemotePeer

public Peer getRemotePeer()

Specified by:

getRemotePeer in interface PeerConnection

Returns:

Remote peer

getRemotePort

public int getRemotePort()

Specified by:

getRemotePort in interface PeerConnection

closeQuietly

public void closeQuietly()

Description copied from interface: PeerConnection

Close the connection without throwing an IOException.

Specified by:

closeQuietly in interface PeerConnection

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException

isClosed

public boolean isClosed()

Specified by:

isClosed in interface PeerConnection

Returns:

true if connection is closed

getLastActive

public long getLastActive()

Specified by:

getLastActive in interface PeerConnection

Returns:

Last time a message was received or sent via this connection

toString

public String toString()

Overrides:

toString in class Object