## all done, didn't find it!!
self.finished=1
reactor.callFromThread(self.callback,[])
-
+
## get value
def goWithNodes(self, nodes, found=None):
self.results = {}
c = self.store.cursor()
s = "delete from kv where time < '%s';" % self.cut
c.execute(s)
- self.store.commit()
reactor.callLater(const.KE_DELAY, self.doExpire)
\ No newline at end of file