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

Author: algorandskiy

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)
 		})
 	}
 }

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