def loop()

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()