Donate CPU:

* timeout after 30 seconds
 * added content for http://cppcheck.osuosl.org:8000/
This commit is contained in:
Daniel Marjamäki 2018-09-02 07:28:25 +02:00
parent 79840add38
commit 215bc3b303
1 changed files with 19 additions and 4 deletions

View File

@ -16,6 +16,15 @@ def strDateTime():
t = datetime.time.strftime(datetime.datetime.now().time(), '%H:%M') t = datetime.time.strftime(datetime.datetime.now().time(), '%H:%M')
return d + ' ' + t return d + ' ' + t
def overviewReport():
html = '<html><head><title>daca@home</title></head><body>\n'
html += '<h1>daca@home</h1>\n'
html += '<a href="latest.html">Latest results</a><br>\n'
html += '<a href="diff">Diff report (1.84 / head)</a><br>\n'
html += '<a href="crash">Crash report</a><br>\n'
html += '</body></html>'
return html
def fmt(a,b,c,d,e): def fmt(a,b,c,d,e):
ret = a + ' ' ret = a + ' '
while len(ret)<10: while len(ret)<10:
@ -222,12 +231,15 @@ class HttpClientThread(Thread):
try: try:
cmd = self.cmd cmd = self.cmd
print('[' + strDateTime() + '] ' + cmd) print('[' + strDateTime() + '] ' + cmd)
res = re.match(r'GET /([a-zA-Z0-9_\-\.]+) HTTP', cmd) res = re.match(r'GET /([a-zA-Z0-9_\-\.]*) HTTP', cmd)
if res is None: if res is None:
self.connection.close() self.connection.close()
return return
url = res.group(1) url = res.group(1)
if url == 'latest.html': if url == '':
html = overviewReport()
httpGetResponse(self.connection, html, 'text/html')
elif url == 'latest.html':
html = latestReport(self.latestResults) html = latestReport(self.latestResults)
httpGetResponse(self.connection, html, 'text/html') httpGetResponse(self.connection, html, 'text/html')
elif url == 'crash': elif url == 'crash':
@ -255,6 +267,7 @@ class HttpClientThread(Thread):
self.connection.close() self.connection.close()
def server(server_address_port, packages, packageIndex, resultPath): def server(server_address_port, packages, packageIndex, resultPath):
socket.setdefaulttimeout(30)
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
server_address = ('', server_address_port) server_address = ('', server_address_port)
@ -359,6 +372,8 @@ if __name__ == "__main__":
if '--test' in sys.argv[1:]: if '--test' in sys.argv[1:]:
server_address_port = 8001 server_address_port = 8001
server(server_address_port, packages, packageIndex, resultPath) try:
server(server_address_port, packages, packageIndex, resultPath)
except socket.timeout:
print('Timeout!')