network: fix misplaced p2p received TX metric (#6144)

algorand · Oct 28, 2024 · eff5fb4 · eff5fb4
1 parent 078aafe
commit eff5fb4
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/config/config_test.go b/config/config_test.go
@@ -773,7 +773,8 @@ func TestLocal_ValidateP2PHybridConfig(t *testing.T) {
 
 	for i, test := range tests {
 		test := test
-		t.Run(fmt.Sprintf("test=%d", i), func(t *testing.T) {
+		name := fmt.Sprintf("test=%d", i)
+		t.Run(name, func(t *testing.T) {
 			t.Parallel()
 
 			c := Local{
@@ -782,7 +783,7 @@ func TestLocal_ValidateP2PHybridConfig(t *testing.T) {
 				NetAddress:          test.netAddress,
 			}
 			err := c.ValidateP2PHybridConfig()
-			require.Equal(t, test.err, err != nil, "test=%d", i)
+			require.Equal(t, test.err, err != nil, name)
 		})
 	}
 }

diff --git a/network/p2p/pubsub.go b/network/p2p/pubsub.go
@@ -153,7 +153,7 @@ func (s *serviceImpl) Subscribe(topic string, val pubsub.ValidatorEx) (SubNextCa
 		return nil, err
 	}
 	// t.SetScoreParams() // already set in makePubSub
-	return t.Subscribe()
+	return t.Subscribe(pubsub.WithBufferSize(32768))
 }
 
 // Publish publishes data to the given topic