Class TcpTransport

java.lang.Object

com.trdp.network.TcpTransport

All Implemented Interfaces:

AutoCloseable

public class TcpTransport
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
TcpTransport(String host, int port)
TcpTransport(String host, int port, InetAddress bindAddress, int trafficClass)	Creates a TCP transport with custom socket options.

Method Summary

Modifier and Type	Method	Description
void	close()
InputStream	getInputStream()
boolean	isClosed()
int	receive(byte[] buffer, int timeoutMs)	Reads a complete TRDP MD frame from the TCP stream.
void	send(byte[] data)
void	setSoTimeout(int timeoutMs)

Methods inherited from class Object

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

Constructor Details

TcpTransport

public TcpTransport(String host,
 int port)
             throws IOException

Throws:

IOException

TcpTransport

public TcpTransport(String host,
 int port,
 InetAddress bindAddress,
 int trafficClass)
             throws IOException

Creates a TCP transport with custom socket options.

Parameters:

host - the remote host to connect to

port - the remote port to connect to

bindAddress - the local address to bind to, or null for any local address

trafficClass - the IP traffic class byte (use UdpTransport.qosToTrafficClass(int) to convert from QoS), or 0 to leave at OS default

Throws:

IOException - if connection fails

Method Details

send

public void send(byte[] data)
          throws IOException

Throws:

IOException

receive

public int receive(byte[] buffer,
 int timeoutMs)
            throws IOException

Reads a complete TRDP MD frame from the TCP stream. Reads the fixed-size MD header first to determine payload length, then reads the exact payload.

Parameters:

buffer - Buffer to receive the frame (must be at least TrdpConstants.TRDP_MD_HEADER_SIZE + TrdpConstants.TRDP_MAX_MD_DATA_SIZE bytes).

timeoutMs - Socket timeout in milliseconds.

Returns:

Total bytes read (header + payload), 0 on timeout, -1 on EOF.

Throws:

IOException

getInputStream

public InputStream getInputStream()
                           throws IOException

Throws:

IOException

setSoTimeout

public void setSoTimeout(int timeoutMs)
                  throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

isClosed

public boolean isClosed()