timestamps.py 文件源码

def collect(self, collectors):
        """Collects timestamp results in parallel, using a DeferredList.

        :param collectors: A list of deferreds to wait for - the deferreds
                           should return integer results.

        """
        result = yield defer.DeferredList([
                self.snmpv2mib.get_timestamp_and_uptime()
                ] + list(collectors))
        tup = []
        for success, value in result:
            if success:
                tup.append(value)
            else:
                value.raiseException()
        self.collected_times = tuple(tup)
        defer.returnValue(self.collected_times)

    # We must ignore pickle load failures by catching the Exception base class
    # pylint: disable=W0703