diff --git a/packages/binary/messagelayer/tangle/tangle.go b/packages/binary/messagelayer/tangle/tangle.go index 8947996fb5a6694430bfc58fb7242553ca0a4cc9..9d7e86427a5877141c84c785e096c4ed07697c96 100644 --- a/packages/binary/messagelayer/tangle/tangle.go +++ b/packages/binary/messagelayer/tangle/tangle.go @@ -57,6 +57,7 @@ func New(store kvstore.KVStore) (result *Tangle) { } result.solidifierWorkerPool.Tune(1024) + result.storeMessageWorkerPool.Tune(1024) return } diff --git a/packages/gossip/manager.go b/packages/gossip/manager.go index 69cfab5bae9a347fa53d1f83a59ad3cf7a46918f..bfefb13cc201e87dd19a617f8aaeba760e9b83e1 100644 --- a/packages/gossip/manager.go +++ b/packages/gossip/manager.go @@ -22,8 +22,8 @@ const ( ) var ( - messageWorkerCount = runtime.GOMAXPROCS(0) - messageWorkerQueueSize = 500 + messageWorkerCount = runtime.GOMAXPROCS(0) * 4 + messageWorkerQueueSize = 1000 messageRequestWorkerCount = 1 messageRequestWorkerQueueSize = 100