diff --git a/hbc b/hbc index 1f8038b..cd3eba5 100755 --- a/hbc +++ b/hbc @@ -59,7 +59,7 @@ daemon.get_maximum_file_descriptors = get_maximum_file_descriptors PORT = 50003 INTERVAL = 10 PIDFILE = '/tmp/hbc.pid' -VER = 1 +VER = 2 MAXRECV = 32767 running = True diff --git a/hbd b/hbd index 7d417fb..66e8f81 100755 --- a/hbd +++ b/hbd @@ -19,6 +19,7 @@ import cPickle import smtplib import traceback import urllib +import urlparse import httplib import threading import Queue @@ -322,7 +323,7 @@ def log(host, m, service=None): hst = "%s " % host else: hst = "" - + msg = "%s: %s%s%s\n" % (ts, hst, srv, m) msgs.append(msg) if logfmt == "msg": @@ -364,7 +365,7 @@ def readsock(sock): msg = oldmtodict(data) else: oldclient = False - if verbose: print "readsock = %s, %s" % (msg,addrp) + if DEBUG > 2: print "readsock = %s, %s" % (msg,addrp) addr = addrp[0:2] name = shortname(msg.get('name', "unknown")) @@ -440,7 +441,7 @@ def readsock(sock): else: opkt = dicttos('ACK', rmsg) ss=sock.sendto(opkt, addr) - if verbose: print "sendto1: %s (%s) %s %s" % (addr, len(opkt), op, str(rmsg)[:50]) + if DEBUG > 2: print "sendto1: %s (%s) %s %s" % (addr, len(opkt), op, str(rmsg)[:50]) # send any commands we have queued while len(host.cmds): @@ -467,7 +468,7 @@ def readsock(sock): except Exception as e: print "opkt len is %s" % len(opkt) print "cannot send: %s" % e - + if verbose: print "sendto2: %s (%s) %s %s" % (addr, len(opkt), op, str(rmsg)[:50]) if DEBUG > 2: print "msg from %s,%s, sent %s bytes back" % (addr[0], addr[1], ss) @@ -503,20 +504,18 @@ class HttpHandler(BaseHTTPServer.BaseHTTPRequestHandler): def do_HEAD(self): - self.setheaders() + self.setheaders(200) - def setheaders(self, headerdict=None): - if not headerdict: - headerdict = {"Content-Type": "text/html; charset = ISO-8859-1" } - self.send_response(200) + def setheaders(self, code, headerdict): + self.send_response(code) self.send_header("Last-Modified", time.strftime("%a, %d %b %Y %H:%M:%S GMT", time.gmtime(now))) # self.send_header("Accept-Ranges","bytes") # self.send_header("Connection","close") for h in headerdict: self.send_header(h, headerdict[h]) self.end_headers() - + def buildhead(self, title="Heartbeat", refresh=None, extras=None): res=[] @@ -556,141 +555,107 @@ class HttpHandler(BaseHTTPServer.BaseHTTPRequestHandler): res.append('