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.18 by tdb, Tue May 29 17:02:35 2001 UTC

# Line 1 | Line 1
1   //---PACKAGE DECLARATION---
2 < package uk.ac.ukc.iscream.filter;
2 > package uk.org.iscream.cms.server.filter;
3  
4   //---IMPORTS---
5   import java.io.*;
6   import java.net.*;
7   import java.util.*;
8 < import uk.ac.ukc.iscream.core.*;
9 < import uk.ac.ukc.iscream.componentmanager.*;
10 < import uk.ac.ukc.iscream.filter.*;
11 < import uk.ac.ukc.iscream.util.*;
8 > import uk.org.iscream.cms.server.core.*;
9 > import uk.org.iscream.cms.server.componentmanager.*;
10 > import uk.org.iscream.cms.server.filter.*;
11 > import uk.org.iscream.cms.server.util.*;
12  
13   /**
14   * This class contains the main method to be run by
# 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 42 | Line 42 | public class UDPReader extends Thread{
42       * @param queue The queue which we are using
43       */
44      public UDPReader(int port, Queue queue){
45 +        // set the Thread name
46 +        setName("filter.UDPReader");
47 +        
48          _port = port;
49          _queue = queue;
50 +        _logger.write(toString(), Logger.SYSINIT, "started");
51      }
52  
53   //---PUBLIC METHODS---
# Line 69 | Line 73 | public class UDPReader extends Thread{
73          }
74          
75          _logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+_port);
76 <
76 >        
77          byte[] buf;
78          
79          // read UDP packets and queue them
80          boolean running = true;
81          while (running){
82              try {
83 <
84 <                    // receive request and put it in the Queue              
83 >                
84 >                // receive request and put it in the Queue              
85                  buf = new byte[packetSizeLimit];
86                  DatagramPacket packet = new DatagramPacket(buf, buf.length);
87                  socket.receive(packet);
# Line 91 | Line 95 | public class UDPReader extends Thread{
95          }
96          socket.close();
97      }
98 <
98 >    
99      /**
100       * Overrides the {@link java.lang.Object#toString() Object.toString()}
101       * method to provide clean logging (every class should have this).
102       *
103 <     * This uses the uk.ac.ukc.iscream.util.NameFormat class
103 >     * This uses the uk.org.iscream.cms.server.util.NameFormat class
104       * to format the toString()
105       *
106       * @return the name of this class and its CVS revision
# Line 124 | Line 128 | public class UDPReader extends Thread{
128       * be changed to null for utility classes.
129       */
130      private String _name = FilterMain.NAME;
131 <
131 >    
132      /**
133       * This holds a reference to the
134       * system logger that is being used.
# Line 139 | Line 143 | public class UDPReader extends Thread{
143      /**
144       * The Queue object
145       */
146 <    Queue _queue;    
146 >    Queue _queue;
147  
148   //---STATIC ATTRIBUTES---
149  

Diff Legend

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