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.1 by pjm2, Wed Nov 22 08:40:53 2000 UTC vs.
Revision 1.2 by tdb, Wed Nov 22 09:32:00 2000 UTC

# Line 1 | Line 1
1   import java.io.*;
2   import java.net.*;
3   import java.util.*;
4 + import uk.ac.ukc.iscream.core.*;
5 + import uk.ac.ukc.iscream.filter.*;
6  
7   // This class contains the main method to be run by
8   // the filter children.  It harvests UDP traffic.
# Line 10 | Line 12 | public class UDPReader extends Thread{
12  
13      // It is normal to use this constructor in preference
14      // to any other in this class.
15 <    public UDPReader(int port, Logger logger){
15 >    public UDPReader(int port, Filter parent, Logger logger){
16          this.logger = logger;
17          this.port = port;
18 +        this.parent = parent;
19      }
20      
21 <    public UDPReader(Logger logger){
22 <        this(4589, logger);
21 >    public UDPReader(Filter parent, Logger logger){
22 >        this(4589, parent, logger);
23      }
24  
25      public void run() {
# Line 45 | Line 48 | public class UDPReader extends Thread{
48                  // receive request
49                  DatagramPacket packet = new DatagramPacket(buf, buf.length);
50                  socket.receive(packet);
51 <                FilterThread t = new FilterThread();
51 >                FilterThread t = new FilterThread(parent);
52                  t.run(packet);
53              }
54              catch (IOException e) {
# Line 59 | Line 62 | public class UDPReader extends Thread{
62      
63      Logger logger;
64      int port;
65 <    
65 >    Filter parent;    
66 >
67      final int packetSizeLimit = 8192;
68      
69   }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines