diff -r 000000000000 -r 676905a3b03c dejsem.1.5/python/dejsem.pycharm/meter.py --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/dejsem.1.5/python/dejsem.pycharm/meter.py Wed Nov 27 09:50:16 2019 +0100 @@ -0,0 +1,55 @@ +# coding=utf8 + +import socket, time, sys +from d import D +from parms import Parms + +class Meter(): + + def __init__(self, d): + self.d = D("{}, troughput measuring daemon".format(d.debid)) + + def run(self): + self.d.log("started", sev=3) + ssc, sc = None, None + ssc = self.bindwait('', Parms.baseport) + try: + while True: + self.d.log("accepting...", sev=3) + sc = ssc.accept()[0] + self.d.log("accepted", sev=3) + n1 = 0 + n0 = len(sc.recv(16 * 1024)) + while n0 > 0: + n1 = n1 + n0 + if self.d.ll(5): self.d.log("n0={}, n1={}".format(n0, n1)) + if n1 >= 16 * 1024: + if self.d.ll(5): self.d.log("{} received, sending acknoledgement".format(n1)) + sc.send(bytes("=>{:08d}".format(n1), "utf8")) + n1 = 0 + n0 = len(sc.recv(16 * 1024)) + sc.close() + except KeyboardInterrupt: + pass + except Exception as e: + self.d.abendMsg("measuring", e=e) + self.d.log("closing ssc...", sev=4) + if sc: sc.close() + if ssc: ssc.close() + + def bindwait(self, host, port): + ssc = socket.socket(socket.AF_INET, socket.SOCK_STREAM) + while True: + try: + ssc.bind((host, port)) + break + except Exception as e: + if e.strerror == "Address already in use": + self.d.log("Address {}:{} already in use, waiting 10 secs...".format(host, port)) + time.sleep(10) + continue + self.d.abend("bind", e) + sys.exit(1) + ssc.listen(1) + self.d.log("bound to {}:{}".format(host, port), sev=2) + return ssc \ No newline at end of file