Examples of com.facebook.presto.jdbc.internal.netty.channel.ChannelFuture

Package com.facebook.presto.jdbc.internal.netty.channel

Examples of com.facebook.presto.jdbc.internal.netty.channel.ChannelFuture

com.facebook.presto.jdbc.internal.netty.channel.ChannelFuture
- NEVER DO THIS {@code @Override}public void messageReceived( {@link ChannelHandlerContext} ctx, {@link MessageEvent} e) {if (e.getMessage() instanceof GoodByeMessage) { {@link ChannelFuture} future = e.getChannel().close();future.awaitUninterruptibly(); // Perform post-closure operation // ... } } // GOOD {@code @Override}public void messageReceived( {@link ChannelHandlerContext} ctx, {@link MessageEvent} e) {if (e.getMessage() instanceof GoodByeMessage) { {@link ChannelFuture} future = e.getChannel().close();future.addListener(new {@link ChannelFutureListener}() { public void operationComplete( {@link ChannelFuture} future) {// Perform post-closure operation // ... } }); } }
In spite of the disadvantages mentioned above, there are certainly the cases where it is more convenient to call {@link #await()}. In such a case, please make sure you do not call {@link #await()} in an I/O thread. Otherwise,{@link IllegalStateException} will be raised to prevent a dead lock.
Do not confuse I/O timeout and await timeout
The timeout value you specify with {@link #await(long)}, {@link #await(long,TimeUnit)}, {@link #awaitUninterruptibly(long)}, or {@link #awaitUninterruptibly(long,TimeUnit)} are not related with I/Otimeout at all. If an I/O operation times out, the future will be marked as 'completed with failure,' as depicted in the diagram above. For example, connect timeout should be configured via a transport-specific option:
```
 // BAD - NEVER DO THIS {@link ClientBootstrap} b = ...;{@link ChannelFuture} f = b.connect(...);f.awaitUninterruptibly(10, TimeUnit.SECONDS); if (f.isCancelled()) { // Connection attempt cancelled by user } else if (!f.isSuccess()) { // You might get a NullPointerException here because the future // might not be completed yet. f.getCause().printStackTrace(); } else { // Connection established successfully } // GOOD {@link ClientBootstrap} b = ...;// Configure the connect timeout option. b.setOption("connectTimeoutMillis", 10000); {@link ChannelFuture} f = b.connect(...);f.awaitUninterruptibly(); // Now we are sure the future is completed. assert f.isDone(); if (f.isCancelled()) { // Connection attempt cancelled by user } else if (!f.isSuccess()) { f.getCause().printStackTrace(); } else { // Connection established successfully } 
```
@apiviz.landmark @apiviz.owns com.facebook.presto.jdbc.internal.netty.channel.ChannelFutureListener - - notifies

        if (e instanceof ChannelStateEvent) {
            ChannelStateEvent event = (ChannelStateEvent) e;


            DefaultLocalChannel channel =
                  (DefaultLocalChannel) event.getChannel();
            ChannelFuture future = event.getFuture();
            ChannelState state = event.getState();
            Object value = event.getValue();
            switch (state) {
            case OPEN:
                if (Boolean.FALSE.equals(value)) {
                    channel.closeNow(future);
                }
                break;
            case BOUND:
                if (value != null) {
                    bind(channel, future, (LocalAddress) value);
                } else {
                    channel.closeNow(future);
                }
                break;
            case CONNECTED:
                if (value != null) {
                    connect(channel, future, (LocalAddress) value);
                } else {
                    channel.closeNow(future);
                }
                break;
            case INTEREST_OPS:
                // Unsupported - discard silently.
                future.setSuccess();
                break;
            }
        } else if (e instanceof MessageEvent) {
            MessageEvent event = (MessageEvent) e;
            DefaultLocalChannel channel = (DefaultLocalChannel) event.getChannel();

View Full Code Here

        // Set Content-Length to workaround some known defect.
        // See also: http://www.ietf.org/mail-archive/web/hybi/current/msg02149.html
        request.setHeader(Names.CONTENT_LENGTH, key3.length);
        request.setContent(ChannelBuffers.copiedBuffer(key3));


        final ChannelFuture handshakeFuture = new DefaultChannelFuture(channel, false);
        ChannelFuture future = channel.write(request);


        future.addListener(new ChannelFutureListener() {
            public void operationComplete(ChannelFuture future) {
                ChannelPipeline p = future.getChannel().getPipeline();
                p.replace(HttpRequestEncoder.class, "ws-encoder", new WebSocket00FrameEncoder());


                if (future.isSuccess()) {
                    handshakeFuture.setSuccess();
                } else {
                    handshakeFuture.setFailure(future.getCause());
                }
            }
        });


        return handshakeFuture;

View Full Code Here

                    getWebSocketLocation(ctx.getPipeline(), req, websocketPath), subprotocols, allowExtensions);
            final WebSocketServerHandshaker handshaker = wsFactory.newHandshaker(req);
            if (handshaker == null) {
                wsFactory.sendUnsupportedWebSocketVersionResponse(ctx.getChannel());
            } else {
                final ChannelFuture handshakeFuture = handshaker.handshake(ctx.getChannel(), req);
                handshakeFuture.addListener(new ChannelFutureListener() {
                    public void operationComplete(ChannelFuture future) throws Exception {
                        if (!future.isSuccess()) {
                            Channels.fireExceptionCaught(ctx, future.getCause());
                        }
                    }

View Full Code Here

        logger.error("Exception Caught", cause);
        ctx.getChannel().close();
    }


    private static void sendHttpResponse(ChannelHandlerContext ctx, HttpRequest req, HttpResponse res) {
        ChannelFuture f = ctx.getChannel().write(res);
        if (!isKeepAlive(req) || res.getStatus().getCode() != 200) {
            f.addListener(ChannelFutureListener.CLOSE);
        }
    }

View Full Code Here

            if (protocol != null) {
                res.addHeader(WEBSOCKET_PROTOCOL, selectSubprotocol(protocol));
            }
        }


        ChannelFuture future = channel.write(res);


        // Upgrade the connection and send the handshake response.
        future.addListener(new ChannelFutureListener() {
            public void operationComplete(ChannelFuture future) {
                ChannelPipeline p = future.getChannel().getPipeline();
                if (p.get(HttpChunkAggregator.class) != null) {
                    p.remove(HttpChunkAggregator.class);
                }
                p.get(HttpRequestDecoder.class).replace("wsdecoder",
                        new WebSocket00FrameDecoder(getMaxFramePayloadLength()));

View Full Code Here

                res.addHeader(Names.SEC_WEBSOCKET_PROTOCOL, selectedSubprotocol);
                setSelectedSubprotocol(selectedSubprotocol);
            }
        }


        ChannelFuture future = channel.write(res);


        // Upgrade the connection and send the handshake response.
        future.addListener(new ChannelFutureListener() {
            public void operationComplete(ChannelFuture future) {
                ChannelPipeline p = future.getChannel().getPipeline();
                if (p.get(HttpChunkAggregator.class) != null) {
                    p.remove(HttpChunkAggregator.class);
                }


                p.get(HttpRequestDecoder.class).replace("wsdecoder",

View Full Code Here

     * @param frame
     *            Web Socket frame that was received
     */
    @Override
    public ChannelFuture close(Channel channel, CloseWebSocketFrame frame) {
        ChannelFuture future = channel.write(frame);
        future.addListener(ChannelFutureListener.CLOSE);
        return future;
    }

View Full Code Here

            for (Map.Entry<String, String> e: customHeaders.entrySet()) {
                request.addHeader(e.getKey(), e.getValue());
            }
        }


        ChannelFuture future = channel.write(request);
        final ChannelFuture handshakeFuture = new DefaultChannelFuture(channel, false);


        future.addListener(new ChannelFutureListener() {
            public void operationComplete(ChannelFuture future) {
                ChannelPipeline p = future.getChannel().getPipeline();
                p.replace(HttpRequestEncoder.class, "ws-encoder", new WebSocket13FrameEncoder(true));


                if (future.isSuccess()) {
                    handshakeFuture.setSuccess();
                } else {
                    handshakeFuture.setFailure(future.getCause());
                }
            }
        });


        return handshakeFuture;

View Full Code Here

                res.addHeader(Names.SEC_WEBSOCKET_PROTOCOL, selectedSubprotocol);
                setSelectedSubprotocol(selectedSubprotocol);
            }
        }


        ChannelFuture future = channel.write(res);


        // Upgrade the connection and send the handshake response.
        future.addListener(new ChannelFutureListener() {
            public void operationComplete(ChannelFuture future) {
                ChannelPipeline p = future.getChannel().getPipeline();
                if (p.get(HttpChunkAggregator.class) != null) {
                    p.remove(HttpChunkAggregator.class);
                }


                p.get(HttpRequestDecoder.class).replace("wsdecoder",

View Full Code Here

     * @param frame
     *            Web Socket frame that was received
     */
    @Override
    public ChannelFuture close(Channel channel, CloseWebSocketFrame frame) {
        ChannelFuture f = channel.write(frame);
        f.addListener(ChannelFutureListener.CLOSE);
        return f;
    }

View Full Code Here

0 1 2 3 4 5

TOP

Related Classes of com.facebook.presto.jdbc.internal.netty.channel.ChannelFuture

com.facebook.presto.jdbc.internal.airlift.http.client.netty.NettyConnectionPool

com.facebook.presto.jdbc.internal.airlift.http.client.netty.NettyConnectionPool$SslConnectionListener

com.facebook.presto.jdbc.internal.netty.bootstrap.ConnectionlessBootstrap

com.facebook.presto.jdbc.internal.netty.bootstrap.ServerBootstrap

com.facebook.presto.jdbc.internal.netty.channel.local.LocalClientChannelSink

com.facebook.presto.jdbc.internal.netty.channel.local.LocalServerChannelSink

com.facebook.presto.jdbc.internal.netty.channel.socket.http.HttpTunnelingClientSocketChannel

com.facebook.presto.jdbc.internal.netty.channel.socket.http.HttpTunnelingClientSocketPipelineSink

com.facebook.presto.jdbc.internal.netty.channel.socket.http.HttpTunnelingServlet

com.facebook.presto.jdbc.internal.netty.channel.socket.nio.AbstractNioWorker

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.

Examples of com.facebook.presto.jdbc.internal.netty.channel.ChannelFuture

Do not confuse I/O timeout and await timeout

Related Classes of com.facebook.presto.jdbc.internal.netty.channel.ChannelFuture