Package org.medcare.igtl.network

Class ServerThread

java.lang.Object

java.lang.Thread

org.medcare.igtl.network.ServerThread

All Implemented Interfaces:

Runnable

public class ServerThread
extends Thread

OpenIGTServer create one ServerThread for each client making a connection. ServerThread will add messages received from client to the messageQueue to be treated then MessageQueueManager will use its ServerThread to send answer to messages.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ServerThread.ClientStatus

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

Thread.BuilderPREVIEW, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
ErrorManager	errorManager

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ServerThread(Socket socket, OpenIGTServer openIGTServer)	Default ServerThread constructor.

Method Summary

Modifier and Type	Method	Description
boolean	getAlive()
OpenIGTServer.ServerStatus	getStatus()	** To set server status **
void	interrupt()	Interrupt this thread
void	run()	Reader thread.
final void	sendBytes(byte[] bytes)	Sends bytes
void	sendMessage(OpenIGTMessage message)
void	sendMessage(Header header, byte[] body)
void	setAlive(boolean alive)
void	setStatus(OpenIGTServer.ServerStatus status)	** To set server status

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Details

errorManager

public ErrorManager errorManager

Constructor Details

ServerThread

public ServerThread(Socket socket,
 OpenIGTServer openIGTServer)
             throws Exception

Default ServerThread constructor.

Parameters:

socket - to listen to

Throws:

IOException

Exception

Method Details

run

public void run()

Reader thread. Reads messages from the socket and add them to the MessageQueueManager

Specified by:

run in interface Runnable

Overrides:

run in class Thread

sendMessage

public void sendMessage(OpenIGTMessage message)
                 throws Exception

Throws:

Exception

sendMessage

public void sendMessage(Header header,
 byte[] body)
                 throws Exception

Throws:

Exception

sendBytes

public final void sendBytes(byte[] bytes)
                     throws IOException

Sends bytes

Parameters:

bytes - - byte[] array.

Throws:

IOException - - Exception in I/O.

interrupt

public void interrupt()

Interrupt this thread

Overrides:

interrupt in class Thread

setStatus

public void setStatus(OpenIGTServer.ServerStatus status)

** To set server status

Parameters:

status - **

getStatus

public OpenIGTServer.ServerStatus getStatus()

** To set server status **

Returns:

the status status

getAlive

public boolean getAlive()

setAlive

public void setAlive(boolean alive)