voldemort.server.socket
Class SocketServer

java.lang.Object
  java.lang.Thread
      voldemort.server.socket.SocketServer

All Implemented Interfaces:

java.lang.Runnable

public class SocketServer
extends java.lang.Thread

A simple socket-based server for serving voldemort requests

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

SocketServer(int port, int defaultThreads, int maxThreads, int socketBufferSize, RequestHandlerFactory handlerFactory, java.lang.String serverName)

Method Summary

void	awaitStartupCompletion() Blocks until the server has started successfully or an exception is thrown.
int	getCurrentThreads()
int	getMaxThreads()
int	getPort()
int	getRemainingThreads()
StatusManager	getStatusManager()
void	killActiveSessions()
void	run()
void	shutdown()

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

SocketServer

public SocketServer(int port,
                    int defaultThreads,
                    int maxThreads,
                    int socketBufferSize,
                    RequestHandlerFactory handlerFactory,
                    java.lang.String serverName)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

shutdown

public void shutdown()

killActiveSessions

public void killActiveSessions()

getPort

public int getPort()

getMaxThreads

public int getMaxThreads()

getCurrentThreads

public int getCurrentThreads()

getRemainingThreads

public int getRemainingThreads()

awaitStartupCompletion

public void awaitStartupCompletion()

Blocks until the server has started successfully or an exception is thrown.

Throws:

VoldemortException - if a problem occurs during start-up wrapping the original exception.

getStatusManager

public StatusManager getStatusManager()