host/java/JavaHost.java

//---PACKAGE DECLARATION---

//---IMPORTS---

/**
 * A small efficient JavaHost
 * Designed to be used as a working design to build the C++ hosts on.
 * Hopefully fully functional and thus can be used as part of a test rig.
 *
 * @author  $Author: tdb1 $
 * @version $Id: JavaHost.java,v 1.4 2000/12/07 23:20:15 tdb1 Exp $
 */
class JavaHost {
    
//---FINAL ATTRIBUTES---

//---STATIC METHODS---

//---CONSTRUCTORS---
    
    /**
     * Constructor for the class. Takes in the hostname and port number
     * of the Filter Manager.
     *
     */
    public JavaHost( String serverName, int port ){
        // create a connection to the filter manager
        System.out.println("Creating connection with Filter Manager");
        Config config = new Config(serverName, port);
        // the config class knows what values it wants to get from
        // the configuration system
        
        // create a SystemMonitor object and pass the config
        // as a param so it knows what to do!
        System.out.println("Creating System Monitor");
        SystemMonitor sysMon = new SystemMonitor(config);
        
        try {
                udpcheckInterval = Long.parseLong(config.getProperty("UDPUpdateTime")) * 1000;
                System.out.println("Configured UDPUpdateTime");
        }
        catch ( NumberFormatException e ){
                System.out.println("The value for UDPUpdateTime is invalid, using a default");
                // 1 mins
                udpcheckInterval = 1000 * 60;  // 1 minute
        }
        
        try {
                tcpcheckInterval = Long.parseLong(config.getProperty("TCPUpdateTime")) * 1000;
                System.out.println("Configured TCPUpdateTime");
        }
        catch ( NumberFormatException e ){
                System.out.println("The value for UDPUpdateTime is invalid, using a default");
                // 10 mins
                tcpcheckInterval = 10000 * 60;  // 5 minutes
        }
        
        // the current time..
        long currentTime = System.currentTimeMillis();
        long nextUDP = currentTime + udpcheckInterval;
        long nextTCP = currentTime + tcpcheckInterval;
        
        while ( true ){
            currentTime = System.currentTimeMillis();
            // keep going for ever and ever ;)
            
            if ( nextTCP < nextUDP ){
                try {
                        long sleeptime = nextTCP - currentTime;
                        if ( sleeptime > 0 ){
                                Thread.sleep(sleeptime);
                        }
                        nextTCP += tcpcheckInterval;
                        // send a heartbeat
                        System.out.println("Sending Heartbeat");
                        config.sendHeartBeat();
                        if ( config.reloadConfig() ){
                            System.out.println("Resarting System");
                            break;      
                        }
                 }
                 catch ( InterruptedException e ){
                        // do nothing
                 }
            }
            else {
                try {
                    long sleeptime = nextUDP - currentTime;
                        if ( sleeptime > 0 ){
                                Thread.sleep(sleeptime);
                        }
                        nextUDP += udpcheckInterval;
                        // send a heartbeat
                        System.out.println("Sending UDP Packet");
                        LowLevelNet.sendUDPPacket(config, sysMon.getInfo());  
            
                 }
                 catch ( InterruptedException e ){
                        // do nothing
                 }      
            }
            
            
        } // while
        
           
    } // public javahost


//---PUBLIC METHODS---

//---PRIVATE METHODS---

//---ACCESSOR/MUTATOR METHODS---

//---ATTRIBUTES---

