/*
    * Copyright 2012 The Netty Project
    *
    * The Netty Project licenses this file to you under the Apache License,
    * version 2.0 (the "License"); you may not use this file except in compliance
    * with the License. You may obtain a copy of the License at:
    *
    *   http://www.apache.org/licenses/LICENSE-2.0
    *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
   * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
   * License for the specific language governing permissions and limitations
   * under the License.
   */
  package io.netty.channel;
  
  import io.netty.buffer.ByteBuf;
  import io.netty.buffer.ByteBufAllocator;
  import io.netty.util.AttributeKey;
  import io.netty.util.AttributeMap;
  import io.netty.util.concurrent.EventExecutor;
  import io.netty.util.concurrent.FutureListener;
  
  import java.net.ConnectException;
  import java.net.SocketAddress;
  import java.nio.channels.Channels;
  
  /**
   * Enables a [email protected] ChannelHandler} to interact with its [email protected] ChannelPipeline}
   * and other handlers. Among other things a handler can notify the next [email protected] ChannelHandler} in the
   * [email protected] ChannelPipeline} as well as modify the [email protected] ChannelPipeline} it belongs to dynamically.
   *
   * <h3>Notify</h3>
   *
   * You can notify the closest handler in the same [email protected] ChannelPipeline} by calling one of the various methods
   * provided here.
   *
   * Please refer to [email protected] ChannelPipeline} to understand how an event flows.
   *
   * <h3>Modifying a pipeline</h3>
   *
   * You can get the [email protected] ChannelPipeline} your handler belongs to by calling
   * [email protected] #pipeline()}.  A non-trivial application could insert, remove, or
   * replace handlers in the pipeline dynamically at runtime.
   *
   * <h3>Retrieving for later use</h3>
   *
   * You can keep the [email protected] ChannelHandlerContext} for later use, such as
   * triggering an event outside the handler methods, even from a different thread.
   * <pre>
   * public class MyHandler extends [email protected] ChannelDuplexHandler} {
   *
   *     <b>private [email protected] ChannelHandlerContext} ctx;</b>
   *
   *     public void beforeAdd([email protected] ChannelHandlerContext} ctx) {
   *         <b>this.ctx = ctx;</b>
   *     }
   *
   *     public void login(String username, password) {
   *         ctx.write(new LoginMessage(username, password));
   *     }
   *     ...
   * }
   * </pre>
   *
   * <h3>Storing stateful information</h3>
   *
   * [email protected] #attr(AttributeKey)} allow you to
   * store and access stateful information that is related with a handler and its
   * context.  Please refer to [email protected] ChannelHandler} to learn various recommended
   * ways to manage stateful information.
   *
   * <h3>A handler can have more than one context</h3>
   *
   * Please note that a [email protected] ChannelHandler} instance can be added to more than
   * one [email protected] ChannelPipeline}.  It means a single [email protected] ChannelHandler}
   * instance can have more than one [email protected] ChannelHandlerContext} and therefore
   * the single instance can be invoked with different
   * [email protected] ChannelHandlerContext}s if it is added to one or more
   * [email protected] ChannelPipeline}s more than once.
   * <p>
   * For example, the following handler will have as many independent [email protected] AttributeKey}s
   * as how many times it is added to pipelines, regardless if it is added to the
   * same pipeline multiple times or added to different pipelines multiple times:
   * <pre>
   * public class FactorialHandler extends [email protected] ChannelInboundHandlerAdapter} {
   *
   *   private final [email protected] AttributeKey}&lt;[email protected] Integer}&gt; counter = [email protected] AttributeKey}.valueOf("counter");
   *
   *   // This handler will receive a sequence of increasing integers starting
   *   // from 1.
   *   [email protected] @Override}
   *   public void channelRead([email protected] ChannelHandlerContext} ctx, Object msg) {
   *     Integer a = ctx.attr(counter).get();
   *
   *     if (a == null) {
   *       a = 1;
   *     }
  *
  *     attr.set(a * (Integer) msg);
  *   }
  * }
  *
  * // Different context objects are given to "f1", "f2", "f3", and "f4" even if
  * // they refer to the same handler instance.  Because the FactorialHandler
  * // stores its state in a context object (using an [email protected] AttributeKey}), the factorial is
  * // calculated correctly 4 times once the two pipelines (p1 and p2) are active.
  * FactorialHandler fh = new FactorialHandler();
  *
  * [email protected] ChannelPipeline} p1 = [email protected] Channels}.pipeline();
  * p1.addLast("f1", fh);
  * p1.addLast("f2", fh);
  *
  * [email protected] ChannelPipeline} p2 = [email protected] Channels}.pipeline();
  * p2.addLast("f3", fh);
  * p2.addLast("f4", fh);
  * </pre>
  *
  * <h3>Additional resources worth reading</h3>
  * <p>
  * Please refer to the [email protected] ChannelHandler}, and
  * [email protected] ChannelPipeline} to find out more about inbound and outbound operations,
  * what fundamental differences they have, how they flow in a  pipeline,  and how to handle
  * the operation in your application.
  */
 public interface ChannelHandlerContext extends AttributeMap {
 
     /**
      * Return the [email protected] Channel} which is bound to the [email protected] ChannelHandlerContext}.
      */
     Channel channel();
 
     /**
      * Returns the [email protected] EventExecutor} which is used to execute an arbitrary task.
      */
     EventExecutor executor();
 
     /**
      * Returns the [email protected] ChannelHandlerInvoker} which is used to trigger an event for the associated
      * [email protected] ChannelHandler}. Note that the methods in [email protected] ChannelHandlerInvoker} are not intended to be called
      * by a user. Use this method only to obtain the reference to the [email protected] ChannelHandlerInvoker}
      * (and not calling its methods) unless you know what you are doing.
      */
     ChannelHandlerInvoker invoker();
 
     /**
      * The unique name of the [email protected] ChannelHandlerContext}.The name was used when then [email protected] ChannelHandler}
      * was added to the [email protected] ChannelPipeline}. This name can also be used to access the registered
      * [email protected] ChannelHandler} from the [email protected] ChannelPipeline}.
      */
     String name();
 
     /**
      * The [email protected] ChannelHandler} that is bound this [email protected] ChannelHandlerContext}.
      */
     ChannelHandler handler();
 
     /**
      * Return [email protected] true} if the [email protected] ChannelHandler} which belongs to this context was removed
      * from the [email protected] ChannelPipeline}. Note that this method is only meant to be called from with in the
      * [email protected] EventLoop}.
      */
     boolean isRemoved();
 
     /**
      * A [email protected] Channel} was registered to its [email protected] EventLoop}.
      *
      * This will result in having the [email protected] ChannelInboundHandler#channelRegistered(ChannelHandlerContext)} method
      * called of the next [email protected] ChannelInboundHandler} contained in the [email protected] ChannelPipeline} of the
      * [email protected] Channel}.
      */
     ChannelHandlerContext fireChannelRegistered();
 
     /**
      * A [email protected] Channel} was unregistered from its [email protected] EventLoop}.
      *
      * This will result in having the [email protected] ChannelInboundHandler#channelUnregistered(ChannelHandlerContext)} method
      * called of the next [email protected] ChannelInboundHandler} contained in the [email protected] ChannelPipeline} of the
      * [email protected] Channel}.
      */
     ChannelHandlerContext fireChannelUnregistered();
 
     /**
      * A [email protected] Channel} is active now, which means it is connected.
      *
      * This will result in having the [email protected] ChannelInboundHandler#channelActive(ChannelHandlerContext)} method
      * called of the next [email protected] ChannelInboundHandler} contained in the [email protected] ChannelPipeline} of the
      * [email protected] Channel}.
      */
     ChannelHandlerContext fireChannelActive();
 
     /**
      * A [email protected] Channel} is inactive now, which means it is closed.
      *
      * This will result in having the [email protected] ChannelInboundHandler#channelInactive(ChannelHandlerContext)} method
      * called of the next [email protected] ChannelInboundHandler} contained in the [email protected] ChannelPipeline} of the
      * [email protected] Channel}.
      */
     ChannelHandlerContext fireChannelInactive();
 
     /**
      * A [email protected] Channel} received an [email protected] Throwable} in one of its inbound operations.
      *
      * This will result in having the [email protected] ChannelInboundHandler#exceptionCaught(ChannelHandlerContext, Throwable)}
      * method called of the next [email protected] ChannelInboundHandler} contained in the [email protected] ChannelPipeline} of the
      * [email protected] Channel}.
      */
     ChannelHandlerContext fireExceptionCaught(Throwable cause);
 
     /**
      * A [email protected] Channel} received an user defined event.
      *
      * This will result in having the [email protected] ChannelInboundHandler#userEventTriggered(ChannelHandlerContext, Object)}
      * method called of the next [email protected] ChannelInboundHandler} contained in the [email protected] ChannelPipeline} of the
      * [email protected] Channel}.
      */
     ChannelHandlerContext fireUserEventTriggered(Object event);
 
     /**
      * A [email protected] Channel} received a message.
      *
      * This will result in having the [email protected] ChannelInboundHandler#channelRead(ChannelHandlerContext, Object)}
      * method called of the next [email protected] ChannelInboundHandler} contained in the [email protected] ChannelPipeline} of the
      * [email protected] Channel}.
      */
     ChannelHandlerContext fireChannelRead(Object msg);
 
     /**
      * Triggers an [email protected] ChannelInboundHandler#channelReadComplete(ChannelHandlerContext)}
      * event to the next [email protected] ChannelInboundHandler} in the [email protected] ChannelPipeline}.
      */
     ChannelHandlerContext fireChannelReadComplete();
 
     /**
      * Triggers an [email protected] ChannelInboundHandler#channelWritabilityChanged(ChannelHandlerContext)}
      * event to the next [email protected] ChannelInboundHandler} in the [email protected] ChannelPipeline}.
      */
     ChannelHandlerContext fireChannelWritabilityChanged();
 
     /**
      * Request to bind to the given [email protected] SocketAddress} and notify the [email protected] ChannelFuture} once the operation
      * completes, either because the operation was successful or because of an error.
      * <p>
      * This will result in having the
      * [email protected] ChannelOutboundHandler#bind(ChannelHandlerContext, SocketAddress, ChannelPromise)} method
      * called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture bind(SocketAddress localAddress);
 
     /**
      * Request to connect to the given {@link SocketAddress} and notify the {@link ChannelFuture} once the operation
      * completes, either because the operation was successful or because of an error.
      * <p>
      * If the connection fails because of a connection timeout, the {@link ChannelFuture} will get failed with
      * a {@link ConnectTimeoutException}. If it fails because of connection refused a {@link ConnectException}
      * will be used.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture connect(SocketAddress remoteAddress);
 
     /**
      * Request to connect to the given {@link SocketAddress} while bind to the localAddress and notify the
      * {@link ChannelFuture} once the operation completes, either because the operation was successful or because of
      * an error.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture connect(SocketAddress remoteAddress, SocketAddress localAddress);
 
     /**
      * Request to disconnect from the remote peer and notify the {@link ChannelFuture} once the operation completes,
      * either because the operation was successful or because of an error.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#disconnect(ChannelHandlerContext, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture disconnect();
 
     /**
      * Request to close the {@link Channel} and notify the {@link ChannelFuture} once the operation completes,
      * either because the operation was successful or because of
      * an error.
      *
      * After it is closed it is not possible to reuse it again.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#close(ChannelHandlerContext, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture close();
 
     /**
      * Request to deregister from the previous assigned {@link EventExecutor} and notify the
      * {@link ChannelFuture} once the operation completes, either because the operation was successful or because of
      * an error.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#deregister(ChannelHandlerContext, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      *
      */
     ChannelFuture deregister();
 
     /**
      * Request to bind to the given {@link SocketAddress} and notify the {@link ChannelFuture} once the operation
      * completes, either because the operation was successful or because of an error.
      *
      * The given {@link ChannelPromise} will be notified.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#bind(ChannelHandlerContext, SocketAddress, ChannelPromise)} method
      * called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture bind(SocketAddress localAddress, ChannelPromise promise);
 
     /**
      * Request to connect to the given {@link SocketAddress} and notify the {@link ChannelFuture} once the operation
      * completes, either because the operation was successful or because of an error.
      *
      * The given {@link ChannelFuture} will be notified.
      *
      * <p>
      * If the connection fails because of a connection timeout, the {@link ChannelFuture} will get failed with
      * a {@link ConnectTimeoutException}. If it fails because of connection refused a {@link ConnectException}
      * will be used.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture connect(SocketAddress remoteAddress, ChannelPromise promise);
 
     /**
      * Request to connect to the given {@link SocketAddress} while bind to the localAddress and notify the
      * {@link ChannelFuture} once the operation completes, either because the operation was successful or because of
      * an error.
      *
      * The given {@link ChannelPromise} will be notified and also returned.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture connect(SocketAddress remoteAddress, SocketAddress localAddress, ChannelPromise promise);
 
     /**
      * Request to disconnect from the remote peer and notify the {@link ChannelFuture} once the operation completes,
      * either because the operation was successful or because of an error.
      *
      * The given {@link ChannelPromise} will be notified.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#disconnect(ChannelHandlerContext, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture disconnect(ChannelPromise promise);
 
     /**
      * Request to close the {@link Channel} and notify the {@link ChannelFuture} once the operation completes,
      * either because the operation was successful or because of
      * an error.
      *
      * After it is closed it is not possible to reuse it again.
      * The given {@link ChannelPromise} will be notified.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#close(ChannelHandlerContext, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture close(ChannelPromise promise);
 
     /**
      * Request to deregister from the previous assigned {@link EventExecutor} and notify the
      * {@link ChannelFuture} once the operation completes, either because the operation was successful or because of
      * an error.
      *
      * The given {@link ChannelPromise} will be notified.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#deregister(ChannelHandlerContext, ChannelPromise)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelFuture deregister(ChannelPromise promise);
 
     /**
      * Request to Read data from the {@link Channel} into the first inbound buffer, triggers an
      * {@link ChannelInboundHandler#channelRead(ChannelHandlerContext, Object)} event if data was
      * read, and triggers a
      * {@link ChannelInboundHandler#channelReadComplete(ChannelHandlerContext) channelReadComplete} event so the
      * handler can decide to continue reading.  If there's a pending read operation already, this method does nothing.
      * <p>
      * This will result in having the
      * {@link ChannelOutboundHandler#read(ChannelHandlerContext)}
      * method called of the next {@link ChannelOutboundHandler} contained in the {@link ChannelPipeline} of the
      * {@link Channel}.
      */
     ChannelHandlerContext read();
 
     /**
      * Request to write a message via this {@link ChannelHandlerContext} through the {@link ChannelPipeline}.
      * This method will not request to actual flush, so be sure to call {@link #flush()}
      * once you want to request to flush all pending data to the actual transport.
      */
     ChannelFuture write(Object msg);
 
     /**
      * Request to write a message via this {@link ChannelHandlerContext} through the {@link ChannelPipeline}.
      * This method will not request to actual flush, so be sure to call {@link #flush()}
      * once you want to request to flush all pending data to the actual transport.
      */
     ChannelFuture write(Object msg, ChannelPromise promise);
 
     /**
      * Request to flush all pending messages via this ChannelOutboundInvoker.
      */
     ChannelHandlerContext flush();
 
     /**
      * Shortcut for call {@link #write(Object, ChannelPromise)} and {@link #flush()}.
      */
     ChannelFuture writeAndFlush(Object msg, ChannelPromise promise);
 
     /**
      * Shortcut for call {@link #write(Object)} and {@link #flush()}.
      */
     ChannelFuture writeAndFlush(Object msg);
 
     /**
      * Return the assigned {@link ChannelPipeline}
      */
     ChannelPipeline pipeline();
 
     /**
      * Return the assigned {@link ByteBufAllocator} which will be used to allocate {@link ByteBuf}s.
      */
     ByteBufAllocator alloc();
 
     /**
      * Return a new {@link ChannelPromise}.
      */
     ChannelPromise newPromise();
 
     /**
      * Return an new {@link ChannelProgressivePromise}
      */
     ChannelProgressivePromise newProgressivePromise();
 
     /**
      * Create a new {@link ChannelFuture} which is marked as succeeded already. So {@link ChannelFuture#isSuccess()}
      * will return {@code true}. All {@link FutureListener} added to it will be notified directly. Also
      * every call of blocking methods will just return without blocking.
      */
     ChannelFuture newSucceededFuture();
 
     /**
      * Create a new {@link ChannelFuture} which is marked as failed already. So {@link ChannelFuture#isSuccess()}
      * will return {@code false}. All {@link FutureListener} added to it will be notified directly. Also
      * every call of blocking methods will just return without blocking.
      */
     ChannelFuture newFailedFuture(Throwable cause);
 
     /**
      * Return a special ChannelPromise which can be reused for different operations.
      * <p>
      * It's only supported to use
      * it for {@link ChannelHandlerContext#write(Object, ChannelPromise)}.
      * </p>
      * <p>
      * Be aware that the returned {@link ChannelPromise} will not support most operations and should only be used
      * if you want to save an object allocation for every write operation. You will not be able to detect if the
      * operation  was complete, only if it failed as the implementation will call
      * {@link ChannelPipeline#fireExceptionCaught(Throwable)} in this case.
      * </p>
      * <strong>Be aware this is an expert feature and should be used with care!</strong>
      */
     ChannelPromise voidPromise();
 
 }