| Modifier and Type | Class and Description |
|---|---|
| private class | |
| private static interface | |
| private class | |
| private class | |
| private class |
| Modifier and Type | Field and Description |
|---|---|
| private final RoundRobinConnectionDistributor. |
| Access | Constructor and Description |
|---|---|
| public | |
| public | |
| public | RoundRobinConnectionDistributor(final NIOTransport transport, final boolean
depending on this flag server useDedicatedAcceptor, final boolean Connections, responsible for accepting client
connections, will or will not use dedicated SelectorRunnertrue means this isServerOnly)NIOChannelDistributor will be used by a Transport, which
operates as a server only(the Transport will never initiate a client-side Connection). In this case we're
able to use optimized (thread unsafe) distribution algorithm.Constructs RoundRobinConnectionDistributor with the given configuration. |
| Modifier and Type | Method and Description |
|---|---|
| public void | registerChannel(final SelectableChannel channel, final int interestOps, final Object attachment)
Implements org.
|
| public void | registerChannelAsync(final SelectableChannel channel, final int interestOps, final Object attachment, final CompletionHandler<RegisterChannelResult> completionHandler)
Implements org.
|
| public void | registerServiceChannelAsync(final SelectableChannel channel, final int interestOps, final Object attachment, final CompletionHandler<RegisterChannelResult> completionHandler)
Implements org.
|
| it | back to summary |
|---|---|
| private final RoundRobinConnectionDistributor. | |
| RoundRobinConnectionDistributor | back to summary |
|---|---|
| public RoundRobinConnectionDistributor(final NIOTransport transport) | |
| RoundRobinConnectionDistributor | back to summary |
|---|---|
| public RoundRobinConnectionDistributor(final NIOTransport transport, final boolean useDedicatedAcceptor) | |
| RoundRobinConnectionDistributor | back to summary |
|---|---|
| public RoundRobinConnectionDistributor(final NIOTransport transport, final boolean useDedicatedAcceptor, final boolean isServerOnly) Constructs RoundRobinConnectionDistributor with the given configuration.
| |
| registerChannel | back to summary |
|---|---|
| public void registerChannel(final SelectableChannel channel, final int interestOps, final Object attachment) throws IOException Implements org.
| |
| registerChannelAsync | back to summary |
|---|---|
| public void registerChannelAsync(final SelectableChannel channel, final int interestOps, final Object attachment, final CompletionHandler<RegisterChannelResult> completionHandler) Implements org.
| |
| registerServiceChannelAsync | back to summary |
|---|---|
| public void registerServiceChannelAsync(final SelectableChannel channel, final int interestOps, final Object attachment, final CompletionHandler<RegisterChannelResult> completionHandler) Implements org.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final AtomicInteger |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public SelectorRunner | |
| public SelectorRunner |
| counter | back to summary |
|---|---|
| private final AtomicInteger counter | |
| DedicatedIterator | back to summary |
|---|---|
| private DedicatedIterator() | |
| next | back to summary |
|---|---|
| public SelectorRunner next() Implements org.
| |
| nextService | back to summary |
|---|---|
| public SelectorRunner nextService() Implements org.
| |
| Modifier and Type | Method and Description |
|---|---|
| public SelectorRunner | |
| public SelectorRunner |
| next | back to summary |
|---|---|
| public SelectorRunner next() | |
| nextService | back to summary |
|---|---|
| public SelectorRunner nextService() | |
| Modifier and Type | Field and Description |
|---|---|
| private int |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public SelectorRunner | |
| public SelectorRunner |
| counter | back to summary |
|---|---|
| private int counter | |
| ServDedicatedIterator | back to summary |
|---|---|
| private ServDedicatedIterator() | |
| next | back to summary |
|---|---|
| public SelectorRunner next() Implements org.
| |
| nextService | back to summary |
|---|---|
| public SelectorRunner nextService() Implements org.
| |