server/XMLReader/UDPReader.java

import java.io.*;
import java.net.*;
import java.util.*;

// This class contains the main method to be run by
// the filter children.  It harvests UDP traffic.
//
//
public class UDPReader extends Thread{

    // It is normal to use this constructor in preference
    // to any other in this class.
    public UDPReader(int port, Logger logger){
        this.logger = logger;
        this.port = port;
    }
    
    public UDPReader(Logger logger){
        this(4589, logger);
    }

    public void run() {

        DatagramSocket socket = null;
        try {
            socket = new DatagramSocket(port);
        }
        catch (BindException e){
            logger.write(this.toString(), Logger.SYSMSG, "Could not start the UDPReader thread on port "+port+" as this port was already in use.");
            return;
        }
        catch (Exception e){
            logger.write(this.toString(), Logger.SYSMSG, "Could not start the UDPReader thread on port "+port+".");
            return;
        }
        
        logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+port);

        byte[] buf;
        
        boolean running = true;
        while (running){
            try {
                buf = new byte[packetSizeLimit];
                // receive request
                DatagramPacket packet = new DatagramPacket(buf, buf.length);
                socket.receive(packet);
                UDPReaderThread t = new UDPReaderThread();
                t.run(packet);
            }
            catch (IOException e) {
                logger.write(this.toString(), Logger.SYSMSG, "The UDPReader thread has been shut down as an exception occured: "+e);
                return;
            }
        }
        socket.close();
    }
    
    
    Logger logger;
    int port;
    
    final int packetSizeLimit = 8192;
    
}
Revision:	1.8
Committed:	Tue Nov 21 10:11:21 2000 UTC (24 years ago) by pjm2
Branch:	MAIN
Changes since 1.7:	+5 -6 lines
Log Message:	Added logging features.
#	User	Rev	Content
1	pjm2	1.1	import java.io.*;
2			import java.net.*;
3			import java.util.*;
4
5			// This class contains the main method to be run by
6	pjm2	1.6	// the filter children. It harvests UDP traffic.
7	pjm2	1.1	//
8			//
9	pjm2	1.6	public class UDPReader extends Thread{
10	pjm2	1.1
11	pjm2	1.6	// It is normal to use this constructor in preference
12			// to any other in this class.
13			public UDPReader(int port, Logger logger){
14			this.logger = logger;
15			this.port = port;
16			}
17
18			public UDPReader(Logger logger){
19			this(4589, logger);
20			}
21	pjm2	1.1
22	pjm2	1.6	public void run() {
23	pjm2	1.2
24	pjm2	1.3	DatagramSocket socket = null;
25			try {
26			socket = new DatagramSocket(port);
27			}
28			catch (BindException e){
29	pjm2	1.8	logger.write(this.toString(), Logger.SYSMSG, "Could not start the UDPReader thread on port "+port+" as this port was already in use.");
30	pjm2	1.6	return;
31			}
32			catch (Exception e){
33	pjm2	1.8	logger.write(this.toString(), Logger.SYSMSG, "Could not start the UDPReader thread on port "+port+".");
34	pjm2	1.6	return;
35	pjm2	1.3	}
36
37	pjm2	1.8	logger.write(this.toString(), Logger.SYSMSG, "UDPReader thread ready and listening for UDP packets on port "+port);
38	pjm2	1.2
39	pjm2	1.4	byte[] buf;
40
41	pjm2	1.2	boolean running = true;
42			while (running){
43			try {
44	pjm2	1.4	buf = new byte[packetSizeLimit];
45	pjm2	1.1	// receive request
46	pjm2	1.2	DatagramPacket packet = new DatagramPacket(buf, buf.length);
47			socket.receive(packet);
48	pjm2	1.7	UDPReaderThread t = new UDPReaderThread();
49	pjm2	1.4	t.run(packet);
50	pjm2	1.2	}
51			catch (IOException e) {
52	pjm2	1.8	logger.write(this.toString(), Logger.SYSMSG, "The UDPReader thread has been shut down as an exception occured: "+e);
53			return;
54	pjm2	1.2	}
55	pjm2	1.1	}
56			socket.close();
57			}
58	pjm2	1.6
59
60			Logger logger;
61			int port;
62
63			final int packetSizeLimit = 8192;
64
65	pjm2	1.1	}