org.dapper.server

Class Server

java.lang.Object

java.lang.Thread

org.dapper.server.Server

All Implemented Interfaces:

Closeable, AutoCloseable, Runnable

public class Server
extends Thread
implements Closeable

The Dapper server class.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	log The instance used for logging.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
Server() Alternate constructor.
Server(InetAddress address, int port) Default constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Shuts down this thread.
void	closeIdleClients() Closes all idle clients.
ServerProcessor.FlowProxy	createFlow(FlowBuilder builder, ClassLoader cl) A facade for createFlow(FlowBuilder, ClassLoader, int).
ServerProcessor.FlowProxy	createFlow(FlowBuilder builder, ClassLoader cl, int flowFlags) Creates a Flow.
<F,N> BlockingQueue<FlowEvent<F,N>>	createFlowEventQueue() Creates a new Queue for subscribing to FlowEvents.
static org.slf4j.Logger	getLog() Gets the static Logger instance.
int	getPendingCount() Gets the number of additional clients required to saturate all pending computations.
List<ServerProcessor.FlowProxy>	refresh() Refreshes all Flows.
void	run() Runs the connection creation loop.
Server	setAutocloseIdle(boolean autocloseIdle) Sets whether idle clients should be automatically closed.
String	toString() Delegates to the underlying ServerProcessor.

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, yield

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.slf4j.Logger log

The instance used for logging.

Constructor Detail

Server

public Server(InetAddress address,
      int port)
       throws UnknownHostException,
              IOException

Default constructor.

Parameters:

address - the server's InetAddress as it would appear to clients.

port - the port to listen on.

Throws:

UnknownHostException - when the server's InetAddress could not be inferred.

IOException - when the underlying ServerSocketChannel could not be bound.

Server

public Server()
       throws UnknownHostException,
              IOException

Alternate constructor. Listens on the default port value Constants.DEFAULT_SERVER_PORT.

Throws:

UnknownHostException - when the server's InetAddress could not be inferred.

IOException - when the underlying ServerSocketChannel could not be bound.

Method Detail

getLog

public static final org.slf4j.Logger getLog()

Gets the static Logger instance.

createFlow

public ServerProcessor.FlowProxy createFlow(FlowBuilder builder,
                                   ClassLoader cl)
                                     throws InterruptedException,
                                            ExecutionException

A facade for createFlow(FlowBuilder, ClassLoader, int).

Throws:

InterruptedException - when this operation is interrupted.

ExecutionException - when something goes awry.

createFlow

public ServerProcessor.FlowProxy createFlow(FlowBuilder builder,
                                   ClassLoader cl,
                                   int flowFlags)
                                     throws InterruptedException,
                                            ExecutionException

Creates a Flow.

Throws:

InterruptedException - when this operation is interrupted.

ExecutionException - when something goes awry.

refresh

public List<ServerProcessor.FlowProxy> refresh()
                                        throws InterruptedException,
                                               ExecutionException

Refreshes all Flows.

Throws:

InterruptedException - when this operation is interrupted.

ExecutionException - when something goes awry.

closeIdleClients

public void closeIdleClients()
                      throws InterruptedException,
                             ExecutionException

Closes all idle clients.

Throws:

InterruptedException - when this operation is interrupted.

ExecutionException - when something goes awry.

setAutocloseIdle

public Server setAutocloseIdle(boolean autocloseIdle)
                        throws InterruptedException,
                               ExecutionException

Sets whether idle clients should be automatically closed.

Throws:

InterruptedException - when this operation is interrupted.

ExecutionException - when something goes awry.

getPendingCount

public int getPendingCount()
                    throws InterruptedException,
                           ExecutionException

Gets the number of additional clients required to saturate all pending computations.

Throws:

InterruptedException - when this operation is interrupted.

ExecutionException - when something goes awry.

createFlowEventQueue

public <F,N> BlockingQueue<FlowEvent<F,N>> createFlowEventQueue()
                                                   throws InterruptedException,
                                                          ExecutionException

Creates a new Queue for subscribing to FlowEvents.

Type Parameters:

F - the Flow attachment type.

N - the FlowNode attachment type.

Throws:

InterruptedException - when this operation is interrupted.

ExecutionException - when something goes awry.

toString

public String toString()

Delegates to the underlying ServerProcessor.

Overrides:

toString in class Thread

close

public void close()

Shuts down this thread.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

run

public void run()

Runs the connection creation loop.

Specified by:

run in interface Runnable

Overrides:

run in class Thread