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 |
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 |