Package org.jboss.netty.channel

Examples of org.jboss.netty.channel.ChannelException

134
135
136
137
138
139
140
141
        try {
            final DatagramChannel channel = DatagramChannel.open();
            channel.configureBlocking(false);
            return channel;
        } catch (final IOException e) {
            throw new ChannelException("Failed to open a DatagramChannel.", e);
        }
    }
View Full Code Here
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
    }

    private void bind(DefaultLocalChannel channel, ChannelFuture future, LocalAddress localAddress) {
        try {
            if (!LocalChannelRegistry.register(localAddress, channel)) {
                throw new ChannelException("address already in use: " + localAddress);
            }

            if (!channel.bound.compareAndSet(false, true)) {
                throw new ChannelException("already bound");
            }

            channel.localAddress = localAddress;
            future.setSuccess();
            fireChannelBound(channel, localAddress);
View Full Code Here
342
343
344
345
346
347
348
349
350
351
352
        @Override
        public void messageReceived(ChannelHandlerContext ctx, MessageEvent e) throws Exception {
            if (!readingChunks) {
                HttpResponse res = (HttpResponse) e.getMessage();
                if (res.getStatus().getCode() != HttpResponseStatus.OK.getCode()) {
                    throw new ChannelException("Unexpected HTTP response status: " + res.getStatus());
                }

                if (res.isChunked()) {
                    readingChunks = true;
                } else {
View Full Code Here
185
186
187
188
189
190
191
192
193
194
195
                if (!started) {
                    // Open a selector if this worker didn't start yet.
                    try {
                        this.selector = selector =  Selector.open();
                    } catch (Throwable t) {
                        throw new ChannelException(
                                "Failed to create a selector.", t);
                    }

                    // Start the worker thread with the new Selector.
                    boolean success = false;
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
            if (!started) {
                // Open a selector if this worker didn't start yet.
                try {
                    this.selector = selector = Selector.open();
                } catch (Throwable t) {
                    throw new ChannelException(
                            "Failed to create a selector.", t);
                }

                // Start the worker thread with the new Selector.
                String threadName =
View Full Code Here
771
772
773
774
775
776
777
778
779
780
781
                if (future != null) {
                    future.setFailure(e);
                }
                close(channel, succeededFuture(channel));
                if (!(e instanceof ClosedChannelException)) {
                    throw new ChannelException(
                            "Failed to register a socket to the selector.", e);
                }
            }

            if (!server) {
View Full Code Here
159
160
161
162
163
164
165
166
167
168
169
            if (!started) {
                // Open a selector if this worker didn't start yet.
                try {
                    this.selector = selector = Selector.open();
                } catch (final Throwable t) {
                    throw new ChannelException("Failed to create a selector.",
                            t);
                }

                boolean success = false;
                try {
View Full Code Here
859
860
861
862
863
864
865
866
867
            } catch (final ClosedChannelException e) {
                if (future != null) {
                    future.setFailure(e);
                }
                close(channel, succeededFuture(channel));
                throw new ChannelException(
                        "Failed to register a socket to the selector.", e);
            }
        }
View Full Code Here
279
280
281
282
283
284
285
286
287
288
        // Wait for the future.
        future.awaitUninterruptibly();
        if (!future.isSuccess()) {
            future.getChannel().close().awaitUninterruptibly();
            throw new ChannelException("Failed to bind to: " + localAddress, future.getCause());
        }

        return channel;
    }
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
            if (!started) {
                // Open a selector if this worker didn't start yet.
                try {
                    this.selector = selector = Selector.open();
                } catch (Throwable t) {
                    throw new ChannelException(
                            "Failed to create a selector.", t);
                }

                // Start the worker thread with the new Selector.
                String threadName =
View Full Code Here
TOP

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

  • com.addthis.meshy.Meshy
  • com.flipkart.phantom.netty.uds.OioServerSocketChannel
  • org.helios.netty.examples.state.CustomServerBootstrap
  • org.infinispan.client.hotrod.TestHelper
  • org.jboss.netty.bootstrap.ConnectionlessBootstrap
  • org.jboss.netty.bootstrap.ServerBootstrap
  • org.jboss.netty.channel.local.DefaultLocalChannel
  • org.jboss.netty.channel.local.LocalClientChannelSink
  • org.jboss.netty.channel.local.LocalServerChannelSink
  • org.jboss.netty.channel.socket.DefaultDatagramChannelConfig
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.