Mirroristas/bigchaindb
2
0
Fork 0
mirror of https://github.com/bigchaindb/bigchaindb.git synced 2024-10-13 13:34:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

clean up processes.py

Browse Source
This commit is contained in:
ryan 2016-08-03 15:41:27 +02:00
parent dd0b758bfa
commit 44aa17098d
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
bigchaindb/processes.py
View File

@ -31,7 +31,6 @@ class Processes(object):
def __init__(self): def __init__(self):
# initialize the class # initialize the class
self.q_new_block = mp.Queue() self.q_new_block = mp.Queue()
self.q_block_new_vote = mp.Queue()
self.q_revert_delete = mp.Queue() self.q_revert_delete = mp.Queue()
def map_bigchain(self): def map_bigchain(self):
@ -52,10 +51,6 @@ class Processes(object):
# this should never happen in regular operation # this should never happen in regular operation
self.q_revert_delete.put(change['old_val']) self.q_revert_delete.put(change['old_val'])
# update (new vote)
elif change['new_val'] is not None and change['old_val'] is not None:
self.q_block_new_vote.put(change['new_val'])
def start(self): def start(self):
logger.info('Initializing BigchainDB...') logger.info('Initializing BigchainDB...')
@ -73,14 +68,13 @@ class Processes(object):
# start the processes # start the processes
logger.info('starting bigchain mapper') logger.info('starting bigchain mapper')
p_map_bigchain.start() p_map_bigchain.start()
logger.info('starting backlog mapper')
logger.info('starting block') logger.info('starting block')
block.start() block.start()
election.start()
p_block_delete_revert.start() p_block_delete_revert.start()
logger.info('starting voter') logger.info('starting voter')
p_voter.start() p_voter.start()
election.start()
logger.info('starting election') logger.info('starting election')
# start message # start message