Crossfire JXClient, Trunk
Public Member Functions | Private Member Functions | Static Private Member Functions | Private Attributes | List of all members
com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer Class Reference
Collaboration diagram for com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer:
Collaboration graph

Public Member Functions

int getLocalPort ()
 
void start ()
 
void stop () throws InterruptedException, IOException
 
 TestCrossfireServer () throws IOException
 
void waitForCharacterLogin () throws InterruptedException
 
void writeBytes (final byte @NotNull[] b) throws IOException
 
void writeString (@NotNull final String s) throws IOException
 

Private Member Functions

OutputStream getOutputStream ()
 
void processAddme () throws IOException
 
void processRequestinfo (@NotNull final String params) throws IOException
 
void processSetup (@NotNull final String params) throws IOException
 
void run ()
 

Static Private Member Functions

static Socket acceptClient (@NotNull final ServerSocket server)
 
static InputStream getInputStream (@NotNull final Socket socket)
 
static int readByte (@NotNull final InputStream in) throws EOFException
 
static byte[] readPacket (@NotNull final InputStream in) throws EOFException
 

Private Attributes

final Charset charset = StandardCharsets.ISO_8859_1
 
Socket client
 
final Semaphore sem = new Semaphore(0)
 
final ServerSocket server = new ServerSocket(0)
 
final Object sync = new Object()
 
final Thread thread = new Thread(this::run)
 

Detailed Description

A dummy Crossfire server for tests.

Definition at line 20 of file TestCrossfireServer.java.

Constructor & Destructor Documentation

◆ TestCrossfireServer()

com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.TestCrossfireServer ( ) throws IOException

Starts a dummy Crossfire server.

Exceptions
IOExceptionif an I/O error occurs

Definition at line 63 of file TestCrossfireServer.java.

Member Function Documentation

◆ acceptClient()

static Socket com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.acceptClient ( @NotNull final ServerSocket  server)
staticprivate

Accepts a single client from a ServerSocket.

Parameters
serverthe server socket
Returns
the client

Definition at line 339 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.client, and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.server.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run().

Here is the caller graph for this function:

◆ getInputStream()

static InputStream com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.getInputStream ( @NotNull final Socket  socket)
staticprivate

Returns the InputStream of a Socket.

Parameters
socketthe socket
Returns
the input stream

Definition at line 357 of file TestCrossfireServer.java.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run().

Here is the caller graph for this function:

◆ getLocalPort()

int com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.getLocalPort ( )

Returns the port the server is listening on.

Returns
the port

