diff --git a/pkg/network/anonymity/queue/queue.go b/pkg/network/anonymity/queue/queue.go index 63470afc..7bca910e 100644 --- a/pkg/network/anonymity/queue/queue.go +++ b/pkg/network/anonymity/queue/queue.go @@ -54,7 +54,7 @@ func NewQBProblemProcessor(pSettings ISettings, pClient client.IClient) IQBProbl fClient: pClient, fMainPool: &sMainPool{ fQueue: make(chan net_message.IMessage, queuePoolCap[0]*consumersCap), - fConsumers: make(map[string]uint64, 64), + fConsumers: make(map[string]uint64, 128), fRawQueue: func() map[uint64]chan []byte { m := make(map[uint64]chan []byte, consumersCap) for i := uint64(0); i < consumersCap; i++ { diff --git a/test/result/coverage.svg b/test/result/coverage.svg index 4f6a78a3..b02a6d16 100644 --- a/test/result/coverage.svg +++ b/test/result/coverage.svg @@ -336,7 +336,7 @@ - + - + - +