X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=SpiderConsole%2Fsrc%2FConnectionOutput.java;fp=SpiderConsole%2Fsrc%2FConnectionOutput.java;h=fcf4f0da790ff5ad2205a80e0975b0a22b2aa486;hb=1540d1ee26801546ad652653951bbc25744d85a0;hp=0000000000000000000000000000000000000000;hpb=5e145358734eabf8855fb2b4c1daabcc55bd9da0;p=spider.git

diff --git a/SpiderConsole/src/ConnectionOutput.java b/SpiderConsole/src/ConnectionOutput.java
new file mode 100644
index 00000000..fcf4f0da
--- /dev/null
+++ b/SpiderConsole/src/ConnectionOutput.java
@@ -0,0 +1,157 @@
+/**
+ * ConnectionOutput - reads from the pipe and writes data to the socket.
+ * @author Ian Norton
+ * @version 1.00 - 20010418.
+ *
+ * Copyright (C) 2001 Ian Norton.
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public Licence as published by
+ * the Free Software Foundation; either version 2 of the Licence, 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 Licence for more details.
+ *
+ * You should have received a copy of the GNU General Public Licence
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ *
+ * Contacting the author :
+ * Ian Norton
+ * i.norton@lancaster.ac.uk
+ * http://www.lancs.ac.uk/~norton/
+ **/
+
+import java.io.* ;
+import java.net.* ;
+
+class ConnectionOutput implements Runnable
+    {
+    // Debug me bugs
+    public static final boolean DEBUG = false ;
+    
+    // Data streams.
+    private OutputStream os ;
+    private PipedInputStream pin ;
+
+    // Connection object that created us.
+    private Connection connection ;
+
+    // Connection status.
+    private boolean disconnected ;
+    
+    // Thread to run the read code in.
+    private Thread t ;
+
+    // Encoding string.
+    public static final String encoding = "latin1"; // "ISO8859_1";   
+
+    /**
+     * ConnectionOutput
+     * @param OutputStream - OutputStream to the socket to write to
+     * @param PipedInputStream - Read data from here
+     * @param Connection - the object that created us                           
+     **/
+    public ConnectionOutput(PipedInputStream p, Connection c)
+        {
+        // Initialise the streams & connection
+        pin = p ;
+        connection = c ;
+
+        disconnected = true ;
+        }
+
+    /**
+     * disconnect - disconnect the current connection.
+     **/                                                                        
+    public void disconnect()
+        {
+        if(!disconnected)
+            {
+            if(DEBUG) System.out.println("ConnectionOutput: disconnect()") ;
+
+            disconnected = true ;
+            connection.disconnect() ;
+            }
+        }
+
+    /**
+     * start - begin reading.  Called when a connect has been achieved.
+     **/
+    public void start(OutputStream o)
+        {
+        os = o ;
+
+        disconnected = false ;
+
+        // Test to see if the thread has been inititialised.
+        if(t == null) ;
+            {
+            if(DEBUG) System.out.println("ConnectionOutput: Creating thread.") ;
+
+            // Initialise the thread to read data & start it.
+            t = new Thread(this, "Connection") ;
+            t.start() ;
+            }
+        }
+
+    /**
+     * Thread run method.
+     **/
+    public void run()
+        {
+        byte[] b = new byte[16];
+
+        // Loop reading data.
+        while(true)
+            {
+            try
+                {
+                // Read from PipedInputStream and write to OutputStream
+                int n = 0;
+
+                // Read that many bytes and return.
+                n = pin.read(b);
+
+                // If disconnected read and disguard data or the MUX dies.
+                if(n > 0 && !disconnected)
+                    {
+                    String output = new String(b, 0, n, encoding) ;
+                    send(output) ;
+                    }                                                   
+                }
+            catch(IOException ex)
+                {
+                System.out.println("ConnectionOutput: IOException reading data from multiplexor.") ;
+                System.exit(1) ;
+                }
+            } // End while(true)
+        } // End run()
+
+    /**
+     * send
+     * @param String s - string to send to destination stream.
+     **/
+    private void send(String s)
+        {
+        if(DEBUG) System.out.println("ConnectionOutput: Send called : " + s) ;
+        try
+            {
+            // Write the data to the stream.
+            for(int i=0;i<s.length();i++)
+                {
+                os.write(s.charAt(i)) ;
+                os.flush() ;
+                }
+            }
+        catch(IOException ex)
+            {
+            System.out.println("ConnectionOutput:  IOException writing to socket.") ;
+            System.exit(1) ;
+            }                                                                   
+        }
+    } // End class
+