thweetkomputer · Oct 16, 2026 · Oct 16, 2026 · Oct 16, 2026 · Oct 16, 2026 · Oct 16, 2026
diff --git a/CMakeLists.txt b/CMakeLists.txt
@@ -2251,8 +2251,10 @@ endforeach()
       NAME lavik_compact_collection_write_e2e
       COMMAND lavik_compact_collection_write_e2e_test $<TARGET_FILE:lavik>
     )
+    # The full write/recovery matrix can exceed ten minutes on ARM64 Debug
+    # runners; allow more time for the complete suite.
     set_tests_properties(lavik_compact_collection_write_e2e PROPERTIES
-      TIMEOUT 600 RUN_SERIAL TRUE
+      TIMEOUT 900 RUN_SERIAL TRUE
     )
 
     add_executable(lavik_adaptive_flush_e2e_test

diff --git a/bycorf b/bycorf
diff --git a/src/storage/engine/read.cpp b/src/storage/engine/read.cpp
@@ -63,11 +63,10 @@ class BatchReadAwaiter {
         --remaining_;
       }
     }
-    // A full io_uring SQ may submit and reap earlier operations while this
-    // loop is still preparing the batch. Unvisited operations are already in
-    // remaining_, so those completions cannot resume us early. The operation
-    // passed to each SubmitRead is itself guaranteed to complete
-    // asynchronously.
+    // Count the whole batch before submission and retire immediate rejections
+    // locally. Accepted operations remain outstanding while queued for backend
+    // capacity; each deferred completion retires one count, and only the last
+    // wakes the caller.
     return remaining_ != 0;
   }
+5 −1		CMakeLists.txt
+4 −3		README.md
+29 −7		docs/architecture/io.md
+3 −2		docs/architecture/networking.md
+4 −3		docs/architecture/runtime.md
+108 −0		example/connect_timer_check.cpp
+12 −1		include/bycorf/io/completion.h
+61 −9		include/bycorf/io/io_uring_backend.h
+7 −0		include/bycorf/io/net_backend.h
+15 −16		include/bycorf/io/spdk_storage.h
+1 −0		include/bycorf/net/tcp_listener.h
+10 −6		include/bycorf/net/tcp_service.h
+11 −0		include/bycorf/runtime/worker.h
+5 −3		src/io/dpdk_backend.cpp
+367 −226		src/io/io_uring_backend.cpp
+120 −121		src/io/spdk_storage.cpp
+4 −0		src/net/tcp_listener.cpp
+31 −34		src/net/tcp_service.cpp
+10 −12		src/net/tcp_stream.cpp
+17 −2		src/runtime/worker.cpp
+408 −0		tests/io_uring_backpressure_check.cpp
+291 −29		tests/spdk_backpressure_stub_check.cpp