andreas/heartbeat
Public Access
1
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases 44 Wiki Activity

always set reuseaddr sockopt

Browse Source
This commit is contained in:
andreas
2013-06-03 13:24:26 +00:00
parent e65d9df061
commit 69d962fdc7
1 changed files with 4 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
hbd
+4 -5
View File
@@ -1,5 +1,5 @@
#!/usr/bin/env python #!/usr/bin/env python
# $Id: hbd,v 1.34 2012/09/22 19:17:53 andreas Exp $ # $Id: hbd,v 1.35 2013/06/03 13:24:26 andreas Exp $
# Wait for heartbeat messages and act on them (or their absence) # Wait for heartbeat messages and act on them (or their absence)
# #
import time, os, string, sys, socket, atexit, select, SocketServer, getopt, signal, cPickle, smtplib, traceback import time, os, string, sys, socket, atexit, select, SocketServer, getopt, signal, cPickle, smtplib, traceback
@@ -29,7 +29,7 @@ INTERVAL=10
GRACE=2 GRACE=2
visual=0 visual=0
os.environ['TZ']='Canada/Eastern' os.environ['TZ']='EST5EDT'
stdscr=None stdscr=None
win=None win=None
@@ -468,7 +468,7 @@ class HtmlHandler(SocketServer.BaseRequestHandler):
res.append("<meta http-equiv=Refresh content=%d>\n" % 60) res.append("<meta http-equiv=Refresh content=%d>\n" % 60)
res.append("</head>") res.append("</head>")
res.append('<body BGCOLOR="#FFFFFF" LINK="#008000" VLINK="#008000" BACKGROUND="/~andreas/images/tile.marble.gif">') res.append('<body BGCOLOR="#FFFFFF" LINK="#008000" VLINK="#008000" BACKGROUND="/~andreas/images/tile.marble.gif">')
res.append("<H2>Heartbeat status</h2><h4> %s (%s)</H4>" % (time.strftime("%H:%M:%S", time.localtime(now)), os.environ.get('TZ','Europe/Berlin'))) res.append("<H2>Heartbeat status</h2><h4> %s (%s)</H4>" % (time.strftime("%H:%M:%S", time.localtime(now)), os.environ.get('TZ','CET-1CDT')))
res.append("<table>") res.append("<table>")
res.append("<tr><th>Host</th><th>State</th><th>IP Addr</th><th>Last change</th></tr>\n" ) res.append("<tr><th>Host</th><th>State</th><th>IP Addr</th><th>Last change</th></tr>\n" )
hosts_sorted=hosts.keys() hosts_sorted=hosts.keys()
@@ -644,8 +644,7 @@ atexit.register(on_exit)
ilist=[] ilist=[]
sock=socket.socket(socket.AF_INET, socket.SOCK_DGRAM) sock=socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
sock.setsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR, \ sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
sock.getsockopt(socket.SOL_SOCKET,socket.SO_REUSEADDR) | 1)
sock.bind(("",hb_port)) sock.bind(("",hb_port))
ilist.append(sock) ilist.append(sock)