Definition at line 93 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.server.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.scriptCallback_drawextinfoMessage_includesSubtypeParameter(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_mapUpdates_suppressInitialMapScroll(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_statsMessage_callsPacketWatcherCallback(), and com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.testNegotiateNumLookObjects1().

Here is the caller graph for this function:

◆ getOutputStream()

OutputStream com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.getOutputStream ( )
private

Returns the OutputStream of a Socket.

Returns
the input stream

Definition at line 373 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.client, and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.sync.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeBytes().

Here is the caller graph for this function:

◆ processAddme()

void com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processAddme ( ) throws IOException
private

Processes an "addme" message.

Exceptions
IOExceptionif an I/O error occurs

Definition at line 275 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.sem, and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeString().

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ processRequestinfo()

void com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processRequestinfo ( @NotNull final String  params) throws IOException
private

Processes a "requestinfo" message.

Parameters
paramsthe message's parameters
Exceptions
IOExceptionif an I/O error occurs

Definition at line 227 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeBytes().

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ processSetup()

void com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processSetup ( @NotNull final String  params) throws IOException
private

Processes a "setup" message.

Parameters
paramsthe message's parameters
Exceptions
IOExceptionif an I/O error occurs

Definition at line 206 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeString().

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ readByte()

static int com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.readByte ( @NotNull final InputStream  in) throws EOFException
staticprivate

Reads a single byte from the client.

Parameters
inthe input stream to read from
Returns
the byte
Exceptions
EOFExceptionif an I/O error occurs

Definition at line 288 of file TestCrossfireServer.java.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.readPacket().

Here is the caller graph for this function:

◆ readPacket()

static byte [] com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.readPacket ( @NotNull final InputStream  in) throws EOFException
staticprivate

Reads a Crossfire message from an InputStream.

Parameters
inthe input stream
Returns
the message
Exceptions
EOFExceptionif the socket has been closed unexpectedly

Definition at line 176 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.readByte().

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ run()

void com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run ( )
private

Processes data bytes received from the socket.

Definition at line 108 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.acceptClient(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.charset, com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.client, com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.getInputStream(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processAddme(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processRequestinfo(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processSetup(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.readPacket(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.server, com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.sync, and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeString().

Here is the call graph for this function:

◆ start()

void com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.start ( )

Starts the server.

Definition at line 69 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.thread.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.scriptCallback_drawextinfoMessage_includesSubtypeParameter(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_mapUpdates_suppressInitialMapScroll(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_statsMessage_callsPacketWatcherCallback(), and com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.testNegotiateNumLookObjects1().

Here is the caller graph for this function:

◆ stop()

void com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.stop ( ) throws InterruptedException, IOException

Stops the server.

Exceptions
InterruptedExceptionif the current thread was interrupted
IOExceptionif closing a socket fails

Definition at line 78 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.client, com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.server, com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.sync, and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.thread.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.scriptCallback_drawextinfoMessage_includesSubtypeParameter(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_mapUpdates_suppressInitialMapScroll(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_statsMessage_callsPacketWatcherCallback(), and com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.testNegotiateNumLookObjects1().

Here is the caller graph for this function:

◆ waitForCharacterLogin()

void com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.waitForCharacterLogin ( ) throws InterruptedException

Blocks until the character login has finished.

Exceptions
InterruptedExceptionif the current thread was interrupted

Definition at line 101 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.sem.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.scriptCallback_drawextinfoMessage_includesSubtypeParameter(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_mapUpdates_suppressInitialMapScroll(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_statsMessage_callsPacketWatcherCallback(), and com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.testNegotiateNumLookObjects1().

Here is the caller graph for this function:

◆ writeBytes()

void com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeBytes ( final byte @NotNull[]  b) throws IOException

Write a Crossfire message to the client.

Parameters
bthe message's payload
Exceptions
IOExceptionif an I/O error occurs

Definition at line 325 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.getOutputStream().

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processRequestinfo(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_mapUpdates_suppressInitialMapScroll(), com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.test_statsMessage_callsPacketWatcherCallback(), and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeString().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ writeString()

void com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeString ( @NotNull final String  s) throws IOException

Write a Crossfire message to the client.

Parameters
sthe message's payload
Exceptions
IOExceptionif an I/O error occurs

Definition at line 316 of file TestCrossfireServer.java.

References com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.charset, and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeBytes().

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processAddme(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processSetup(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run(), and com.realtime.crossfire.jxclient.server.crossfire.DefaultCrossfireServerConnectionTest.scriptCallback_drawextinfoMessage_includesSubtypeParameter().

Here is the call graph for this function:
Here is the caller graph for this function:

Member Data Documentation

◆ charset

final Charset com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.charset = StandardCharsets.ISO_8859_1
private

The Charset for converting bytes to characters.

Definition at line 26 of file TestCrossfireServer.java.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run(), and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.writeString().

◆ client

Socket com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.client
private

The client socket. Set to

null

if not open.

Definition at line 57 of file TestCrossfireServer.java.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.acceptClient(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.getOutputStream(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run(), and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.stop().

◆ sem

final Semaphore com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.sem = new Semaphore(0)
private

The Semaphore for waiting until character login.

Definition at line 32 of file TestCrossfireServer.java.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.processAddme(), and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.waitForCharacterLogin().

◆ server

final ServerSocket com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.server = new ServerSocket(0)
private

The server socket.

Definition at line 39 of file TestCrossfireServer.java.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.acceptClient(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.getLocalPort(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run(), and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.stop().

◆ sync

final Object com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.sync = new Object()
private

The synchronization object for accesses to client.

Definition at line 51 of file TestCrossfireServer.java.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.getOutputStream(), com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.run(), and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.stop().

◆ thread

final Thread com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.thread = new Thread(this::run)
private

The worker thread for processing data received from the socket.

Definition at line 45 of file TestCrossfireServer.java.

Referenced by com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.start(), and com.realtime.crossfire.jxclient.server.crossfire.TestCrossfireServer.stop().

The documentation for this class was generated from the following file:
Generated by   doxygen 1.8.17