From d8d3cfd60b7ebb81a9c602308e50f90d192c5d2e Mon Sep 17 00:00:00 2001 From: vibul Date: Thu, 15 Dec 2011 16:35:01 +1100 Subject: [PATCH] Format source code --- .../websocketx/autobahn/WebSocketServer.java | 14 +- .../autobahn/WebSocketServerHandler.java | 5 +- .../websocketx/client/WebSocketCallback.java | 61 +- .../client/WebSocketClientFactory.java | 7 +- .../client/WebSocketClientHandler.java | 5 +- .../websocketx/client/WebSocketException.java | 16 +- .../client/WebSocketHttpResponseDecoder.java | 42 +- .../websocketx/server/WebSocketServer.java | 14 +- .../server/WebSocketServerIndexPage.java | 103 ++-- .../sslserver/WebSocketSslServer.java | 16 +- .../WebSocketSslServerIndexPage.java | 103 ++-- .../WebSocketSslServerPipelineFactory.java | 8 +- .../WebSocketSslServerSslContext.java | 5 +- .../http/websocketx/BinaryWebSocketFrame.java | 70 ++- .../http/websocketx/CloseWebSocketFrame.java | 44 +- .../ContinuationWebSocketFrame.java | 206 ++++--- .../http/websocketx/PingWebSocketFrame.java | 70 +-- .../http/websocketx/PongWebSocketFrame.java | 68 +-- .../http/websocketx/TextWebSocketFrame.java | 178 +++--- .../codec/http/websocketx/UTF8Exception.java | 8 +- .../codec/http/websocketx/UTF8Output.java | 80 +-- .../websocketx/WebSocket00FrameDecoder.java | 172 +++--- .../websocketx/WebSocket00FrameEncoder.java | 121 ++-- .../websocketx/WebSocket08FrameDecoder.java | 565 +++++++++--------- .../websocketx/WebSocket08FrameEncoder.java | 198 +++--- .../websocketx/WebSocket13FrameDecoder.java | 27 +- .../websocketx/WebSocket13FrameEncoder.java | 24 +- .../websocketx/WebSocketClientHandshaker.java | 12 +- .../WebSocketClientHandshaker00.java | 19 +- .../WebSocketClientHandshaker08.java | 22 +- .../WebSocketClientHandshaker13.java | 20 +- .../WebSocketClientHandshakerFactory.java | 12 +- .../codec/http/websocketx/WebSocketFrame.java | 88 +-- .../http/websocketx/WebSocketFrameType.java | 2 +- .../WebSocketHandshakeException.java | 14 +- .../websocketx/WebSocketServerHandshaker.java | 268 +++++---- .../WebSocketServerHandshaker00.java | 259 ++++---- .../WebSocketServerHandshaker08.java | 46 +- .../WebSocketServerHandshaker13.java | 44 +- .../WebSocketServerHandshakerFactory.java | 19 +- .../http/websocketx/WebSocketVersion.java | 15 +- 41 files changed, 1524 insertions(+), 1546 deletions(-) diff --git a/src/main/java/org/jboss/netty/example/http/websocketx/autobahn/WebSocketServer.java b/src/main/java/org/jboss/netty/example/http/websocketx/autobahn/WebSocketServer.java index 8e5a2e357e..5bb3f67b12 100644 --- a/src/main/java/org/jboss/netty/example/http/websocketx/autobahn/WebSocketServer.java +++ b/src/main/java/org/jboss/netty/example/http/websocketx/autobahn/WebSocketServer.java @@ -25,8 +25,8 @@ import org.jboss.netty.bootstrap.ServerBootstrap; import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory; /** - * A Web Socket echo server for running the autobahn - * test suite + * A Web Socket echo server for running the autobahn test + * suite */ public class WebSocketServer { public static void main(String[] args) { @@ -34,19 +34,19 @@ public class WebSocketServer { ch.setLevel(Level.FINE); Logger.getLogger("").addHandler(ch); Logger.getLogger("").setLevel(Level.FINE); - + // Configure the server. ServerBootstrap bootstrap = new ServerBootstrap(new NioServerSocketChannelFactory( Executors.newCachedThreadPool(), Executors.newCachedThreadPool())); - - //bootstrap.setOption("child.tcpNoDelay", true); - + + // bootstrap.setOption("child.tcpNoDelay", true); + // Set up the event pipeline factory. bootstrap.setPipelineFactory(new WebSocketServerPipelineFactory()); // Bind and start to accept incoming connections. bootstrap.bind(new InetSocketAddress(9000)); - + System.out.println("Web Socket Server started on localhost:9000."); } } diff --git a/src/main/java/org/jboss/netty/example/http/websocketx/autobahn/WebSocketServerHandler.java b/src/main/java/org/jboss/netty/example/http/websocketx/autobahn/WebSocketServerHandler.java index 8a3b9620cf..dd6bd9b002 100644 --- a/src/main/java/org/jboss/netty/example/http/websocketx/autobahn/WebSocketServerHandler.java +++ b/src/main/java/org/jboss/netty/example/http/websocketx/autobahn/WebSocketServerHandler.java @@ -90,8 +90,9 @@ public class WebSocketServerHandler extends SimpleChannelUpstreamHandler { ctx.getChannel().write( new PongWebSocketFrame(frame.isFinalFragment(), frame.getRsv(), frame.getBinaryData())); } else if (frame instanceof TextWebSocketFrame) { - //String text = ((TextWebSocketFrame) frame).getText(); - ctx.getChannel().write(new TextWebSocketFrame(frame.isFinalFragment(), frame.getRsv(), frame.getBinaryData())); + // String text = ((TextWebSocketFrame) frame).getText(); + ctx.getChannel().write( + new TextWebSocketFrame(frame.isFinalFragment(), frame.getRsv(), frame.getBinaryData())); } else if (frame instanceof BinaryWebSocketFrame) { ctx.getChannel().write( new BinaryWebSocketFrame(frame.isFinalFragment(), frame.getRsv(), frame.getBinaryData())); diff --git a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketCallback.java b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketCallback.java index 5953c73e68..24ece03b93 100644 --- a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketCallback.java +++ b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketCallback.java @@ -24,7 +24,6 @@ package org.jboss.netty.example.http.websocketx.client; import org.jboss.netty.handler.codec.http.websocketx.WebSocketFrame; - /** * Copied from https://github.com/cgbystrom/netty-tools * @@ -32,37 +31,37 @@ import org.jboss.netty.handler.codec.http.websocketx.WebSocketFrame; */ public interface WebSocketCallback { - /** - * Called when the client is connected to the server - * - * @param client - * Current client used to connect - */ - void onConnect(WebSocketClient client); + /** + * Called when the client is connected to the server + * + * @param client + * Current client used to connect + */ + void onConnect(WebSocketClient client); - /** - * Called when the client got disconnected from the server. - * - * @param client - * Current client that was disconnected - */ - void onDisconnect(WebSocketClient client); + /** + * Called when the client got disconnected from the server. + * + * @param client + * Current client that was disconnected + */ + void onDisconnect(WebSocketClient client); - /** - * Called when a message arrives from the server. - * - * @param client - * Current client connected - * @param frame - * Data received from server - */ - void onMessage(WebSocketClient client, WebSocketFrame frame); + /** + * Called when a message arrives from the server. + * + * @param client + * Current client connected + * @param frame + * Data received from server + */ + void onMessage(WebSocketClient client, WebSocketFrame frame); - /** - * Called when an unhandled errors occurs. - * - * @param t - * The causing error - */ - void onError(Throwable t); + /** + * Called when an unhandled errors occurs. + * + * @param t + * The causing error + */ + void onError(Throwable t); } diff --git a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientFactory.java b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientFactory.java index 73184e3566..ef00c4a3d6 100644 --- a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientFactory.java +++ b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientFactory.java @@ -38,8 +38,8 @@ import java.util.concurrent.Executors; /** * Copied from https://github.com/cgbystrom/netty-tools * - * A factory for creating WebSocket clients. The entry point for creating and - * connecting a client. Can and should be used to create multiple instances. + * A factory for creating WebSocket clients. The entry point for creating and connecting a client. Can and should be + * used to create multiple instances. */ public class WebSocketClientFactory { @@ -57,8 +57,7 @@ public class WebSocketClientFactory { * Callback interface to receive events * @param customHeaders * Map of custom headers to add to the client request - * @return A WebSocket client. Call {@link WebSocketClient#connect()} to - * connect. + * @return A WebSocket client. Call {@link WebSocketClient#connect()} to connect. */ public WebSocketClient newClient(final URI url, final WebSocketVersion version, final WebSocketCallback callback, final Map customHeaders) { diff --git a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientHandler.java b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientHandler.java index 61ba90d7c7..0fb396cc4a 100644 --- a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientHandler.java +++ b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketClientHandler.java @@ -44,9 +44,8 @@ import org.jboss.netty.util.CharsetUtil; /** * Copied from https://github.com/cgbystrom/netty-tools * - * Handles socket communication for a connected WebSocket client Not intended - * for end-users. Please use {@link WebSocketClient} or - * {@link WebSocketCallback} for controlling your client. + * Handles socket communication for a connected WebSocket client Not intended for end-users. Please use + * {@link WebSocketClient} or {@link WebSocketCallback} for controlling your client. */ public class WebSocketClientHandler extends SimpleChannelUpstreamHandler implements WebSocketClient { diff --git a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketException.java b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketException.java index 3f7280bc4d..91762218fa 100644 --- a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketException.java +++ b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketException.java @@ -30,15 +30,15 @@ import java.io.IOException; */ public class WebSocketException extends IOException { - /** + /** */ - private static final long serialVersionUID = 1L; + private static final long serialVersionUID = 1L; - public WebSocketException(String s) { - super(s); - } + public WebSocketException(String s) { + super(s); + } - public WebSocketException(String s, Throwable throwable) { - super(s, throwable); - } + public WebSocketException(String s, Throwable throwable) { + super(s, throwable); + } } \ No newline at end of file diff --git a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketHttpResponseDecoder.java b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketHttpResponseDecoder.java index 745b9126d6..21cef9a313 100644 --- a/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketHttpResponseDecoder.java +++ b/src/main/java/org/jboss/netty/example/http/websocketx/client/WebSocketHttpResponseDecoder.java @@ -25,27 +25,27 @@ import org.jboss.netty.handler.codec.http.HttpResponseDecoder; */ public class WebSocketHttpResponseDecoder extends HttpResponseDecoder { - @Override - protected boolean isContentAlwaysEmpty(HttpMessage msg) { - if (msg instanceof HttpResponse) { - HttpResponse res = (HttpResponse) msg; - int code = res.getStatus().getCode(); + @Override + protected boolean isContentAlwaysEmpty(HttpMessage msg) { + if (msg instanceof HttpResponse) { + HttpResponse res = (HttpResponse) msg; + int code = res.getStatus().getCode(); - // FIX force reading of protocol upgrade challenge data into the content buffer - if (code == 101) { - return false; - } + // FIX force reading of protocol upgrade challenge data into the content buffer + if (code == 101) { + return false; + } - if (code < 200) { - return true; - } - switch (code) { - case 204: - case 205: - case 304: - return true; - } - } - return false; - } + if (code < 200) { + return true; + } + switch (code) { + case 204: + case 205: + case 304: + return true; + } + } + return false; + } } diff --git a/src/main/java/org/jboss/netty/example/http/websocketx/server/WebSocketServer.java b/src/main/java/org/jboss/netty/example/http/websocketx/server/WebSocketServer.java index 81a85a5930..e08333ac6e 100644 --- a/src/main/java/org/jboss/netty/example/http/websocketx/server/WebSocketServer.java +++ b/src/main/java/org/jboss/netty/example/http/websocketx/server/WebSocketServer.java @@ -29,11 +29,10 @@ import org.jboss.netty.channel.socket.nio.NioServerSocketChannelFactory; * * http://localhost:8080/websocket * - * Open your browser at http://localhost:8080/, then the demo page will be - * loaded and a Web Socket connection will be made automatically. + * Open your browser at http://localhost:8080/, then the demo page will be loaded and a Web Socket connection will be + * made automatically. * - * This server illustrates support for the different web socket specification - * versions and will work with: + * This server illustrates support for the different web socket specification versions and will work with: * *