Initial checkin of directory structure and source code of the java Activity

[privoxy.git] / src / java / org / privoxy / activityconsole / ServerThread.java

diff --git a/src/java/org/privoxy/activityconsole/ServerThread.java b/src/java/org/privoxy/activityconsole/ServerThread.java
new file mode 100644 (file)
index 0000000..2748e7b
--- /dev/null
+++ b/src/java/org/privoxy/activityconsole/ServerThread.java
@@ -0,0 +1,130 @@
+/*********************************************************************
+ *
+ * File        :  $Source$
+ *
+ * Purpose     :  Listen on a specified port for status updates from
+ *                Privoxy.  If we get a suitable update, pass it along
+ *                to the GUI for processing.  We need to handle getting
+ *                shut down and restarting on another port gracefully.
+ *
+ * Copyright   :  Written by and Copyright (C) 2003 the SourceForge
+ *                Privoxy team. http://www.privoxy.org/
+ *
+ *                Based on the Internet Junkbuster originally written
+ *                by and Copyright (C) 1997 Anonymous Coders and
+ *                Junkbusters Corporation.  http://www.junkbusters.com
+ *
+ *                This program is free software; you can redistribute it
+ *                and/or modify it under the terms of the GNU General
+ *                Public License as published by the Free Software
+ *                Foundation; either version 2 of the License, or (at
+ *                your option) any later version.
+ *
+ *                This program is distributed in the hope that it will
+ *                be useful, but WITHOUT ANY WARRANTY; without even the
+ *                implied warranty of MERCHANTABILITY or FITNESS FOR A
+ *                PARTICULAR PURPOSE.  See the GNU General Public
+ *                License for more details.
+ *
+ *                The GNU General Public License should be included with
+ *                this file.  If not, you can view it at
+ *                http://www.gnu.org/copyleft/gpl.html
+ *                or write to the Free Software Foundation, Inc., 59
+ *                Temple Place - Suite 330, Boston, MA  02111-1307, USA.
+ *
+ * Revisions   :
+ *    $Log$
+ *********************************************************************/
+
+package org.privoxy.activityconsole;
+
+import java.net.*;
+import java.io.*;
+import java.text.*;
+import java.util.*;
+import javax.swing.*;
+
+/** 
+ * Listens on a specified port for status updates from Privoxy. 
+ * @author Last Modified By: $Author$
+ * @version $Rev$-$Date$$State$
+ */
+public class ServerThread extends Thread
+{
+  private static final String
+    COPYRIGHT = org.privoxy.activityconsole.Copyright.COPYRIGHT;
+
+  static ActivityConsoleGui _parent;
+  static int _port;
+  static ServerSocket _serverSocket;
+
+  public ServerThread(ActivityConsoleGui parent, int thePort)
+  {
+    _parent = parent;
+    _port = thePort;
+  }
+
+  public void run()
+  {
+    try
+    {
+      _serverSocket = new ServerSocket(_port);        
+      try
+      {
+        // System.out.println( "ServerThread serving port "+_port+"." );
+        boolean shouldRun = true;
+        while (shouldRun)
+        {
+          Socket theSocket = _serverSocket.accept();
+          if (!Thread.currentThread().interrupted())
+          {
+            BufferedReader in = 
+            new BufferedReader(new InputStreamReader(theSocket.getInputStream()));
+            String line = in.readLine();
+            /* Ensure the line isn't null and it's not way, way too long... */
+            if ((line != null) && (line.length() < 65536))
+            {
+              _parent.updateStats(line,theSocket.getInetAddress().getHostName());
+            }
+            in.close();
+            theSocket.close();
+          }
+          else
+          {
+            shouldRun = false;
+          }
+        }
+        _serverSocket.close();
+        _serverSocket = null;
+      }
+      catch (IOException io)
+      {
+        try
+        {
+          _serverSocket.close();
+          _serverSocket = null;
+        }
+        catch (IOException fred)
+        {
+          _serverSocket = null;
+        }
+      }
+    }
+    catch (IOException io)
+    {
+      System.err.println(io);
+      JOptionPane.showMessageDialog(null, io, "Alert: port "+_port, JOptionPane.ERROR_MESSAGE);
+    }
+  }
+
+  public void doClose()
+  {
+    try
+    {
+      _serverSocket.close();
+    }
+    catch (IOException fred)
+    {
+    }
+  }
+}