Purge items from memory state on final
This commit is contained in:
parent
c3a592c0f6
commit
387014f77b
@ -91,11 +91,18 @@ class ChaindFsAdapter(ChaindAdapter):
|
|||||||
if self.store.is_reserved(tx.hash):
|
if self.store.is_reserved(tx.hash):
|
||||||
raise QueueLockError(tx.hash)
|
raise QueueLockError(tx.hash)
|
||||||
|
|
||||||
return self.store.final(tx.hash, block, tx, error=False)
|
r = self.store.final(tx.hash, block, tx, error=False)
|
||||||
|
self.store.purge(tx.hash)
|
||||||
|
return r
|
||||||
|
|
||||||
|
|
||||||
def fail(self, block, tx):
|
def fail(self, block, tx):
|
||||||
return self.store.final(tx.hash, block, tx, error=True)
|
if self.store.is_reserved(tx.hash):
|
||||||
|
raise QueueLockError(tx.hash)
|
||||||
|
|
||||||
|
r = self.store.final(tx.hash, block, tx, error=True)
|
||||||
|
self.store.purge(tx.hash)
|
||||||
|
return r
|
||||||
|
|
||||||
|
|
||||||
def sendfail(self):
|
def sendfail(self):
|
||||||
|
Loading…
Reference in New Issue
Block a user