From 7ede7dce2a503b992a638b44a0ee4e0e5b2a725a Mon Sep 17 00:00:00 2001 From: ryan Date: Fri, 29 Apr 2016 16:09:29 +0200 Subject: [PATCH] clean shut down --- bigchaindb/voter.py | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/bigchaindb/voter.py b/bigchaindb/voter.py index 0aa89a60..3f0de12c 100644 --- a/bigchaindb/voter.py +++ b/bigchaindb/voter.py @@ -215,6 +215,7 @@ class Election(object): # poison pill if next_block == 'stop': + self.q_invalid_blocks.put('stop') logger.info('clean exit') return @@ -227,6 +228,12 @@ class Election(object): """ while True: invalid_block = self.q_invalid_blocks.get() + + # poison pill + if invalid_block == 'stop': + logger.info('clean exit') + return + b = Bigchain() for tx in invalid_block['block']['transactions']: b.write_transaction(tx)