diag(quic-interop): chunk-size + openBidiStreamsBatch entry/exit logs

Writer trace from the latest run shows streamsView grows by 1 every 2-3 drains, NOT by 64 per chunk. Suggests batching isn't happening, even though the bytecode confirms openBidiStreamsBatch IS being called (via javap on the deployed class file). Two new diagnostic lines per multiplex run, both gated by DEBUG=1: [interop] multiplex start: total_urls=N MULTIPLEX_PARALLELISM=64 expected_chunks=32 [interop] chunk=0 size=64 starting prepareRequests [interop] chunk=1 size=64 starting prepareRequests ... [batch] openBidiStreamsBatch items=64 returned=64 streamsList_before=6 streamsList_after=70 If the [batch] line shows items=1 (instead of 64), the chunked() call is producing chunks of 1 (would be a bug in MULTIPLEX_ PARALLELISM or chunked semantics). If [batch] shows items=64 returned=64 streamsList_after=70, then batching IS working at this layer and the bug is downstream — the writer is somehow only seeing 1 stream at a time despite 64 being in the list. https://claude.ai/code/session_01HcvfQq1ttPV9PkRoJb4nyT
2026-05-07 13:32:54 +00:00
parent 8ae942b5aa
commit 679bb62a17
2 changed files with 23 additions and 2 deletions
@@ -364,8 +364,20 @@ private fun runTransferTest(
                            // (responses dribble in over a long stretch).
                            val debug = System.getenv("QUIC_INTEROP_DEBUG") == "1"
                            val transferStartMs = nowMs()
+                            if (debug) {
+                                System.err.println(
+                                    "[interop] multiplex start: total_urls=${urls.size} " +
+                                        "MULTIPLEX_PARALLELISM=$MULTIPLEX_PARALLELISM " +
+                                        "expected_chunks=${(urls.size + MULTIPLEX_PARALLELISM - 1) / MULTIPLEX_PARALLELISM}",
+                                )
+                            }
                            urls.chunked(MULTIPLEX_PARALLELISM).forEachIndexed { chunkIdx, chunk ->
                                val chunkStartMs = nowMs()
+                                if (debug && chunkIdx < 3) {
+                                    System.err.println(
+                                        "[interop] chunk=$chunkIdx size=${chunk.size} starting prepareRequests",
+                                    )
+                                }
                                // Single lock-held batch open + enqueue.
                                // Without this, openBidiStream's per-call
                                // lock acquire / release lets the send loop
@@ -800,9 +800,18 @@ class QuicConnection(
        init: (QuicStream, I) -> R,
    ): List<R> {
        if (items.isEmpty()) return emptyList()
-        return streamsLock.withLock {
-            items.map { init(openBidiStreamLocked(), it) }
+        val streamsBefore = if (writerDebugEnabled) streams.size else 0
+        val result =
+            streamsLock.withLock {
+                items.map { init(openBidiStreamLocked(), it) }
+            }
+        if (writerDebugEnabled) {
+            System.err.println(
+                "[batch] openBidiStreamsBatch items=${items.size} returned=${result.size} " +
+                    "streamsList_before=$streamsBefore streamsList_after=${streams.size}",
+            )
        }
+        return result
    }

    /**