Package one.nio.server

Class Server

java.lang.Object

one.nio.server.Server

All Implemented Interfaces:

ServerMXBean

Direct Known Subclasses:

HttpServer, RpcServer

public class Server
extends Object
implements ServerMXBean

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	Server.QueueStats
private static final class	Server.SelectorStats

Field Summary

Fields

Modifier and Type	Field	Description
protected Acceptor	acceptor
protected final CleanupThread	cleanup
protected boolean	closeSessions
private static final org.slf4j.Logger	log
protected boolean	pinAcceptors
protected final int	port
private Server.QueueStats	queueStats
private final LongAdder	requestsProcessed
private final LongAdder	requestsRejected
protected SelectorThread[]	selectors
private Server.SelectorStats	selectorStats
protected boolean	useWorkers
protected final WorkerPool	workers

Constructor Summary

Constructors

Constructor	Description
Server(ServerConfig config)

Method Summary

Modifier and Type	Method	Description
final void	asyncExecute(Runnable command)
Session	createSession(Socket socket)
long	getAcceptedSessions()
int	getConnections()
long	getKeepAlive()
long	getQueueAvgBytes()
double	getQueueAvgLength()
long	getQueueMaxBytes()
long	getQueueMaxLength()
private Server.QueueStats	getQueueStats()
long	getRejectedSessions()
long	getRequestsProcessed()
long	getRequestsRejected()
double	getSelectorAvgReady()
int	getSelectorCount()
int	getSelectorMaxReady()
long	getSelectorOperations()
long	getSelectorSessions()
private Server.SelectorStats	getSelectorStats()
private Selector	getSmallestPinnedSelector(int idx, int total)
private Selector	getSmallestSelector()
int	getWorkers()
int	getWorkersActive()
boolean	getWorkersUsed()
final void	incRequestsProcessed()
final void	incRequestsRejected()
void	reconfigure(ServerConfig config)
void	register(Session session)
void	register(Session session, int acceptorIndex, int acceptorGroupSize)
void	registerShutdownHook()
void	reset()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

log

private static final org.slf4j.Logger log

requestsProcessed

private final LongAdder requestsProcessed

requestsRejected

private final LongAdder requestsRejected

selectorStats

private volatile Server.SelectorStats selectorStats

queueStats

private volatile Server.QueueStats queueStats

port

protected final int port

acceptor

protected volatile Acceptor acceptor

selectors

protected volatile SelectorThread[] selectors

useWorkers

protected boolean useWorkers

workers

protected final WorkerPool workers

cleanup

protected final CleanupThread cleanup

closeSessions

protected boolean closeSessions

pinAcceptors

protected boolean pinAcceptors

Constructor Details

Server

public Server(ServerConfig config)
       throws IOException

Throws:

IOException

Method Details

reconfigure

public void reconfigure(ServerConfig config)
                 throws IOException

Throws:

IOException

start

public void start()

stop

public void stop()

registerShutdownHook

public void registerShutdownHook()

createSession

public Session createSession(Socket socket)
                      throws RejectedSessionException

Throws:

RejectedSessionException

register

public void register(Session session,
 int acceptorIndex,
 int acceptorGroupSize)

register

public void register(Session session)

getSmallestPinnedSelector

private Selector getSmallestPinnedSelector(int idx,
 int total)

getSmallestSelector

private Selector getSmallestSelector()

incRequestsProcessed

public final void incRequestsProcessed()

incRequestsRejected

public final void incRequestsRejected()

getConnections

public int getConnections()

Specified by:

getConnections in interface ServerMXBean

getKeepAlive

public long getKeepAlive()

Specified by:

getKeepAlive in interface ServerMXBean

getWorkersUsed

public boolean getWorkersUsed()

Specified by:

getWorkersUsed in interface ServerMXBean

getWorkers

public int getWorkers()

Specified by:

getWorkers in interface ServerMXBean

getWorkersActive

public int getWorkersActive()

Specified by:

getWorkersActive in interface ServerMXBean

getAcceptedSessions

public long getAcceptedSessions()

Specified by:

getAcceptedSessions in interface ServerMXBean

getRejectedSessions

public long getRejectedSessions()

Specified by:

getRejectedSessions in interface ServerMXBean

getSelectorCount

public int getSelectorCount()

Specified by:

getSelectorCount in interface ServerMXBean

getSelectorAvgReady

public double getSelectorAvgReady()

Specified by:

getSelectorAvgReady in interface ServerMXBean

getSelectorMaxReady

public int getSelectorMaxReady()

Specified by:

getSelectorMaxReady in interface ServerMXBean

getSelectorOperations

public long getSelectorOperations()

Specified by:

getSelectorOperations in interface ServerMXBean

getSelectorSessions

public long getSelectorSessions()

Specified by:

getSelectorSessions in interface ServerMXBean

getQueueAvgLength

public double getQueueAvgLength()

Specified by:

getQueueAvgLength in interface ServerMXBean

getQueueAvgBytes

public long getQueueAvgBytes()

Specified by:

getQueueAvgBytes in interface ServerMXBean

getQueueMaxLength

public long getQueueMaxLength()

Specified by:

getQueueMaxLength in interface ServerMXBean

getQueueMaxBytes

public long getQueueMaxBytes()

Specified by:

getQueueMaxBytes in interface ServerMXBean

getRequestsProcessed

public long getRequestsProcessed()

Specified by:

getRequestsProcessed in interface ServerMXBean

getRequestsRejected

public long getRequestsRejected()

Specified by:

getRequestsRejected in interface ServerMXBean

reset

public void reset()

Specified by:

reset in interface ServerMXBean

asyncExecute

public final void asyncExecute(Runnable command)

getSelectorStats

private Server.SelectorStats getSelectorStats()

getQueueStats

private Server.QueueStats getQueueStats()