Package io.deephaven.enterprise.comm.protocol.tcp

Class TCPConnectionImpl

java.lang.Object

io.deephaven.enterprise.niowrapper.sched.NullIOHandler

io.deephaven.enterprise.comm.protocol.tcp.TCPConnectionImpl

All Implemented Interfaces:

com.fishlib.base.log.LogOutputAppendable, TCPConnection, ConnectorWrapper.Listener, IOHandler

public class TCPConnectionImpl
extends NullIOHandler
implements TCPConnection, ConnectorWrapper.Listener

Created by IntelliJ IDEA. User: rfang Date: Jan 7, 2009 Time: 1:56:58 PM To change this template use File | Settings | File Templates.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TCPConnectionImpl.Factory

Nested classes/interfaces inherited from interface io.deephaven.enterprise.comm.protocol.tcp.TCPConnection

TCPConnection.Listener, TCPConnection.Null, TCPConnection.Parameters

Field Summary

Fields inherited from interface io.deephaven.enterprise.comm.protocol.tcp.TCPConnection

NULL

Constructor Summary

Constructors

Constructor	Description
TCPConnectionImpl(TCPConnection.Parameters params, ProtocolHandler handler, TCPConnection.Listener listener, NIODataRecorder recorder, com.fishlib.io.logger.Logger log)

Method Summary

Modifier and Type	Method	Description
com.fishlib.base.log.LogOutput	append(com.fishlib.base.log.LogOutput logOutput)
void	attach(Object attachment)
void	connect(String host, int port)
void	connect(InetSocketAddress address)
void	connecting()
boolean	connectionDisconnected(IOException e)
void	connectionFailed(IOException e)
void	connectionSucceeded()
void	disconnect()
Object	getAttachment()
boolean	handleIncoming(IOJob job)	Handle input from an IOJob.
void	send(Message message)
void	send(Message[] messages, int numMessages)
void	send(ByteBuffer buf)
void	startJob(IOJob job)

Methods inherited from class io.deephaven.enterprise.niowrapper.sched.NullIOHandler

endJob, handleEOF, handleError, handleOutgoing, handleTimeout

Methods inherited from class java.lang.Object

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

Constructor Details

TCPConnectionImpl

public TCPConnectionImpl(TCPConnection.Parameters params,
 ProtocolHandler handler,
 TCPConnection.Listener listener,
 NIODataRecorder recorder,
 com.fishlib.io.logger.Logger log)

Method Details

connect

public void connect(String host,
 int port)
             throws IOException

Specified by:

connect in interface TCPConnection

Throws:

IOException

connect

public void connect(InetSocketAddress address)
             throws IOException

Specified by:

connect in interface TCPConnection

Throws:

IOException

disconnect

public void disconnect()

Specified by:

disconnect in interface TCPConnection

send

public void send(ByteBuffer buf)
          throws IOException

Specified by:

send in interface TCPConnection

Throws:

IOException

send

public void send(Message message)
          throws IOException

Specified by:

send in interface TCPConnection

Throws:

IOException

send

public void send(Message[] messages,
 int numMessages)
          throws IOException

Specified by:

send in interface TCPConnection

Throws:

IOException

attach

public void attach(Object attachment)

Specified by:

attach in interface TCPConnection

getAttachment

public Object getAttachment()

Specified by:

getAttachment in interface TCPConnection

startJob

public void startJob(IOJob job)

Specified by:

startJob in interface IOHandler

Overrides:

startJob in class NullIOHandler

handleIncoming

public boolean handleIncoming(IOJob job)

Description copied from interface: IOHandler

Handle input from an IOJob. This method will be called again if it returns true, and it must do so if the handler does not consume all the data (or it might never be called to finish processing the buffer).

Specified by:

handleIncoming in interface IOHandler

Overrides:

handleIncoming in class NullIOHandler

Parameters:

job - the IOJob containing the input data

Returns:

true if there is or might be enough data to process another message, false if the buffer is empty or there was an error

connectionFailed

public void connectionFailed(IOException e)

Specified by:

connectionFailed in interface ConnectorWrapper.Listener

connectionDisconnected

public boolean connectionDisconnected(IOException e)

Specified by:

connectionDisconnected in interface ConnectorWrapper.Listener

connectionSucceeded

public void connectionSucceeded()

Specified by:

connectionSucceeded in interface ConnectorWrapper.Listener

connecting

public void connecting()

Specified by:

connecting in interface ConnectorWrapper.Listener

append

public com.fishlib.base.log.LogOutput append(com.fishlib.base.log.LogOutput logOutput)

Specified by:

append in interface com.fishlib.base.log.LogOutputAppendable