java.lang.Object
- one.nio.server.Server

All Implemented Interfaces:

ServerMXBean

Direct Known Subclasses:

HttpServer, RpcServer
```
public class Server
extends java.lang.Object
implements ServerMXBean
```

Nested Class Summary

Nested Classes
Modifier and Type Class Description

private static class Server.QueueStats

private static class Server.SelectorStats

Field Summary

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

Constructor Summary

Constructors
Constructor Description

Server(ServerConfig config)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`asyncExecute(java.lang.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()`
`void`	`incRequestsProcessed()`
`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 Detail

log

private static final org.slf4j.Logger log

requestsProcessed

private final java.util.concurrent.atomic.LongAdder requestsProcessed

requestsRejected

private final java.util.concurrent.atomic.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 Detail

Server

public Server(ServerConfig config)
       throws java.io.IOException

Throws:: java.io.IOException

Method Detail
- reconfigure
```
public void reconfigure(ServerConfig config)
                 throws java.io.IOException
```
  Throws:
  
  java.io.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(java.lang.Runnable command)
```
- getSelectorStats
```
private Server.SelectorStats getSelectorStats()
```
- getQueueStats
```
private Server.QueueStats getQueueStats()
```

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

Class Server

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

log

requestsProcessed

requestsRejected

selectorStats

queueStats

port

acceptor

selectors

useWorkers

workers

cleanup

closeSessions

pinAcceptors

Constructor Detail

Server

Method Detail

reconfigure

start

stop

registerShutdownHook

createSession

register

register

getSmallestPinnedSelector

getSmallestSelector

incRequestsProcessed

incRequestsRejected

getConnections

getKeepAlive

getWorkersUsed

getWorkers

getWorkersActive

getAcceptedSessions

getRejectedSessions

getSelectorCount

getSelectorAvgReady

getSelectorMaxReady

getSelectorOperations

getSelectorSessions

getQueueAvgLength

getQueueAvgBytes

getQueueMaxLength

getQueueMaxBytes

getRequestsProcessed

getRequestsRejected

reset

asyncExecute

getSelectorStats

getQueueStats