update

number571 · Nov 25, 2024 · b6e5c00 · b6e5c00
1 parent 01062c4
commit b6e5c00
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/pkg/network/anonymity/queue/queue.go b/pkg/network/anonymity/queue/queue.go
@@ -53,15 +53,15 @@ func NewQBProblemProcessor(pSettings ISettings, pClient client.IClient) IQBProbl
 		fSettings: pSettings,
 		fClient:   pClient,
 		fMainPool: &sMainPool{
-			fQueue: make(chan net_message.IMessage, queuePoolCap[0]*consumersCap),
+			fQueue:     make(chan net_message.IMessage, queuePoolCap[0]*consumersCap),
+			fConsumers: make(map[string]uint64, 64),
 			fRawQueue: func() map[uint64]chan []byte {
 				m := make(map[uint64]chan []byte, consumersCap)
 				for i := uint64(0); i < consumersCap; i++ {
 					m[i] = make(chan []byte, queuePoolCap[0])
 				}
 				return m
 			}(),
-			fConsumers: make(map[string]uint64, 256),
 		},
 		fRandPool: &sRandPool{
 			fQueue:    make(chan net_message.IMessage, queuePoolCap[1]),

diff --git a/test/result/badge_coverage.svg b/test/result/badge_coverage.svg
diff --git a/test/result/coverage.svg b/test/result/coverage.svg