Commit 2e5137d1 authored by jan.koester's avatar jan.koester
Browse files

test

parent ae8e96f8

src/httpd.cpp

+0 −25
Original line number Diff line number Diff line
@@ -454,13 +454,6 @@ void libhttppp::HttpEvent::_dispatchH2Stream(HttpRequest &cureq, 
                status_code, content_type, content_length, extra);

            out += h2BuildFrame(H2_FRAME_HEADERS, H2_FLAG_END_HEADERS, sid, hpack_out);



            std::cerr << "[H2-FC] sid=" << sid << " START: sw="

                      << cureq.h2state().peerStreamWindows[sid]

                      << " cw=" << cureq.h2state().peerConnWindow

                      << " content_length=" << content_length

                      << " body.size=" << body.size()

                      << std::endl;



            // Create streaming state

            auto ss = std::make_shared<HttpRequest::H2StreamingResponse>();

            ss->streamId = sid;
@@ -778,8 +771,6 @@ bool libhttppp::HttpEvent::Http2RequestEvent(netplus::con &curcon, 


    // Process all complete frames in RecvData

reprocess:

    std::cerr << "[H2-REPROCESS] RecvData.size=" << cureq.RecvData.size()

              << " off=" << off << std::endl;

    while (off + H2_FRAME_HEADER_LEN <= cureq.RecvData.size()) {

        const char *data = cureq.RecvData.data();

        uint32_t flen = (static_cast<uint8_t>(data[off]) << 16) |
@@ -793,17 +784,11 @@ reprocess: 
                       static_cast<uint8_t>(data[off + 8]);



        if (off + H2_FRAME_HEADER_LEN + flen > cureq.RecvData.size()) {

            std::cerr << "[H2-FRAME] INCOMPLETE: need " << (off + H2_FRAME_HEADER_LEN + flen)

                      << " have " << cureq.RecvData.size() << std::endl;

            break; // Incomplete frame, wait for more data

        }



        off += H2_FRAME_HEADER_LEN;



        std::cerr << "[H2-FRAME] type=" << (int)ftype

                  << " flags=0x" << std::hex << (int)fflags << std::dec

                  << " sid=" << sid << " flen=" << flen << std::endl;



        switch (ftype) {

        case H2_FRAME_SETTINGS:

            if (!(fflags & H2_FLAG_ACK)) {
@@ -996,11 +981,6 @@ reprocess: 
                    if (swit != cureq.h2state().peerStreamWindows.end())

                        swit->second += static_cast<int32_t>(increment);

                }

                std::cerr << "[H2-FC] WINDOW_UPDATE sid=" << sid

                          << " inc=" << increment

                          << " sw=" << (sid ? cureq.h2state().peerStreamWindows.count(sid) ? cureq.h2state().peerStreamWindows[sid] : 0 : 0)

                          << " cw=" << cureq.h2state().peerConnWindow

                          << std::endl;

                // Resume any parked streaming responses

                _resumeH2Streams(cureq, out, tid, args);

            }
@@ -1018,11 +998,6 @@ reprocess: 
    }



done:

    std::cerr << "[H2-DONE] out.size=" << out.size()

              << " SendData.size=" << cureq.SendData.size()

              << " RecvData.size=" << cureq.RecvData.size()

              << " off=" << off

              << std::endl;

    if (!out.empty()) {

        // DEBUG: validate H2 frames before writing to SendData

        {