Package org.jgroups.protocols

Class SimpleTCP.Connection

java.lang.Object

org.jgroups.protocols.SimpleTCP.Connection

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

Enclosing class:

SimpleTCP

protected class SimpleTCP.Connection
extends Object
implements Runnable, Closeable

1 connection per peer to send and receive messages

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	buffer
protected final DataInputStream	in
protected final DataOutputStream	out
protected final IpAddress	peer_addr
protected final Runner	runner
protected final Socket	sock
protected final AtomicInteger	writers

Constructor Summary

Constructors

Constructor	Description
Connection(Socket sock)

Method Summary

Modifier and Type	Method	Description
void	close()
protected BufferedInputStream	createBufferedInputStream(InputStream in)
protected BufferedOutputStream	createBufferedOutputStream(OutputStream out)
void	run()
protected void	send(byte[] buffer, int offset, int length)
protected SimpleTCP.Connection	start()
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

sock

protected final Socket sock

peer_addr

protected final IpAddress peer_addr

in

protected final DataInputStream in

out

protected final DataOutputStream out

runner

protected final Runner runner

buffer

protected byte[] buffer

writers

protected final AtomicInteger writers

Constructor Details

Connection

public Connection(Socket sock)
           throws Exception

Throws:

Exception

Method Details

start

protected SimpleTCP.Connection start()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

send

protected void send(byte[] buffer,
 int offset,
 int length)
             throws Exception

Throws:

Exception

run

public void run()

Specified by:

run in interface Runnable

toString

public String toString()

Overrides:

toString in class Object

createBufferedOutputStream

protected BufferedOutputStream createBufferedOutputStream(OutputStream out)

createBufferedInputStream

protected BufferedInputStream createBufferedInputStream(InputStream in)