if not self.schedule:\r
self.schedule = reactor.callLater(self.throttle - t, self.flush, True)\r
return\r
+ else:\r
+ # process the rest of the packet\r
+ if not scheduled:\r
+ if not self.schedule:\r
+ self.schedule = reactor.callLater(0, self.flush, True)\r
+ return\r
+ \r
self.throttle = t + config.UPDATE_FREQ\r
\r
encdata = simplejson.dumps(self.buffer)\r