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/TCPReaderInit.java
(Generate patch)

Comparing projects/cms/source/server/uk/org/iscream/cms/server/filter/TCPReaderInit.java (file contents):
Revision 1.15 by tdb, Wed Feb 7 13:47:11 2001 UTC vs.
Revision 1.21 by tdb, Tue Mar 13 02:19:46 2001 UTC

# Line 39 | Line 39 | class TCPReaderInit extends Thread {
39       * @throws IOException if something goes badly wrong
40       */
41      public TCPReaderInit(Socket socket, Queue queue) throws IOException {
42 +        // set the Thread name
43 +        setName("filter.TCPReaderInit");
44 +        
45          _socket = socket;
46          _queue = queue;
47          // setup the reader & writer
# Line 101 | Line 104 | class TCPReaderInit extends Thread {
104                  _socketOut.println("OK");
105              }
106  
107 <            String date = new Long(System.currentTimeMillis()).toString();
108 <            String hostname = _socket.getInetAddress().getHostName();
107 >            String date = new Long(System.currentTimeMillis()/((long) 1000)).toString();
108 >            String hostname = _socket.getInetAddress().getHostName().toLowerCase();
109              String ipadd = _socket.getInetAddress().getHostAddress();
107            String xml = "<packet type=\"heartbeat\" machine_name=\""+hostname+"\" date=\""+date+"\" ip=\""+ipadd+"\"></packet>";
110              
111 +            // run the service checks for this host
112 +            _logger.write(toString(), Logger.DEBUG, "Running service checks");
113 +            String checks = PluginServiceCheckManager.getInstance().runServiceChecks(hostname);
114 +            
115 +            // build the heartbeat packet
116 +            String xml = "<packet type=\"heartbeat\" machine_name=\""+hostname+"\" date=\""+date+"\" ip=\""+ipadd+"\">" + checks + "</packet>";
117 +            
118 +            // get it to be sent on
119              _queue.add(xml);
120              
121          } catch (Exception e) {
122 <            _logger.write(toString(), Logger.ERROR, "ERROR: " + e.getMessage());
122 >            _logger.write(toString(), Logger.ERROR, "ERROR: " + e);
123          }
124          
125          // Disconnect streams & socket

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines