in scripts/mcast.py [0:0]
def loop(self, data, count=0, interval=1):
try:
seq = 1
while True:
segment = self.datafmt % {'seq':seq, 'time':time.time(), 'data': data}
ssize = self.sock.sendto(segment, (self.grp_addr, self.port))
if ssize < len(segment):
logging.warn("Failed to send: '%s'" % segment)
else:
logging.info("Sent data: '%s'" % segment)
if count > 0 and seq >= count:
return ssize == len(segment)
seq += 1
time.sleep(interval)
except (KeyboardInterrupt, SystemExit):
logging.info("Exiting...")
except:
traceback.print_exc()