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

fixed failing test by joining block processes

Browse Source
This commit is contained in:
Rodolphe Marques 2016-03-16 17:30:01 +01:00
parent 33904b6804
commit eff33e35f6
2 changed files with 13 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
bigchaindb/block.py
View File

@ -215,3 +215,10 @@ class Block(object):
p_blocks.start()
p_write.start()
p_delete.start()
# join processes
p_filter.join()
p_validate.join()
p_blocks.join()
p_write.join()
p_delete.join()

8
bigchaindb/processes.py
View File

@ -63,6 +63,10 @@ class Processes(object):
def start(self):
logger.info('Initializing BigchainDB...')
# instantiate block and voter
block = Block(self.q_new_transaction)
# start the web api
webapi = server.create_app()
p_webapi = mp.Process(name='webapi', target=webapi.run, kwargs={'host': 'localhost'})
@ -71,7 +75,7 @@ class Processes(object):
# initialize the processes
p_map_bigchain = mp.Process(name='bigchain_mapper', target=self.map_bigchain)
p_map_backlog = mp.Process(name='backlog_mapper', target=self.map_backlog)
p_block = Block(self.q_new_transaction)
p_block = mp.Process(name='block', target=block.start)
p_voter = Voter(self.q_new_block)
# start the processes
@ -86,7 +90,7 @@ class Processes(object):
p_voter.start()
# start message
p_block.initialized.wait()
block.initialized.wait()
p_voter.initialized.wait()
logger.info('Initialization complete. BigchainDB ready and waiting for events.')
logger.info('You can send events through the API documented at http://docs.bigchaindb.apiary.io/')