ChannelGroupFuture implementation.
| Modifier and Type | Class and Description |
|---|---|
| private static class |
| Modifier and Type | Field and Description |
|---|---|
| private final ChannelFutureListener | |
| private int | |
| private final Map | |
| private final ChannelGroup | |
| private int |
| Access | Constructor and Description |
|---|---|
| pack-priv | DefaultChannelGroupFuture(ChannelGroup group, Collection<ChannelFuture> futures, EventExecutor executor)
Creates a new instance. |
| pack-priv | DefaultChannelGroupFuture(ChannelGroup group, Map<Channel, ChannelFuture> futures, EventExecutor executor)
|
| childListener | back to summary |
|---|---|
| private final ChannelFutureListener childListener | |
| failureCount | back to summary |
|---|---|
| private int failureCount | |
| futures | back to summary |
|---|---|
| private final Map<Channel, ChannelFuture> futures | |
| group | back to summary |
|---|---|
| private final ChannelGroup group | |
| successCount | back to summary |
|---|---|
| private int successCount | |
| DefaultChannelGroupFuture | back to summary |
|---|---|
| pack-priv DefaultChannelGroupFuture(ChannelGroup group, Collection<ChannelFuture> futures, EventExecutor executor) Creates a new instance. | |
| DefaultChannelGroupFuture | back to summary |
|---|---|
| pack-priv DefaultChannelGroupFuture(ChannelGroup group, Map<Channel, ChannelFuture> futures, EventExecutor executor) | |
| addListener | back to summary |
|---|---|
| public DefaultChannelGroupFuture addListener(GenericFutureListener<? extends Future<? super Void>> listener) Overrides io. Implements io. Doc from io. Adds the specified listener to this future. The specified listener is notified when this future is done. If this future is already completed, the specified listener is notified immediately.
| |
| addListeners | back to summary |
|---|---|
| public DefaultChannelGroupFuture addListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) Overrides io. Implements io. Doc from io. Adds the specified listeners to this future. The specified listeners are notified when this future is done. If this future is already completed, the specified listeners are notified immediately.
| |
| await | back to summary |
|---|---|
| public DefaultChannelGroupFuture await() throws InterruptedException Overrides io. Implements io. Doc from io. Waits for this future to be completed.
| |
| awaitUninterruptibly | back to summary |
|---|---|
| public DefaultChannelGroupFuture awaitUninterruptibly() Overrides io. Implements io. Doc from io. Waits for this future to be completed without
interruption. This method catches an
| |
| cause | back to summary |
|---|---|
| public ChannelGroupException cause() Overrides io. Implements io. Doc from io. Returns the cause of the failed I/O operation if the I/O operation has failed.
| |
| checkDeadLock | back to summary |
|---|---|
| protected void checkDeadLock() Overrides io.
| |
| find | back to summary |
|---|---|
| public ChannelFuture find(Channel channel) Implements io. Doc from io. Returns the
| |
| group | back to summary |
|---|---|
| public ChannelGroup group() Implements io. Doc from io. Returns the
| |
| isPartialFailure | back to summary |
|---|---|
| public synchronized boolean isPartialFailure() Implements io. Doc from io. Returns
| |
| isPartialSuccess | back to summary |
|---|---|
| public synchronized boolean isPartialSuccess() Implements io. Doc from io. Returns
| |
| iterator | back to summary |
|---|---|
| public Iterator Implements io. Doc from io. Returns the
| |
| removeListener | back to summary |
|---|---|
| public DefaultChannelGroupFuture removeListener(GenericFutureListener<? extends Future<? super Void>> listener) Overrides io. Implements io. Doc from io. Removes the first occurrence of the specified listener from this future. The specified listener is no longer notified when this future is done. If the specified listener is not associated with this future, this method does nothing and returns silently.
| |
| removeListeners | back to summary |
|---|---|
| public DefaultChannelGroupFuture removeListeners(GenericFutureListener<? extends Future<? super Void>>... listeners) Overrides io. Implements io. Doc from io. Removes the first occurrence for each of the listeners from this future. The specified listeners are no longer notified when this future is done. If the specified listeners are not associated with this future, this method does nothing and returns silently.
| |
| setFailure | back to summary |
|---|---|
| public DefaultChannelGroupFuture setFailure(Throwable cause) Overrides io. Implements io. Doc from io. Marks this future as a failure and notifies all
listeners.
If it is success or failed already it will throw an
| |
| setFailure0 | back to summary |
|---|---|
| private void setFailure0(ChannelGroupException cause) | |
| setSuccess | back to summary |
|---|---|
| public DefaultChannelGroupFuture setSuccess(Void result) Overrides io. Implements io. Doc from io. Marks this future as a success and notifies all
listeners.
If it is success or failed already it will throw an
| |
| setSuccess0 | back to summary |
|---|---|
| private void setSuccess0() | |
| sync | back to summary |
|---|---|
| public DefaultChannelGroupFuture sync() throws InterruptedException Overrides io. Implements io. Doc from io. Waits for this future until it is done, and rethrows the cause of the failure if this future failed.
| |
| syncUninterruptibly | back to summary |
|---|---|
| public DefaultChannelGroupFuture syncUninterruptibly() Overrides io. Implements io. Doc from io. Waits for this future until it is done, and rethrows the cause of the failure if this future failed.
| |
| tryFailure | back to summary |
|---|---|
| public boolean tryFailure(Throwable cause) Overrides io. Implements io. Doc from io. Marks this future as a failure and notifies all listeners.
| |
| trySuccess | back to summary |
|---|---|
| public boolean trySuccess(Void result) Overrides io. Implements io. Doc from io. Marks this future as a success and notifies all listeners.
| |
| Access | Constructor and Description |
|---|---|
| pack-priv |
| Modifier and Type | Method and Description |
|---|---|
| public K | |
| public V | |
| public V | setValue(V
new value to be stored in this entry value)Implements java. |
| DefaultEntry | back to summary |
|---|---|
| pack-priv DefaultEntry(K key, V value) | |
| getKey | back to summary |
|---|---|
| public K getKey() Implements java. Doc from java. Returns the key corresponding to this entry.
| |
| getValue | back to summary |
|---|---|
| public V getValue() Implements java. Doc from java. Returns the value corresponding to this entry. If the mapping
has been removed from the backing map (by the iterator's
| |
| setValue | back to summary |
|---|---|
| public V setValue(V value) Implements java. Doc from java. Replaces the value corresponding to this entry with the specified
value (optional operation). (Writes through to the map.) The
behavior of this call is undefined if the mapping has already been
removed from the map (by the iterator's
| |