org.jgroups.protocols

Class SimpleTCP.Connection

java.lang.Object

org.jgroups.protocols.SimpleTCP.Connection

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Runnable

Enclosing class:

SimpleTCP

protected class SimpleTCP.Connection
extends java.lang.Object
implements java.lang.Runnable, java.io.Closeable

1 connection per peer to send and receive messages

Field Summary

Fields

Modifier and Type	Field and Description
protected byte[]	buffer
protected java.io.DataInputStream	in
protected java.io.DataOutputStream	out
protected IpAddress	peer_addr
protected Runner	runner
protected java.net.Socket	sock
protected java.util.concurrent.atomic.AtomicInteger	writers

Constructor Summary

Constructors

Constructor and Description
Connection(java.net.Socket sock)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

sock

protected final java.net.Socket sock

peer_addr

protected final IpAddress peer_addr

in

protected final java.io.DataInputStream in

out

protected final java.io.DataOutputStream out

runner

protected final Runner runner

buffer

protected byte[] buffer

writers

protected final java.util.concurrent.atomic.AtomicInteger writers

Constructor Detail

Connection

public Connection(java.net.Socket sock)
           throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

start

protected SimpleTCP.Connection start()

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

send

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

Throws:

java.lang.Exception

run

public void run()

Specified by:

run in interface java.lang.Runnable

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

createBufferedOutputStream

protected java.io.BufferedOutputStream createBufferedOutputStream(java.io.OutputStream out)

createBufferedInputStream

protected java.io.BufferedInputStream createBufferedInputStream(java.io.InputStream in)