| Index: src/org/adblockplus/brazil/SSLConnectionHandler.java |
| diff --git a/src/org/adblockplus/brazil/SSLConnectionHandler.java b/src/org/adblockplus/brazil/SSLConnectionHandler.java |
| index e6324be3609dd72a165e23a4ddbaba1b2288a1d6..09eb5d1177cb00fb6d19588fef189f145951ae78 100644 |
| --- a/src/org/adblockplus/brazil/SSLConnectionHandler.java |
| +++ b/src/org/adblockplus/brazil/SSLConnectionHandler.java |
| @@ -63,7 +63,7 @@ import sunlabs.brazil.util.MatchString; |
| public class SSLConnectionHandler extends BaseRequestHandler |
| { |
| @Override |
| - public boolean respond(Request request) throws IOException |
| + public boolean respond(final Request request) throws IOException |
| { |
| if (!request.method.equals("CONNECT")) |
| return false; |
| @@ -87,7 +87,7 @@ public class SSLConnectionHandler extends BaseRequestHandler |
| } |
| else |
| { |
| - int c = request.url.indexOf(':'); |
| + final int c = request.url.indexOf(':'); |
| host = request.url.substring(0, c); |
| port = Integer.parseInt(request.url.substring(c + 1)); |
| } |
| @@ -97,7 +97,7 @@ public class SSLConnectionHandler extends BaseRequestHandler |
| serverSocket.setKeepAlive(true); |
| serverSocket.connect(new InetSocketAddress(host, port)); |
| } |
| - catch (Exception e) |
| + catch (final Exception e) |
| { |
| request.sendError(500, "SSL connection failure"); |
| return true; |
| @@ -108,7 +108,7 @@ public class SSLConnectionHandler extends BaseRequestHandler |
| if (proxyHost != null) |
| { |
| // Forward request to upstream proxy |
| - OutputStream out = serverSocket.getOutputStream(); |
| + final OutputStream out = serverSocket.getOutputStream(); |
| out.write((request.method + " " + request.url + " " + request.protocol + "\r\n").getBytes()); |
| request.headers.print(out); |
| out.write("\r\n".getBytes()); |
| @@ -117,14 +117,14 @@ public class SSLConnectionHandler extends BaseRequestHandler |
| else |
| { |
| // Send response to client |
| - OutputStream out = request.sock.getOutputStream(); |
| + final OutputStream out = request.sock.getOutputStream(); |
| out.write((request.protocol + " 200 Connection established\r\n\r\n").getBytes()); |
| out.flush(); |
| } |
| // Start bi-directional data transfer |
| - ConnectionHandler client = new ConnectionHandler(request.sock, serverSocket); |
| - ConnectionHandler server = new ConnectionHandler(serverSocket, request.sock); |
| + final ConnectionHandler client = new ConnectionHandler(request.sock, serverSocket); |
| + final ConnectionHandler server = new ConnectionHandler(serverSocket, request.sock); |
| client.start(); |
| server.start(); |
| @@ -132,7 +132,7 @@ public class SSLConnectionHandler extends BaseRequestHandler |
| client.join(); |
| server.join(); |
| } |
| - catch (InterruptedException e) |
| + catch (final InterruptedException e) |
| { |
| request.log(Server.LOG_ERROR, prefix, "Data exchange error: " + e.getMessage()); |
| } |
| @@ -146,10 +146,10 @@ public class SSLConnectionHandler extends BaseRequestHandler |
| private class ConnectionHandler extends Thread |
| { |
| - private InputStream in; |
| - private OutputStream out; |
| + private final InputStream in; |
| + private final OutputStream out; |
| - ConnectionHandler(Socket sin, Socket sout) throws IOException |
| + ConnectionHandler(final Socket sin, final Socket sout) throws IOException |
| { |
| in = sin.getInputStream(); |
| out = sout.getOutputStream(); |
| @@ -158,7 +158,7 @@ public class SSLConnectionHandler extends BaseRequestHandler |
| @Override |
| public void run() |
| { |
| - byte[] buf = new byte[4096]; |
| + final byte[] buf = new byte[4096]; |
| int count; |
| try |
| @@ -169,7 +169,7 @@ public class SSLConnectionHandler extends BaseRequestHandler |
| } |
| out.flush(); |
| } |
| - catch (IOException e) |
| + catch (final IOException e) |
| { |
| e.printStackTrace(); |
| } |