alluxio.network

Class RejectingServer

java.lang.Object

java.lang.Thread

alluxio.network.RejectingServer

All Implemented Interfaces:

Runnable

public final class RejectingServer
extends Thread

A server which listens on a socket and closes all connections. This is useful for sitting on a socket without causing clients to hang when they try to connect.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
RejectingServer(InetSocketAddress address)
RejectingServer(InetSocketAddress address, long sleepTime)

Method Summary

Modifier and Type	Method and Description
void	run()
void	stopAndJoin() Stops the server and joins the server thread.

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

RejectingServer

public RejectingServer(InetSocketAddress address)

Parameters:

address - the socket address to reject requests on

RejectingServer

public RejectingServer(InetSocketAddress address,
                       long sleepTime)

Parameters:

address - the socket address to reject requests on

sleepTime - sleep time before close connection

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

stopAndJoin

public void stopAndJoin()

Stops the server and joins the server thread.