ViewVC Help
View File | Revision Log | Show Annotations | Revision Graph | Root Listing
root/i-scream/projects/cms/source/server/uk/org/iscream/cms/server/filter/UDPReader.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/filter/UDPReader.java (file contents):
Revision 1.6 by tdb, Wed Nov 29 19:26:00 2000 UTC vs.
Revision 1.12 by tdb, Fri Jan 12 00:45:25 2001 UTC

# Line 7 | Line 7 | import java.net.*;
7   import java.util.*;
8   import uk.ac.ukc.iscream.core.*;
9   import uk.ac.ukc.iscream.filter.*;
10 + import uk.ac.ukc.iscream.util.*;
11  
12   /**
13   * This class contains the main method to be run by
# Line 23 | Line 24 | public class UDPReader extends Thread{
24       * The current CVS revision of this class
25       */
26      public final String REVISION = "$Revision$";
27 +
28 +    /**
29 +     * The maximum size of a packet
30 +     */
31 +    private final int packetSizeLimit = 8192;  
32      
33   //---STATIC METHODS---
34  
35   //---CONSTRUCTORS---
36  
37 <    // It is normal to use this constructor in preference
38 <    // to any other in this class.
39 <    public UDPReader(int port, Filter parent, Logger logger){
40 <        this.logger = logger;
41 <        this.port = port;
42 <        this.parent = parent;
37 >    /**
38 >     * It is normal to use this constructor in preference
39 >     * to any other in this class.
40 >     */
41 >    public UDPReader(int port, Queue queue){
42 >        _port = port;
43 >        _queue = queue;
44      }
38 –    
39 –    public UDPReader(Filter parent, Logger logger){
40 –        this(4589, parent, logger);
41 –    }
45  
46   //---PUBLIC METHODS---
47  
# Line 46 | Line 49 | public class UDPReader extends Thread{
49  
50          DatagramSocket socket = null;
51          try {
52 <            socket = new DatagramSocket(port);
52 >            socket = new DatagramSocket(_port);
53          }
54          catch (BindException e){
55 <            logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+port+" as this port was already in use.");
55 >            _logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+_port+" as this port was already in use.");
56              return;
57          }
58          catch (Exception e){
59 <            logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+port+".");
59 >            _logger.write(this.toString(), Logger.FATAL, "Could not start the UDPReader thread on port "+_port+".");
60              return;
61          }
62          
63 <        logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+port);
63 >        _logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+_port);
64  
65          byte[] buf;
66          
# Line 65 | Line 68 | public class UDPReader extends Thread{
68          while (running){
69              try {
70  
71 <                    // receive request and pass on to the FilterThread.                
71 >                    // receive request and put it in the Queue              
72                  buf = new byte[packetSizeLimit];
73                  DatagramPacket packet = new DatagramPacket(buf, buf.length);
74                  socket.receive(packet);
75 <                FilterThread t = new FilterThread(packet, parent, logger);
76 <                t.start();
74 <
75 >                String xml = new String(packet.getData());
76 >                _queue.add(xml);
77              }
78              catch (IOException e) {
79 <                logger.write(this.toString(), Logger.WARNING, "This UDPReader thread has been shut down as an exception occured: "+e);
79 >                _logger.write(this.toString(), Logger.WARNING, "This UDPReader thread has been shut down as an exception occured: "+e);
80                  return;
81              }
82          }
# Line 85 | Line 87 | public class UDPReader extends Thread{
87       * Overrides the {@link java.lang.Object#toString() Object.toString()}
88       * method to provide clean logging (every class should have this).
89       *
90 +     * This uses the uk.ac.ukc.iscream.util.NameFormat class
91 +     * to format the toString()
92 +     *
93       * @return the name of this class and its CVS revision
94       */
95      public String toString() {
96 <        return this.getClass().getName() + "(" + REVISION.substring(11, REVISION.length() - 2) + ")";
96 >        return FormatName.getName(
97 >            _name,
98 >            getClass().getName(),
99 >            REVISION);
100      }
101  
102   //---PRIVATE METHODS---
# Line 97 | Line 105 | public class UDPReader extends Thread{
105  
106   //---ATTRIBUTES---
107  
108 <    Logger logger;
109 <    int port;
110 <    Filter parent;    
108 >    /**
109 >     * This is the friendly identifier of the
110 >     * component this class is running in.
111 >     * eg, a Filter may be called "filter1",
112 >     * If this class does not have an owning
113 >     * component,  a name from the configuration
114 >     * can be placed here.  This name could also
115 >     * be changed to null for utility classes.
116 >     */
117 >    private String _name = FilterMain.NAME;
118  
119 <    final int packetSizeLimit = 8192;
119 >    /**
120 >     * This holds a reference to the
121 >     * system logger that is being used.
122 >     */
123 >    private Logger _logger = ReferenceManager.getInstance().getLogger();
124 >    
125 >    /**
126 >     * The port that this reader is using
127 >     */
128 >    int _port;
129 >    
130 >    /**
131 >     * The Queue object
132 >     */
133 >    Queue _queue;    
134  
135   //---STATIC ATTRIBUTES---
136  

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines