tensor/outputs/riemann.py
def tick(self):
        """Clock tick called every self.inter
        """
        if self.factory.proto:
            # Check backpressure
            if (self.pressure < 0) or (self.factory.proto.pressure <= self.pressure):
                self.emptyQueue()
        elif self.expire:
            # Check queue age and expire stale events
            for i, e in enumerate(self.events):
                if (time.time() - e.time) > e.ttl:
                    self.events.pop(i)
def tick(self):
        """Clock tick called every self.inter
        """
        if self.factory.proto:
            # Check backpressure
            if (self.pressure < 0) or (self.factory.proto.pressure <= self.pressure):
                self.emptyQueue()
        elif self.expire:
            # Check queue age and expire stale events
            for i, e in enumerate(self.events):
                if (time.time() - e.time) > e.ttl:
                    self.events.pop(i)
def tick ( self ) : if self . factory . proto : # Check backpressure if ( self . pressure < 0 ) or ( self . factory . proto . pressure <= self . pressure ) : self . emptyQueue ( ) elif self . expire : # Check queue age and expire stale events for i , e in enumerate ( self . events ) : if ( time . time ( ) - e . time ) > e . ttl : self . events . pop ( i )
Clock tick called every self.inter
Clock tick called every self . inter