    private long udpcheckInterval;
    private long tcpcheckInterval;
    private final long defaultUpdateTime = 60000;


//---STATIC ATTRIBUTES---

} // class
Revision:	1.5
Committed:	Fri Dec 8 15:44:56 2000 UTC (23 years, 11 months ago) by ab11
Branch:	MAIN
Changes since 1.4:	+71 -10 lines
Log Message:	Hacked around to move thread of control away from SystemMonitor. TCP heartbeats and UDP packets now have independant times
#	User	Rev	Content
1	ab11	1.2	//---PACKAGE DECLARATION---
2	ab11	1.1
3	ab11	1.2	//---IMPORTS---
4
5			/**
6			* A small efficient JavaHost
7			* Designed to be used as a working design to build the C++ hosts on.
8			* Hopefully fully functional and thus can be used as part of a test rig.
9			*
10	ab11	1.5	* @author $Author: tdb1 $
11			* @version $Id: JavaHost.java,v 1.4 2000/12/07 23:20:15 tdb1 Exp $
12	ab11	1.2	*/
13	ab11	1.1	class JavaHost {
14	ab11	1.2
15			//---FINAL ATTRIBUTES---
16
17			//---STATIC METHODS---
18
19			//---CONSTRUCTORS---
20
21			/**
22			* Constructor for the class. Takes in the hostname and port number
23	tdb	1.4	* of the Filter Manager.
24	ab11	1.2	*
25			*/
26			public JavaHost( String serverName, int port ){
27	tdb	1.4	// create a connection to the filter manager
28			System.out.println("Creating connection with Filter Manager");
29	ab11	1.2	Config config = new Config(serverName, port);
30			// the config class knows what values it wants to get from
31	tdb	1.4	// the configuration system
32	ab11	1.2
33	tdb	1.4	// create a SystemMonitor object and pass the config
34	ab11	1.2	// as a param so it knows what to do!
35	ab11	1.3	System.out.println("Creating System Monitor");
36	ab11	1.2	SystemMonitor sysMon = new SystemMonitor(config);
37
38	ab11	1.5	try {
39			udpcheckInterval = Long.parseLong(config.getProperty("UDPUpdateTime")) * 1000;
40			System.out.println("Configured UDPUpdateTime");
41			}
42			catch ( NumberFormatException e ){
43			System.out.println("The value for UDPUpdateTime is invalid, using a default");
44			// 1 mins
45			udpcheckInterval = 1000 * 60; // 1 minute
46			}
47
48			try {
49			tcpcheckInterval = Long.parseLong(config.getProperty("TCPUpdateTime")) * 1000;
50			System.out.println("Configured TCPUpdateTime");
51			}
52			catch ( NumberFormatException e ){
53			System.out.println("The value for UDPUpdateTime is invalid, using a default");
54			// 10 mins
55			tcpcheckInterval = 10000 * 60; // 5 minutes
56			}
57
58			// the current time..
59			long currentTime = System.currentTimeMillis();
60			long nextUDP = currentTime + udpcheckInterval;
61			long nextTCP = currentTime + tcpcheckInterval;
62
63	ab11	1.2	while ( true ){
64	ab11	1.5	currentTime = System.currentTimeMillis();
65	ab11	1.2	// keep going for ever and ever ;)
66	ab11	1.5
67			if ( nextTCP < nextUDP ){
68			try {
69			long sleeptime = nextTCP - currentTime;
70			if ( sleeptime > 0 ){
71			Thread.sleep(sleeptime);
72			}
73			nextTCP += tcpcheckInterval;
74			// send a heartbeat
75			System.out.println("Sending Heartbeat");
76			config.sendHeartBeat();
77			if ( config.reloadConfig() ){
78			System.out.println("Resarting System");
79			break;
80			}
81			}
82			catch ( InterruptedException e ){
83			// do nothing
84			}
85	ab11	1.3	}
86	ab11	1.5	else {
87			try {
88			long sleeptime = nextUDP - currentTime;
89			if ( sleeptime > 0 ){
90			Thread.sleep(sleeptime);
91			}
92			nextUDP += udpcheckInterval;
93			// send a heartbeat
94			System.out.println("Sending UDP Packet");
95			LowLevelNet.sendUDPPacket(config, sysMon.getInfo());
96
97			}
98			catch ( InterruptedException e ){
99			// do nothing
100			}
101			}
102
103
104
105	ab11	1.3	} // while
106	ab11	1.2
107	ab11	1.3
108	ab11	1.2	} // public javahost
109
110
111			//---PUBLIC METHODS---
112
113			//---PRIVATE METHODS---
114
115			//---ACCESSOR/MUTATOR METHODS---
116
117			//---ATTRIBUTES---
118	ab11	1.5
119			private long udpcheckInterval;
120			private long tcpcheckInterval;
121			private final long defaultUpdateTime = 60000;
122
123	ab11	1.2
124			//---STATIC ATTRIBUTES---
125
126	ab11	1.1	} // class