Loading test/http3_control_streams_test.cpp +7 −0 Changes for test/http3_control_streams_test.cpp: 7 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -105,6 +105,13 @@ std::map<uint64_t, std::vector<uint8_t>> g_captured; void runServerThread(std::map<std::string, ssl::CertificateBundle> certs, int port) { try { quic serverSock(certs, "127.0.0.1", port, 64, -1); // The default (non-incremental) dispatch path only forwards // client-initiated *bidirectional* streams (id % 4 == 0) to // _stream_callback -- it's built around the one-bidi-stream-per- // HTTP-request model. Control/QPACK streams are unidirectional, so // incremental dispatch (which forwards every stream type) is // required to observe them here. serverSock.setIncrementalStreamDispatch(true); serverSock.setStreamCallback([](netplus::socket *, uint64_t stream_id, const std::vector<uint8_t> &data, bool) { std::lock_guard<std::mutex> lk(g_capturedMutex); Loading Loading
test/http3_control_streams_test.cpp +7 −0 Changes for test/http3_control_streams_test.cpp: 7 added lines, 0 removed lines. Original line number Diff line number Diff line Loading @@ -105,6 +105,13 @@ std::map<uint64_t, std::vector<uint8_t>> g_captured; void runServerThread(std::map<std::string, ssl::CertificateBundle> certs, int port) { try { quic serverSock(certs, "127.0.0.1", port, 64, -1); // The default (non-incremental) dispatch path only forwards // client-initiated *bidirectional* streams (id % 4 == 0) to // _stream_callback -- it's built around the one-bidi-stream-per- // HTTP-request model. Control/QPACK streams are unidirectional, so // incremental dispatch (which forwards every stream type) is // required to observe them here. serverSock.setIncrementalStreamDispatch(true); serverSock.setStreamCallback([](netplus::socket *, uint64_t stream_id, const std::vector<uint8_t> &data, bool) { std::lock_guard<std::mutex> lk(g_capturedMutex); Loading