Proxy configurators

src/org/adblockplus/brazil/RequestHandler.java

 /*
  * This file is part of Adblock Plus <http://adblockplus.org/>,
  * Copyright (C) 2006-2014 Eyeo GmbH
  *
  * Adblock Plus is free software: you can redistribute it and/or modify
  * it under the terms of the GNU General Public License version 3 as
  * published by the Free Software Foundation.
  *
  * Adblock Plus is distributed in the hope that it will be useful,
  * but WITHOUT ANY WARRANTY; without even the implied warranty of
@@ skipping 11 matching lines @@
 import java.io.FilterOutputStream;
 import java.io.IOException;
 import java.io.InterruptedIOException;
 import java.io.OutputStream;
 import java.net.ConnectException;
 import java.net.MalformedURLException;
 import java.net.URL;
 import java.net.UnknownHostException;
 import java.nio.charset.Charset;
 import java.util.List;
+import java.util.concurrent.atomic.AtomicLong;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 import java.util.zip.GZIPInputStream;
 import java.util.zip.InflaterInputStream;
 
 import org.adblockplus.ChunkedOutputStream;
 import org.adblockplus.android.AdblockPlus;
 import org.apache.commons.lang.StringUtils;
 import org.literateprograms.BoyerMoore;
 
@@ skipping 37 matching lines @@
  * See the description under {@link sunlabs.brazil.server.Handler#respond
  * respond} for a more detailed explanation.
  */
 
 public class RequestHandler extends BaseRequestHandler
 {
   private AdblockPlus application;
   private String via;
   private static final Pattern RE_HTTP = Pattern.compile("^https?:");
 
+  private static final AtomicLong BLOCKED_REQUESTS = new AtomicLong();
+  private static final AtomicLong UNBLOCKED_REQUESTS = new AtomicLong();
+
+  public static long getBlockedRequestCount()
+  {
+    return BLOCKED_REQUESTS.get();
+  }
+
+  public static long getUnblockedRequestCount()
+  {
+    return UNBLOCKED_REQUESTS.get();
+  }
+
   @Override
   public boolean init(final Server server, final String prefix)
   {
     super.init(server, prefix);
 
     application = AdblockPlus.getApplication();
     via = " " + server.hostName + ":" + server.listen.getLocalPort() + " (" + server.name + ")";
 
     return true;
   }
@@ skipping 10 matching lines @@
     catch (final Exception e)
     {
       Log.e(prefix, "Filter error", e);
     }
 
     request.log(Server.LOG_LOG, prefix, block + ": " + request.url);
 
     int count = request.server.requestCount;
     if (shouldLogHeaders)
     {
+      // FIXME Don't log to "err"
       System.err.println(dumpHeaders(count, request, request.headers, true));
     }
 
     if (block)
     {
       request.sendHeaders(204, null, 0);
+      BLOCKED_REQUESTS.incrementAndGet();
       return true;
     }
 
+    UNBLOCKED_REQUESTS.incrementAndGet();
+
     // Do not further process non-http requests
     if (!RE_HTTP.matcher(request.url).find())
     {
       return false;
     }
 
     String url = request.url;
 
     if ((request.query != null) && (request.query.length() > 0))
     {
@@ skipping 246 matching lines @@
       request.sendError(500, msg);
       Log.e(prefix, msg, e);
     }
     finally
     {
       target.close();
     }
     return true;
   }
 }