com.highqsoft.corbafileserver.plugin.impl

Class Waitress

java.lang.Object

java.lang.Thread

com.highqsoft.corbafileserver.plugin.impl.Waitress

All Implemented Interfaces:

java.lang.Runnable

public class Waitress
extends java.lang.Thread

A class responsible for handling clients that have just connected to the server.

Author:

user

Nested Class Summary

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

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

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Waitress() Creates a new Waitress.

Method Summary

Methods

Modifier and Type	Method and Description
void	registerWorker(java.lang.Runnable runner, DefaultTransportPluginWorker worker) Adds a worker to the map of workers to be handled in the waiting line.
void	run()
void	sendWorkerStarted(java.lang.Runnable runnable) Takes the given Runnable and looks up the worker associated with it.

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

Constructor Detail

Waitress

public Waitress()

Creates a new Waitress. Sets the thread name and high priority.

Method Detail

registerWorker

public void registerWorker(java.lang.Runnable runner,
                  DefaultTransportPluginWorker worker)

Adds a worker to the map of workers to be handled in the waiting line.

Parameters:

runner - the key to look up the worker, must not be null

worker - the worker to add, must not be null

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

sendWorkerStarted

public void sendWorkerStarted(java.lang.Runnable runnable)
                       throws java.io.IOException

Takes the given Runnable and looks up the worker associated with it. If it knows a worker for that runnable, it will be sent a SERVER_READY signal so that the client of that worker can start with its query.

Parameters:

runnable - the key for finding the worker

Throws:

java.io.IOException - thrown if a communication error occurs