connector
This commit is contained in:
parent
afcb02f556
commit
62913d76e7
@ -73,11 +73,12 @@ class BlockLoader:
|
|||||||
if self.last_batch_size < 1000000 and self.rpc_batch_limit < 450:
|
if self.last_batch_size < 1000000 and self.rpc_batch_limit < 450:
|
||||||
self.rpc_batch_limit += 50
|
self.rpc_batch_limit += 50
|
||||||
self.log.warning("rpc batch limit %s " % self.rpc_batch_limit)
|
self.log.warning("rpc batch limit %s " % self.rpc_batch_limit)
|
||||||
elif self.last_batch_size > 40000000 and self.rpc_batch_limit > 10:
|
elif self.last_batch_size > 40000000 and self.rpc_batch_limit > 100:
|
||||||
self.rpc_batch_limit = 30
|
self.rpc_batch_limit -= 50
|
||||||
self.log.warning("rpc batch limit %s " % self.rpc_batch_limit)
|
self.log.warning("rpc batch limit %s " % self.rpc_batch_limit)
|
||||||
if self.last_batch_size > 80000000 and self.rpc_batch_limit > 10:
|
elif self.last_batch_size > 80000000 and self.rpc_batch_limit < 60:
|
||||||
self.rpc_batch_limit = 20
|
self.rpc_batch_limit = 20
|
||||||
|
|
||||||
self.log.warning("rpc batch limit %s " % self.rpc_batch_limit)
|
self.log.warning("rpc batch limit %s " % self.rpc_batch_limit)
|
||||||
for i in self.worker_busy:
|
for i in self.worker_busy:
|
||||||
if not self.worker_busy[i]:
|
if not self.worker_busy[i]:
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user