Make Inbound peer resource allocation synchronous

packages/node/p2p/stream.go

@@ -96,7 +96,7 @@ func (m *Manager) acceptPeer(ctx context.Context, p *peer.Peer, opts []ConnectPe
 		return nil, ErrNoP2P
 	}
 
-	handleInboundStream := func(ctx context.Context, protocolID protocol.ID, registeredProtocols ...protocol.ID) (*PacketsStream, error) {
+	handleInboundStream := func(ctx context.Context, protocolID protocol.ID) (*PacketsStream, error) {
 		if buildConnectPeerConfig(opts).useDefaultTimeout {
 			var cancel context.CancelFunc
 			ctx, cancel = context.WithTimeout(ctx, defaultConnectionTimeout)

plugins/autopeering/plugin.go

@@ -108,7 +108,8 @@ func configureGossipIntegration() {
 			Plugin.Logger().Debugw("error dropping neighbor", "id", ev.DroppedID, "err", err)
 		}
 	}))
-	deps.Selection.Events().IncomingPeering.Attach(event.NewClosure(func(ev *selection.PeeringEvent) {
+	// We need to allocate synchronously the resources to accomodate incoming stream requests.
+	deps.Selection.Events().IncomingPeering.Hook(event.NewClosure(func(ev *selection.PeeringEvent) {
 		if !ev.Status {
 			return // ignore rejected peering
 		}