kylefang/stacks-puppet-node
1
0
Fork 0
mirror of https://github.com/alexgo-io/stacks-puppet-node.git synced 2026-04-18 07:40:42 +08:00
Code Issues Packages Projects Releases Wiki Activity

serialize all calls to enqueue zone files

Browse Source
This commit is contained in:
Jude Nelson
2018-08-06 18:14:16 -04:00
parent 66e8edc08f
commit 097fc369bd
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
blockstack/lib/subdomains.py
View File

@@ -430,6 +430,8 @@ class SubdomainIndex(object):
self.subdomain_db = SubdomainDB(subdomain_db_path, blockstack_opts['zonefiles'])
self.subdomain_db_lock = threading.Lock()
self.serialized_enqueue_zonefile = threading.Lock()
self.atlasdb_path = blockstack_opts['atlasdb_path']
self.zonefiles_dir = blockstack_opts['zonefiles']
@@ -828,8 +830,9 @@ class SubdomainIndex(object):
* AtlasZonefileCrawler (as it's "store_zonefile" callback).
* rpc_put_zonefiles()
"""
log.debug("Append {} from {}".format(zonefile_hash, block_height))
queuedb_append(self.subdomain_queue_path, "zonefiles", zonefile_hash, json.dumps({'zonefile_hash': zonefile_hash, 'block_height': block_height}))
with self.serialized_enqueue_zonefile:
log.debug("Append {} from {}".format(zonefile_hash, block_height))
queuedb_append(self.subdomain_queue_path, "zonefiles", zonefile_hash, json.dumps({'zonefile_hash': zonefile_hash, 'block_height': block_height}))
def index_blockchain(self, block_start, block_end):