dev.roanh.convexmerger.net

Class InternalServer.ServerThread

java.lang.Object

java.lang.Thread

dev.roanh.convexmerger.net.InternalServer.ServerThread

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

InternalServer

private class InternalServer.ServerThread
extends java.lang.Thread

Main thread managing all connections and initially responsible for accepting joining players.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Map<java.lang.Integer,Connection>	connections Map of active connections indexed by player ID.
private java.util.concurrent.ExecutorService	executor Executor service used to handle incoming connections.
private int	nextID The ID to assign to the next valid player.
private boolean	running Whether the server is running and accepting new connections.
private java.net.ServerSocket	server Main server socket.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Modifier	Constructor and Description
private	ServerThread() Constructs a new server thread.

Method Summary

Modifier and Type	Method and Description
private void	broadCast(Packet packet) Broadcasts a packet to all connected players.
private void	broadCast(Player source, Packet packet) Broadcasts a packet to all connected players except for the given source player.
private void	close() Closes all connections held by this server thread.
private void	handleClient(java.net.Socket socket) Handles an incoming client connection.
void	run()
private void	shutdown() Shuts down the part of this server responsible for accepting incoming players.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

executor

private java.util.concurrent.ExecutorService executor

Executor service used to handle incoming connections.

server

private java.net.ServerSocket server

Main server socket.

connections

private java.util.Map<java.lang.Integer,Connection> connections

Map of active connections indexed by player ID.

running

private volatile boolean running

Whether the server is running and accepting new connections.

nextID

private volatile int nextID

The ID to assign to the next valid player. ID 1 is reseved for the player hosting the game.

Constructor Detail

ServerThread

private ServerThread()

Constructs a new server thread.

Method Detail

close

private void close()

Closes all connections held by this server thread.

broadCast

private void broadCast(Player source,
                       Packet packet)

Broadcasts a packet to all connected players except for the given source player.

Parameters:

source - The player to exclude.

packet - The packet to send.

broadCast

private void broadCast(Packet packet)

Broadcasts a packet to all connected players.

Parameters:

packet - The packet to send.

shutdown

private void shutdown()

Shuts down the part of this server responsible for accepting incoming players. Connected players will still remain connected.

handleClient

private void handleClient(java.net.Socket socket)

Handles an incoming client connection.

Parameters:

socket - The client socket.

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread