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.14 by tdb, Sun Jan 28 05:34:38 2001 UTC vs.
Revision 1.15 by tdb, Thu Feb 1 00:18:42 2001 UTC

# Line 25 | Line 25 | public class UDPReader extends Thread{
25       * The current CVS revision of this class
26       */
27      public final String REVISION = "$Revision$";
28 <
28 >    
29      /**
30       * The maximum size of a packet
31       */
# Line 44 | Line 44 | public class UDPReader extends Thread{
44      public UDPReader(int port, Queue queue){
45          _port = port;
46          _queue = queue;
47 +        _logger.write(toString(), Logger.SYSINIT, "started");
48      }
49  
50   //---PUBLIC METHODS---
# Line 69 | Line 70 | public class UDPReader extends Thread{
70          }
71          
72          _logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+_port);
73 <
73 >        
74          byte[] buf;
75          
76          // read UDP packets and queue them
77          boolean running = true;
78          while (running){
79              try {
80 <
81 <                    // receive request and put it in the Queue              
80 >                
81 >                // receive request and put it in the Queue              
82                  buf = new byte[packetSizeLimit];
83                  DatagramPacket packet = new DatagramPacket(buf, buf.length);
84                  socket.receive(packet);
# Line 91 | Line 92 | public class UDPReader extends Thread{
92          }
93          socket.close();
94      }
95 <
95 >    
96      /**
97       * Overrides the {@link java.lang.Object#toString() Object.toString()}
98       * method to provide clean logging (every class should have this).
# Line 124 | Line 125 | public class UDPReader extends Thread{
125       * be changed to null for utility classes.
126       */
127      private String _name = FilterMain.NAME;
128 <
128 >    
129      /**
130       * This holds a reference to the
131       * system logger that is being used.
# Line 139 | Line 140 | public class UDPReader extends Thread{
140      /**
141       * The Queue object
142       */
143 <    Queue _queue;    
143 >    Queue _queue;
144  
145   //---STATIC ATTRIBUTES---
146  

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines