def run(self):
        self.log.info('ListenerThread started on {0}:{1}(udp)'.format(
            self.host, self.port))

        rdr = collectd_network.Reader(self.host, self.port)

        try:
            while ALIVE:
                try:
                    items = rdr.interpret(poll_interval=self.poll_interval)
                    self.send_to_collector(items)
                except __HOLE__, e:
                    self.log.warn('Dropping bad packet: {0}'.format(e))
        except Exception, e:
            self.log.error('caught exception: type={0}, exc={1}'.format(type(e),
                                                                        e))

        self.log.info('ListenerThread - stop')
dataset/ETHPy150Open BrightcoveOS/Diamond/src/collectors/jcollectd/jcollectd.py/ListenerThread.run