]> gb7djk.dxcluster.net Git - spider.git/blob - SpiderConsole/src/PipedOutputMUX.java
more UPGRADE mods.
[spider.git] / SpiderConsole / src / PipedOutputMUX.java
1 /**
2  * OutputStreamMultiplexor 
3  * Takes one output stream and sends it to multiple output streams.
4  * @author Ian Norton
5  * @version 1.0 - 20010418.
6  *
7  * Copyright (C) 2001 Ian Norton.
8  *
9  * This program is free software; you can redistribute it and/or modify
10  * it under the terms of the GNU General Public Licence as published by
11  * the Free Software Foundation; either version 2 of the Licence, or
12  * (at your option) any later version.
13  *
14  * This program is distributed in the hope that it will be useful,
15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
17  * GNU General Public Licence for more details.
18  *
19  * You should have received a copy of the GNU General Public Licence
20  * along with this program; if not, write to the Free Software
21  * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
22  *
23  * Contacting the author :
24  * Ian Norton
25  * i.norton@lancaster.ac.uk
26  * http://www.lancs.ac.uk/~norton/
27  **/
28
29 import java.io.* ;
30 import java.util.Vector ;
31 import java.util.Enumeration ;
32 import java.util.Calendar ;
33
34 class PipedOutputMUX implements Runnable
35     {
36     public static final boolean DEBUG = false ;
37     public static final String encoding = "latin1"; // "ISO8859_1";
38     
39     private PipedInputStream pin ;
40     private Vector streams ;
41
42     private Thread t ;
43     
44     /**
45      * PipedOutputMUX initialiser
46      * @param PipedOutputStream i - Source stream
47      **/
48     public PipedOutputMUX(PipedInputStream i)
49         {
50         pin = i ;
51          
52         // Streams Vector holds all the OutputStreams we know about.
53         streams = new Vector() ;
54
55         // Initialise and start the thread.
56         t = new Thread(this, "OutputMultiplexor") ;
57         t.start() ;
58         }
59
60     /**
61      * addOutputStream
62      * @param PipedOutputStream po - add a stream to send output to.
63      **/
64     public void addOutputStream(PipedOutputStream po)
65         {
66         // Add the supplied stream to the vector of streams.
67         streams.addElement(po) ;
68         }
69
70     /**
71      * run - Thread run method.
72      **/
73     public void run()
74         {
75         // Loop continually reading the input stream.
76         while(true)
77             {
78             try
79                 {
80                 byte[] b = new byte[16];
81
82                 // Read a line and see if it has any data in it.
83                 int n = 0;
84
85                 // Trying to read
86                 while(pin.available() > 0)
87                     {
88                     int rdb = pin.available() ;
89                     if(rdb > 16) rdb = 16 ;
90                     n = pin.read(b, 0, rdb);
91
92                     if(n > 0)
93                         {
94                         // Convert the output to a string and send it.
95                         String output = new String(b, 0, n, encoding) ;
96                         if(DEBUG) System.out.println(output) ;
97                         send(output) ;
98                         }
99                     }
100                 }
101             catch(IOException ex)
102                 {
103                 System.out.println("PipedOutputMUX: IOException trying to read.") ;
104                 System.exit(1) ;
105                 }
106             } // End of loop
107         } // End of run()
108
109     /**
110      * send
111      * @param String s - string to send to all streams.
112      **/
113     private void send(String s)
114         {
115         // Calendar cal = Calendar.getInstance() ;
116         // if(DEBUG) System.out.println("PipedOutputMUX: " + cal.getTime() + " Send called with :" + s) ;
117
118         // If we have no streams, then we can't do anything.
119         if(streams.size() == 0) return ;
120         
121         // Create Enumeration object to enumerate with :-)
122         Enumeration e = streams.elements() ;
123
124         // Go through the enumeration and send the string to each stream.
125         while(e.hasMoreElements())
126             {
127             PipedOutputStream os = (PipedOutputStream)e.nextElement() ;
128
129             try
130                 {
131                 // Write the data to the stream.
132                 for(int i=0;i<s.length();i++)
133                     {
134                     os.write(s.charAt(i)) ;
135                     os.flush() ;
136                     }
137                 }
138             catch(IOException ex)
139                 {
140                 // If we get an IO exception, then the other end of the pipe
141                 // has been closed.  We need to remove this stream.
142                 streams.removeElement(os) ;
143                 System.out.println("IOException - stream removed.") ;
144                 }
145             }
146         }
147
148     } // End of class.