Package megamek.common.net.connections

Class DataStreamConnection

java.lang.Object

megamek.common.net.connections.AbstractConnection

megamek.common.net.connections.DataStreamConnection

public class DataStreamConnection
extends AbstractConnection

Implementation of the AbstractConnection that uses the DataInputStream and DataOutputStream to send/receive data.

Field Summary

Fields

Modifier and Type	Field	Description
protected int	encoding
protected int	len
protected PacketReadState	state
protected boolean	zipped	store data for packet reception statemachine

Fields inherited from class megamek.common.net.connections.AbstractConnection

marshaller, marshallingType

Constructor Summary

Constructors

Constructor	Description
DataStreamConnection(String host, int port, int id)	Creates new Client connection.
DataStreamConnection(Socket socket, int id)	Creates new server connection.

Method Summary

Modifier and Type	Method	Description
void	flush()	override flush to flush the data stream after flushing packet queue
protected INetworkPacket	readNetworkPacket()	Reads a complete NetworkPacket.
protected void	sendNetworkPacket(byte[] data, boolean isZipped)	Sends the data.
String	toString()

Methods inherited from class megamek.common.net.connections.AbstractConnection

addConnectionListener, close, getBytesReceived, getBytesSent, getConnectionTypeText, getId, getInetAddress, getInputStream, getMarshallingType, getOutputStream, getReceiveBufferSize, getSendBufferSize, hasPending, isClosed, isCompressed, isServer, open, processConnectionEvent, processPacket, processPacket, removeConnectionListener, send, sendNow, setCompression, setId, setMarshallingType, update

Methods inherited from class java.lang.Object

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

Field Details

zipped

protected boolean zipped

store data for packet reception statemachine

encoding

protected int encoding

len

protected int len

state

protected PacketReadState state

Constructor Details

DataStreamConnection

public DataStreamConnection(Socket socket,
 int id)

Creates new server connection.

Parameters:

socket - The network socket to use

id - The connection ID

DataStreamConnection

public DataStreamConnection(String host,
 int port,
 int id)

Creates new Client connection.

Parameters:

host - The host address

port - The network port

id - The connection ID

Method Details

readNetworkPacket

protected INetworkPacket readNetworkPacket()
                                    throws Exception

Description copied from class: AbstractConnection

Reads a complete NetworkPacket. This method must not block, must return null instead.

Specified by:

readNetworkPacket in class AbstractConnection

Returns:

the NetworkPacket that was sent.

Throws:

Exception

sendNetworkPacket

protected void sendNetworkPacket(byte[] data,
 boolean isZipped)
                          throws Exception

Description copied from class: AbstractConnection

Sends the data. This must not be blocked for too long

Specified by:

sendNetworkPacket in class AbstractConnection

Parameters:

data - data to send

isZipped - should the data be compressed

Throws:

Exception - if there's an issue with sending the packet

flush

public void flush()

override flush to flush the data stream after flushing packet queue

Overrides:

flush in class AbstractConnection

toString

public String toString()

Overrides:

toString in class Object