Collaboration diagram for com.realtime.crossfire.jxclient.server.socket.ClientSocket:

Public Member Functions
void	addClientSocketListener (@NotNull final ClientSocketListener clientSocketListener)

	ClientSocket (@NotNull final GuiStateManager guiStateManager, @Nullable final DebugWriter debugProtocol) throws IOException

void	connect (@NotNull final String host, final int port)

void	disconnect (@NotNull final String reason, final boolean isError)

void	removeClientSocketListener (@NotNull final ClientSocketListener clientSocketListener)

void	start ()

void	stop () throws InterruptedException

void	writePacket (final byte @NotNull[] buf, final int len, @NotNull final ClientSocketMonitorCommand monitor)

Private Member Functions
void	doConnect () throws IOException

void	doReconnect () throws IOException

void	doTransceive () throws IOException

void	process ()

void	processConnect (@NotNull final String host, final int port) throws IOException

void	processDisconnect (@NotNull final String reason, final boolean isError)

void	processRead () throws IOException

void	processReadCommand ()

void	processWrite () throws IOException

void	updateInterestOps ()

void	updateWriteInterestOps ()

Private Attributes
final EventListenerList2< ClientSocketListener >	clientSocketListeners = new EventListenerList2<>()

final DebugWriter	debugProtocol

boolean	disconnectPending

final GuiStateManager	guiStateManager

String	host

final byte[]	inputBuf = new byte[2+MAXIMUM_PACKET_SIZE]

final ByteBuffer	inputBuffer = ByteBuffer.wrap(inputBuf)

int	inputLen = -1

int	interestOps

boolean	isConnected

final ByteBuffer	outputBuffer = ByteBuffer.allocate(2+MAXIMUM_PACKET_SIZE)

final byte[]	packetHeader = new byte[2]

int	port

boolean	reconnect = true

boolean	reconnectIsError

String	reconnectReason = "disconnect"

SelectableChannel	selectableChannel

SelectionKey	selectionKey

final Selector	selector

SocketChannel	socketChannel

final Object	syncConnect = new Object()

final Object	syncOutput = new Object()

final Thread	thread = new Thread(this::process, "JXClient:ClientSocket")

Static Private Attributes
static final int	MAXIMUM_PACKET_SIZE = 65536

Detailed Description

A socket that processes incoming data.

final ClientSocket clientSocket = new ClientSocket(...);
clientSocket.writePacket(...);
clientSocket.disconnect();

Author: Andreas Kirschbaum

Definition at line 55 of file ClientSocket.java.

Constructor & Destructor Documentation

◆ ClientSocket()

com.realtime.crossfire.jxclient.server.socket.ClientSocket.ClientSocket	(	@NotNull final GuiStateManager	guiStateManager,
		@Nullable final DebugWriter	debugProtocol
	)		throws IOException

Creates a new instance.

Parameters

guiStateManager	the gui state manager to update
debugProtocol	tf non- null , write all protocol commands to this writer

Exceptions

IOException if the socket cannot be created

Definition at line 206 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.debugProtocol, com.realtime.crossfire.jxclient.server.socket.ClientSocket.guiStateManager, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.selector.

Member Function Documentation

◆ addClientSocketListener()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.addClientSocketListener ( @NotNull final ClientSocketListener clientSocketListener )

Adds a ClientSocketListener to be notified.

Parameters

clientSocketListener the client socket listener to add

Definition at line 248 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.clientSocketListeners.

Referenced by com.realtime.crossfire.jxclient.server.server.DefaultServerConnection.addClientSocketListener().

Here is the caller graph for this function:

◆ connect()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.connect	(	@NotNull final String	host,
		final int	port
	)

Connects to a server. Disconnects an existing connection if necessary.

Parameters

host	the host to connect to
port	the port to connect to

Definition at line 265 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.server.DefaultServerConnection.connect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ disconnect()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnect	(	@NotNull final String	reason,
		final boolean	isError
	)

Terminates the connection. Does nothing if not connected.

Parameters

reason	the reason for the disconnect
isError	whether the disconnect is unexpected

Definition at line 286 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.server.DefaultServerConnection.disconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.processReadCommand().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ doConnect()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.doConnect ( ) throws IOException

private

Processes pending connect requests.

Exceptions

IOException if an I/O error occurs

