fix yet another bug

Author: sirtimid

packages/ocap-kernel/src/remotes/network.ts

@@ -590,24 +590,32 @@ export async function initNetwork(
           return;
         }
 
-        // Re-check connection limit after dial completes to prevent race conditions
-        // Multiple concurrent dials could all pass the initial check, then all add channels
-        try {
-          checkConnectionLimit();
-        } catch {
-          // Connection limit reached - close the dialed channel and queue the message
-          logger.log(
-            `${targetPeerId}:: connection limit reached after dial, queueing message`,
-          );
-          // Explicitly close the channel to release network resources
-          await connectionFactory.closeChannel(channel, targetPeerId);
-          queue.enqueue(message);
-          // Start reconnection to retry later when limit might free up
-          handleConnectionLoss(targetPeerId);
-          return;
-        }
+        // Check if a concurrent call already registered a channel for this peer
+        // (dialIdempotent may return the same channel due to deduplication)
+        const existingChannel = channels.get(targetPeerId);
+        if (existingChannel) {
+          // Another concurrent call already registered the channel, use it
+          channel = existingChannel;
+        } else {
+          // Re-check connection limit after dial completes to prevent race conditions
+          // Multiple concurrent dials could all pass the initial check, then all add channels
+          try {
+            checkConnectionLimit();
+          } catch {
+            // Connection limit reached - close the dialed channel and queue the message
+            logger.log(
+              `${targetPeerId}:: connection limit reached after dial, queueing message`,
+            );
+            // Explicitly close the channel to release network resources
+            await connectionFactory.closeChannel(channel, targetPeerId);
+            queue.enqueue(message);
+            // Start reconnection to retry later when limit might free up
+            handleConnectionLoss(targetPeerId);
+            return;
+          }
 
-        registerChannel(targetPeerId, channel);
+          registerChannel(targetPeerId, channel);
+        }
       } catch (problem) {
         outputError(targetPeerId, `opening connection`, problem);
         handleConnectionLoss(targetPeerId);

vitest.config.ts

@@ -130,7 +130,7 @@ export default defineConfig({
         'packages/kernel-ui/**': {
           statements: 97.57,
           functions: 97.29,
-          branches: 93.25,
+          branches: 93.26,
           lines: 97.57,
         },
         'packages/kernel-utils/**': {
@@ -158,10 +158,10 @@ export default defineConfig({
           lines: 22.22,
         },
         'packages/ocap-kernel/**': {
-          statements: 96.41,
+          statements: 96.42,
           functions: 98.56,
           branches: 97.27,
-          lines: 96.41,
+          lines: 96.42,
         },
         'packages/omnium-gatherum/**': {
           statements: 5.67,