| Modifier and Type | Class and Description |
|---|---|
| public static class | |
| private static class | |
| private class | |
| private static class |
| Modifier and Type | Field and Description |
|---|---|
| protected volatile long | |
| protected static final int | |
| private final TCPNIOConnectorHandler. | |
| protected boolean | |
| protected boolean | |
| private static final Logger |
| Access | Constructor and Description |
|---|---|
| protected |
| Modifier and Type | Method and Description |
|---|---|
| private static void | abortConnection(final TCPNIOConnection connection, final CompletionHandler<Connection<L>> completionHandler, final Throwable failure)
|
| public static TCPNIOConnectorHandler. | Returns: theTCPNIOConnectorHandler builder.Return the |
| public void | connect(final SocketAddress remoteAddress, final SocketAddress localAddress, final CompletionHandler<Connection<L>> completionHandler)
Overrides org. Implements org. Creates, initializes |
| protected FutureImpl | connectAsync(final SocketAddress remoteAddress, final SocketAddress localAddress, final CompletionHandler<Connection<L>> completionHandler, final boolean needFuture)
Implements abstract org.
|
| protected void | connectSync(SocketAddress remoteAddress, SocketAddress localAddress, CompletionHandler<Connection<L>> completionHandler)
|
| public long | |
| public boolean | |
| public boolean | |
| protected static void | onConnectedAsync(final TCPNIOConnection connection, final CompletionHandler<Connection<L>> completionHandler)
|
| public void | |
| public void | |
| public void | |
| protected void | waitNIOFuture(final FutureImpl<Connection<L>> future, final CompletionHandler<Connection<L>> completionHandler)
|
| connectionTimeoutMillis | back to summary |
|---|---|
| protected volatile long connectionTimeoutMillis | |
| DEFAULT_CONNECTION_TIMEOUT | back to summary |
|---|---|
| protected static final int DEFAULT_CONNECTION_TIMEOUT Hides org. | |
| instantConnectHandler | back to summary |
|---|---|
| private final TCPNIOConnectorHandler. | |
| isReuseAddress | back to summary |
|---|---|
| protected boolean isReuseAddress | |
| isReusePort | back to summary |
|---|---|
| protected boolean isReusePort | |
| LOGGER | back to summary |
|---|---|
| private static final Logger LOGGER | |
| TCPNIOConnectorHandler | back to summary |
|---|---|
| protected TCPNIOConnectorHandler(final TCPNIOTransport transport) | |
| abortConnection | back to summary |
|---|---|
| private static void abortConnection(final TCPNIOConnection connection, final CompletionHandler<Connection<L>> completionHandler, final Throwable failure) | |
| builder | back to summary |
|---|---|
| public static TCPNIOConnectorHandler. Return the
| |
| connect | back to summary |
|---|---|
| public void connect(final SocketAddress remoteAddress, final SocketAddress localAddress, final CompletionHandler<Connection<L>> completionHandler) Overrides org. Implements org. Doc from org. Creates, initializes
| |
| connectAsync | back to summary |
|---|---|
| protected FutureImpl Implements abstract org.
| |
| connectSync | back to summary |
|---|---|
| protected void connectSync(SocketAddress remoteAddress, SocketAddress localAddress, CompletionHandler<Connection<L>> completionHandler) | |
| getSyncConnectTimeout | back to summary |
|---|---|
| public long getSyncConnectTimeout(final TimeUnit timeUnit) | |
| isReuseAddress | back to summary |
|---|---|
| public boolean isReuseAddress() | |
| isReusePort | back to summary |
|---|---|
| public boolean isReusePort() | |
| onConnectedAsync | back to summary |
|---|---|
| protected static void onConnectedAsync(final TCPNIOConnection connection, final CompletionHandler<Connection<L>> completionHandler) throws IOException | |
| setReuseAddress | back to summary |
|---|---|
| public void setReuseAddress(boolean isReuseAddress) | |
| setReusePort | back to summary |
|---|---|
| public void setReusePort(boolean isReusePort) | |
| setSyncConnectTimeout | back to summary |
|---|---|
| public void setSyncConnectTimeout(final long timeout, final TimeUnit timeUnit) | |
| waitNIOFuture | back to summary |
|---|---|
| protected void waitNIOFuture(final FutureImpl<Connection<L>> future, final CompletionHandler<Connection<L>> completionHandler) | |
| Modifier and Type | Field and Description |
|---|---|
| private Boolean | |
| private Boolean | |
| private Long | |
| private TimeUnit | |
| private TCPNIOTransport |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public TCPNIOConnectorHandler | |
| protected AbstractSocketConnectorHandler | |
| public TCPNIOConnectorHandler. | |
| public TCPNIOConnectorHandler. | |
| public TCPNIOConnectorHandler. | |
| public TCPNIOConnectorHandler. |
| reuseAddress | back to summary |
|---|---|
| private Boolean reuseAddress | |
| reusePort | back to summary |
|---|---|
| private Boolean reusePort | |
| timeout | back to summary |
|---|---|
| private Long timeout | |
| timeoutTimeunit | back to summary |
|---|---|
| private TimeUnit timeoutTimeunit | |
| transport | back to summary |
|---|---|
| private TCPNIOTransport transport | |
| Builder | back to summary |
|---|---|
| public Builder() | |
| build | back to summary |
|---|---|
| public TCPNIOConnectorHandler build() Overrides org.
| |
| create | back to summary |
|---|---|
| protected AbstractSocketConnectorHandler create() Implements abstract org.
| |
| setReuseAddress | back to summary |
|---|---|
| public TCPNIOConnectorHandler. | |
| setReusePort | back to summary |
|---|---|
| public TCPNIOConnectorHandler. | |
| setSyncConnectTimeout | back to summary |
|---|---|
| public TCPNIOConnectorHandler. | |
| setTransport | back to summary |
|---|---|
| public TCPNIOConnectorHandler. | |
| Modifier and Type | Field and Description |
|---|---|
| private final CompletionHandler |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | onComplete(final Context context, final Object data)
Overrides org. Implements org.
|
| public void | onError(final Context context, final Object description)
Overrides org. Implements org. Error occurred during |
| public void | onNotRun(final Context context)
Overrides org. Implements org.
|
| public void | onReregister(final Context context)
Overrides org. Implements org. Reregister |
| completionHandler | back to summary |
|---|---|
| private final CompletionHandler<Connection<L>> completionHandler | |
| EnableReadHandler | back to summary |
|---|---|
| private EnableReadHandler(final CompletionHandler<Connection<L>> completionHandler) | |
| onComplete | back to summary |
|---|---|
| public void onComplete(final Context context, final Object data) throws IOException Overrides org. Implements org. Doc from org.
| |
| onError | back to summary |
|---|---|
| public void onError(final Context context, final Object description) throws IOException Overrides org. Implements org. Doc from org. Error occurred during
| |
| onNotRun | back to summary |
|---|---|
| public void onNotRun(final Context context) throws IOException Overrides org. Implements org. Doc from org.
| |
| onReregister | back to summary |
|---|---|
| public void onReregister(final Context context) throws IOException Overrides org. Implements org. Doc from org. Reregister
| |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | completed(RegisterChannelResult result)
Overrides org. Implements org. The operation was completed. |
| InstantConnectHandler | back to summary |
|---|---|
| private InstantConnectHandler() | |
| completed | back to summary |
|---|---|
| public void completed(RegisterChannelResult result) Overrides org. Implements org. Doc from org. The operation was completed.
| |
| Modifier and Type | Field and Description |
|---|---|
| private final TCPNIOConnection |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public void | completed(final RegisterChannelResult result)
Overrides org. Implements org. The operation was completed. |
| public void | failed(final Throwable throwable)
Overrides org. Implements org. The operation was failed. |
| connection | back to summary |
|---|---|
| private final TCPNIOConnection connection | |
| RegisterChannelCompletionHandler | back to summary |
|---|---|
| public RegisterChannelCompletionHandler(TCPNIOConnection connection) | |
| completed | back to summary |
|---|---|
| public void completed(final RegisterChannelResult result) Overrides org. Implements org. Doc from org. The operation was completed.
| |
| failed | back to summary |
|---|---|
| public void failed(final Throwable throwable) Overrides org. Implements org. Doc from org. The operation was failed.
| |