Definition at line 335 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.clientSocketListeners, com.realtime.crossfire.jxclient.server.socket.ClientSocket.interestOps, com.realtime.crossfire.jxclient.server.socket.ClientSocket.isConnected, com.realtime.crossfire.jxclient.server.socket.ClientSocket.socketChannel, com.realtime.crossfire.jxclient.server.socket.ClientSocket.syncOutput, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateInterestOps().

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.process().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ doReconnect()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect ( ) throws IOException

private

Processes pending re- or disconnect requests.

Exceptions

IOException if an I/O error occurs

Definition at line 362 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.process().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ doTransceive()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.doTransceive ( ) throws IOException

private

Processes pending data to receive of transmit.

Exceptions

IOException if an I/O error occurs

Definition at line 413 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.isConnected, com.realtime.crossfire.jxclient.server.socket.ClientSocket.process(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processRead(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processWrite(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.selectionKey, com.realtime.crossfire.jxclient.server.socket.ClientSocket.selector, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.syncOutput.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.process().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ process()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.process ( )

private

Reads/writes data from/to the socket. Returns if the thread has been interrupted.

Definition at line 306 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.debugProtocol, com.realtime.crossfire.jxclient.util.DebugWriter.debugProtocolWrite(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.doConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.doTransceive(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.thread, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateWriteInterestOps().

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doTransceive().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ processConnect()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect	(	@NotNull final String	host,
		final int	port
	)		throws IOException

private

Connects the socket. The socket must not be connected.

Parameters

host	the host to connect to
port	the port to connect to

Exceptions

IOException if an I/O error occurs

Definition at line 436 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ processDisconnect()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect	(	@NotNull final String	reason,
		final boolean	isError
	)

private

Disconnects the socket. Does nothing if not currently connected.

Parameters

reason	the reason for disconnection
isError	whether the disconnect is unexpected

Definition at line 486 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.process().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ processRead()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.processRead ( ) throws IOException

private

Reads data from the socket and parses the data into commands.

Exceptions

IOException if an I/O error occurs

Definition at line 541 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.inputBuffer, com.realtime.crossfire.jxclient.server.socket.ClientSocket.processReadCommand(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.socketChannel, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.syncOutput.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doTransceive().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ processReadCommand()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.processReadCommand ( )

private

Parses data from inputBuffer into commands.

Definition at line 559 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.clientSocketListeners, com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.inputBuf, com.realtime.crossfire.jxclient.server.socket.ClientSocket.inputBuffer, com.realtime.crossfire.jxclient.server.socket.ClientSocket.inputLen, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.start().

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.processRead().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ processWrite()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.processWrite ( ) throws IOException

private

Writes some pending data to the socket. Does nothing if no pending data exists or if the socket does not accept data.

Exceptions

IOException if an I/O error occurs

Definition at line 634 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.outputBuffer, com.realtime.crossfire.jxclient.server.socket.ClientSocket.socketChannel, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.syncOutput.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doTransceive().

Here is the caller graph for this function:

◆ removeClientSocketListener()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.removeClientSocketListener ( @NotNull final ClientSocketListener clientSocketListener )

Removes a ClientSocketListener to be notified.

Parameters

clientSocketListener the client socket listener to remove

Definition at line 256 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.clientSocketListeners.

Referenced by com.realtime.crossfire.jxclient.server.server.DefaultServerConnection.removeClientSocketListener().

Here is the caller graph for this function:

◆ start()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.start ( )

Starts operation.

Definition at line 215 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.debugProtocol, com.realtime.crossfire.jxclient.util.DebugWriter.debugProtocolWrite(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.thread.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.processReadCommand(), and com.realtime.crossfire.jxclient.server.server.DefaultServerConnection.start().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ stop()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.stop ( ) throws InterruptedException

Stops operation.

Exceptions

InterruptedException if stopping was interrupted

Definition at line 226 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.debugProtocol, com.realtime.crossfire.jxclient.util.DebugWriter.debugProtocolWrite(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.selector, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.thread.

Referenced by com.realtime.crossfire.jxclient.server.server.DefaultServerConnection.stop().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ updateInterestOps()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateInterestOps ( )

private

Updates selectionKey's interest ops to match interestOps. Does nothing if

selectionKey

is

null

.

Definition at line 678 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.debugProtocol, com.realtime.crossfire.jxclient.util.DebugWriter.debugProtocolWrite(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.interestOps, com.realtime.crossfire.jxclient.server.socket.ClientSocket.selectionKey, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.syncOutput.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doConnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateWriteInterestOps().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ updateWriteInterestOps()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateWriteInterestOps ( )

private

Updates interestOps's OP_WRITE according to whether outputBuffer has pending data.

Definition at line 657 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.interestOps, com.realtime.crossfire.jxclient.server.socket.ClientSocket.outputBuffer, com.realtime.crossfire.jxclient.server.socket.ClientSocket.syncOutput, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateInterestOps().

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.process().

Here is the call graph for this function:

Here is the caller graph for this function:

◆ writePacket()

void com.realtime.crossfire.jxclient.server.socket.ClientSocket.writePacket	(	final byte @NotNull[]	buf,
		final int	len,
		@NotNull final ClientSocketMonitorCommand	monitor
	)

Writes a packet. The packet contents must not change until this function has returned.

This function may be called even if the socket has been closed. In this case he packet is discarded.

Parameters

buf	the packet to send
len	the number of bytes to send
monitor	the monitor command to send to script processes

Definition at line 598 of file ClientSocket.java.

References com.realtime.crossfire.jxclient.server.socket.ClientSocket.clientSocketListeners, com.realtime.crossfire.jxclient.server.socket.ClientSocket.outputBuffer, com.realtime.crossfire.jxclient.server.socket.ClientSocket.packetHeader, com.realtime.crossfire.jxclient.server.socket.ClientSocket.selector, com.realtime.crossfire.jxclient.server.socket.ClientSocket.socketChannel, and com.realtime.crossfire.jxclient.server.socket.ClientSocket.syncOutput.

Referenced by com.realtime.crossfire.jxclient.server.server.DefaultServerConnection.writePacket().

Here is the caller graph for this function:

Member Data Documentation

◆ clientSocketListeners

final EventListenerList2<ClientSocketListener> com.realtime.crossfire.jxclient.server.socket.ClientSocket.clientSocketListeners = new EventListenerList2<>()

private

The ClientSocketListeners to notify.

Definition at line 79 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.addClientSocketListener(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.doConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processReadCommand(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.removeClientSocketListener(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.writePacket().

◆ debugProtocol

final DebugWriter com.realtime.crossfire.jxclient.server.socket.ClientSocket.debugProtocol

private

The appender to write state changes to. May be

null

to not write anything.

Definition at line 73 of file ClientSocket.java.

◆ disconnectPending

boolean com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnectPending

private

If set, notify listeners.

Definition at line 125 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect().

◆ guiStateManager

final GuiStateManager com.realtime.crossfire.jxclient.server.socket.ClientSocket.guiStateManager

private

The GuiStateManager instance that is updated.

Definition at line 66 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.ClientSocket(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect().

◆ host

String com.realtime.crossfire.jxclient.server.socket.ClientSocket.host

private

The host to connect to. Set to

null

for disconnect.

Definition at line 115 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.connect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect().

◆ inputBuf

final byte [] com.realtime.crossfire.jxclient.server.socket.ClientSocket.inputBuf = new byte[2+MAXIMUM_PACKET_SIZE]

private

The receive buffer. It is wrapped into inputBuffer.

Definition at line 153 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.processReadCommand().

◆ inputBuffer

final ByteBuffer com.realtime.crossfire.jxclient.server.socket.ClientSocket.inputBuffer = ByteBuffer.wrap(inputBuf)

private

The receive buffer. Contains data pending to be processed.

Definition at line 159 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processRead(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.processReadCommand().

◆ inputLen

int com.realtime.crossfire.jxclient.server.socket.ClientSocket.inputLen = -1

private

If set to

-1

, a two-byte packet header is read next from inputBuffer. Otherwise, it is set to the packet length which will be read from inputBuffer.

Definition at line 166 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.processReadCommand().

◆ interestOps

int com.realtime.crossfire.jxclient.server.socket.ClientSocket.interestOps

private

The currently set interest ops for selectionKey.

Definition at line 148 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateInterestOps(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateWriteInterestOps().

◆ isConnected

boolean com.realtime.crossfire.jxclient.server.socket.ClientSocket.isConnected

private

Whether socketChannel is connected.

Definition at line 191 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.doTransceive(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect().

◆ MAXIMUM_PACKET_SIZE

final int com.realtime.crossfire.jxclient.server.socket.ClientSocket.MAXIMUM_PACKET_SIZE = 65536

staticprivate

The maximum payload size of a Crossfire protocol packet.

Definition at line 60 of file ClientSocket.java.

◆ outputBuffer

final ByteBuffer com.realtime.crossfire.jxclient.server.socket.ClientSocket.outputBuffer = ByteBuffer.allocate(2+MAXIMUM_PACKET_SIZE)

private

The output buffer. Contains data pending to send.

Definition at line 179 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processWrite(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateWriteInterestOps(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.writePacket().

◆ packetHeader

final byte [] com.realtime.crossfire.jxclient.server.socket.ClientSocket.packetHeader = new byte[2]

private

A buffer for sending packets.

Definition at line 130 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.writePacket().

◆ port

int com.realtime.crossfire.jxclient.server.socket.ClientSocket.port

private

The port to connect to.

Definition at line 120 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.connect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect().

◆ reconnect

boolean com.realtime.crossfire.jxclient.server.socket.ClientSocket.reconnect = true

private

Set if host or port has changed and thus a reconnect is needed.

Definition at line 98 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.connect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect().

◆ reconnectIsError

boolean com.realtime.crossfire.jxclient.server.socket.ClientSocket.reconnectIsError

private

Only valid if reconnect is set.

Definition at line 109 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.connect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect().

◆ reconnectReason

String com.realtime.crossfire.jxclient.server.socket.ClientSocket.reconnectReason = "disconnect"

private

Only valid if reconnect is set.

Definition at line 104 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.connect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect().

◆ selectableChannel

SelectableChannel com.realtime.crossfire.jxclient.server.socket.ClientSocket.selectableChannel

private

The SelectableChannel of socketChannel.

Definition at line 136 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect().

◆ selectionKey

SelectionKey com.realtime.crossfire.jxclient.server.socket.ClientSocket.selectionKey

private

The SelectionKey registered to selectableChannel. It's interesting ops are interestOps.

Definition at line 143 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doTransceive(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.updateInterestOps().

◆ selector

final Selector com.realtime.crossfire.jxclient.server.socket.ClientSocket.selector

private

The Selector used for waiting.

Definition at line 85 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.ClientSocket(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.connect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.doTransceive(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.stop(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.writePacket().

◆ socketChannel

SocketChannel com.realtime.crossfire.jxclient.server.socket.ClientSocket.socketChannel

private

The SocketChannel when connected. Set to

null

when not connected.

Definition at line 186 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processRead(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processWrite(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.writePacket().

◆ syncConnect

final Object com.realtime.crossfire.jxclient.server.socket.ClientSocket.syncConnect = new Object()

private

Synchronization object for reconnect, host, port, and disconnectPending.

Definition at line 92 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.connect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.disconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect().

◆ syncOutput

final Object com.realtime.crossfire.jxclient.server.socket.ClientSocket.syncOutput = new Object()

private

Synchronization object for outputBuffer, selectionKey, interestOps, and socketChannel.

Definition at line 173 of file ClientSocket.java.

◆ thread

final Thread com.realtime.crossfire.jxclient.server.socket.ClientSocket.thread = new Thread(this::process, "JXClient:ClientSocket")

private

The Thread used to operate the socket.

Definition at line 197 of file ClientSocket.java.

Referenced by com.realtime.crossfire.jxclient.server.socket.ClientSocket.doReconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.process(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processConnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.processDisconnect(), com.realtime.crossfire.jxclient.server.socket.ClientSocket.start(), and com.realtime.crossfire.jxclient.server.socket.ClientSocket.stop().

The documentation for this class was generated from the following file:

src/network/src/main/java/com/realtime/crossfire/jxclient/server/socket/ClientSocket.java

Public Member Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ ClientSocket()

Member Function Documentation

◆ addClientSocketListener()

◆ connect()

◆ disconnect()

◆ doConnect()

◆ doReconnect()

◆ doTransceive()

◆ process()

◆ processConnect()

◆ processDisconnect()

◆ processRead()

◆ processReadCommand()

◆ processWrite()

◆ removeClientSocketListener()

◆ start()

◆ stop()

◆ updateInterestOps()

◆ updateWriteInterestOps()

◆ writePacket()

Member Data Documentation

◆ clientSocketListeners

◆ debugProtocol

◆ disconnectPending

◆ guiStateManager

◆ host

◆ inputBuf

◆ inputBuffer

◆ inputLen

◆ interestOps

◆ isConnected

◆ MAXIMUM_PACKET_SIZE

◆ outputBuffer

◆ packetHeader

◆ port

◆ reconnect

◆ reconnectIsError

◆ reconnectReason

◆ selectableChannel

◆ selectionKey

◆ selector

◆ socketChannel

◆ syncConnect

◆ syncOutput

◆ thread