Examples of org.jboss.netty.channel.ChannelHandlerContext

org.jboss.netty.channel.ChannelHandlerContext
Provides the properties and operations which are specific to the {@link ChannelHandler} and the {@link ChannelPipeline} it belongs to.Via a {@link ChannelHandlerContext}, a {@link ChannelHandler} can sendan upstream or downstream {@link ChannelEvent} to the next or previous{@link ChannelHandler} in the {@link ChannelPipeline}.
```
 +---------+ 1 .. 1 +----------------+ 1 .. n +----------+ 1 .. 1 +---------+ | Handler |------->| HandlerContext |------->| Pipeline |------->| Channel | +---------+        +----------------+        +----------+        +---------+ 
```
@author The Netty Project (netty-dev@lists.jboss.org) @author Trustin Lee (tlee@redhat.com) @version $Rev: 1010 $, $Date: 2009-03-11 19:53:52 +0900 (Wed, 11 Mar 2009) $ @apiviz.owns org.jboss.netty.channel.ChannelHandler

    public ChannelFuture handshake() {
        if (handshaken && !isEnableRenegotiation()) {
            throw new IllegalStateException("renegotiation disabled");
        }


        ChannelHandlerContext ctx = this.ctx;
        Channel channel = ctx.getChannel();
        ChannelFuture handshakeFuture;
        synchronized (handshakeLock) {
            if (handshaking) {
                return this.handshakeFuture;
            } else {

View Full Code Here

    /**
     * Sends an SSL {@code close_notify} message to the specified channel and
     * destroys the underlying {@link SSLEngine}.
     */
    public ChannelFuture close() {
        ChannelHandlerContext ctx = this.ctx;
        Channel channel = ctx.getChannel();
        try {
            engine.closeOutbound();
            return wrapNonAppData(ctx, channel);
        } catch (SSLException e) {
            return failedFuture(channel, e);

View Full Code Here

            long channelCounter = getChannelCounter(channel).addAndGet(increment);
            //System.out.println("IC: " + channelCounter + ", " + increment);
            if (maxChannelMemorySize != 0 && channelCounter >= maxChannelMemorySize && channel.isOpen()) {
                if (channel.isReadable()) {
                    //System.out.println("UNREADABLE");
                    ChannelHandlerContext ctx = eventTask.getContext();
                    if (ctx.getHandler() instanceof ExecutionHandler) {
                        // readSuspended = true;
                        ctx.setAttachment(Boolean.TRUE);
                    }
                    channel.setReadable(false);
                }
            }
        } else {

View Full Code Here

            long channelCounter = getChannelCounter(channel).addAndGet(-increment);
            //System.out.println("DC: " + channelCounter + ", " + increment);
            if (maxChannelMemorySize != 0 && channelCounter < maxChannelMemorySize && channel.isOpen()) {
                if (!channel.isReadable()) {
                    //System.out.println("READABLE");
                    ChannelHandlerContext ctx = eventTask.getContext();
                    if (ctx.getHandler() instanceof ExecutionHandler) {
                        // readSuspended = false;
                        ctx.setAttachment(null);
                    }
                    channel.setReadable(true);
                }
            }
        }

View Full Code Here


    /**
     * Continues to fetch the chunks from the input.
     */
    public void resumeTransfer() {
        ChannelHandlerContext ctx = this.ctx;
        if (ctx == null) {
            return;
        }


        try {

View Full Code Here

    /**
     * Sends an SSL {@code close_notify} message to the specified channel and
     * destroys the underlying {@link SSLEngine}.
     */
    public ChannelFuture close(Channel channel) throws SSLException {
        ChannelHandlerContext ctx = context(channel);
        engine.closeOutbound();
        return wrapNonAppData(ctx, channel);
    }

View Full Code Here

    }


    @Override
    public Set<Credential> extractCredentials() {
        HashSet<Credential> credentials = new HashSet<Credential>();
        ChannelHandlerContext handlerContext = getMessage().getHeader(NettyConstants.NETTY_CHANNEL_HANDLER_CONTEXT, ChannelHandlerContext.class);
        if (handlerContext != null) {
            SslHandler sslHandler = handlerContext.getPipeline().get(SslHandler.class);
            if (sslHandler != null) {
                credentials.addAll(new SSLSessionCredentialExtractor().extract(sslHandler.getEngine().getSession()));
            }
        }
        return credentials;

View Full Code Here

            long channelCounter = getChannelCounter(channel).addAndGet(increment);
            //System.out.println("IC: " + channelCounter + ", " + increment);
            if (maxChannelMemorySize != 0 && channelCounter >= maxChannelMemorySize && channel.isOpen()) {
                if (channel.isReadable()) {
                    //System.out.println("UNREADABLE");
                    ChannelHandlerContext ctx = eventTask.getContext();
                    if (ctx.getHandler() instanceof ExecutionHandler) {
                        // readSuspended = true;
                        ctx.setAttachment(Boolean.TRUE);
                    }
                    channel.setReadable(false);
                }
            }
        } else {

View Full Code Here

            long channelCounter = getChannelCounter(channel).addAndGet(-increment);
            //System.out.println("DC: " + channelCounter + ", " + increment);
            if (maxChannelMemorySize != 0 && channelCounter < maxChannelMemorySize && channel.isOpen()) {
                if (!channel.isReadable()) {
                    //System.out.println("READABLE");
                    ChannelHandlerContext ctx = eventTask.getContext();
                    if (ctx.getHandler() instanceof ExecutionHandler) {
                        // readSuspended = false;
                        ctx.setAttachment(null);
                    }
                    channel.setReadable(true);
                }
            }
        }

View Full Code Here

    /**
     * Sends an SSL {@code close_notify} message to the specified channel and
     * destroys the underlying {@link SSLEngine}.
     */
    public ChannelFuture close(Channel channel) throws SSLException {
        ChannelHandlerContext ctx = context(channel);
        engine.closeOutbound();
        return wrapNonAppData(ctx, channel);
    }

View Full Code Here

0 1 2 3 4 5 6 7 8

TOP

Related Classes of org.jboss.netty.channel.ChannelHandlerContext

com.facebook.nifty.core.TestCodec

com.github.kevwil.aspen.domain.DefaultRackEnvironmentTest

com.github.kevwil.aspen.domain.ResponseTest

com.linkedin.r2.transport.http.client.HttpNettyClient

com.ning.http.client.providers.netty.NettyAsyncHttpProvider

com.yahoo.omid.replication.TestSharedMessageBuffer

org.apache.james.imapserver.netty.ImapRequestFrameDecoder

org.jboss.netty.handler.codec.compression.JdkZlibEncoder

org.jboss.netty.handler.codec.compression.ZlibEncoder

org.jboss.netty.handler.codec.http.HttpChunkAggregatorTest

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.