| 32 | } // end anonymous namespace |
| 33 | |
| 34 | Http3ErrorUPtr |
| 35 | Http3FrameCollector::on_write_ready(QUICStreamId stream_id, MIOBuffer &writer, size_t &nwritten, bool &all_done) |
| 36 | { |
| 37 | all_done = true; |
| 38 | nwritten = 0; |
| 39 | |
| 40 | for (auto g : this->_generators) { |
| 41 | if (g->is_done()) { |
| 42 | continue; |
| 43 | } |
| 44 | size_t len = 0; |
| 45 | Http3FrameUPtr frame = g->generate_frame(); |
| 46 | if (frame) { |
| 47 | auto b = frame->to_io_buffer_block(); |
| 48 | len = writer.write(b.get(), INT64_MAX, 0); |
| 49 | nwritten += len; |
| 50 | Dbg(dbg_ctl_http3, "[TX] [%" PRIu64 "] | %s size=%zu", stream_id, Http3DebugNames::frame_type(frame->type()), len); |
| 51 | } |
| 52 | |
| 53 | all_done &= g->is_done(); |
| 54 | } |
| 55 | |
| 56 | return Http3ErrorUPtr(nullptr); |
| 57 | } |
| 58 | |
| 59 | void |
| 60 | Http3FrameCollector::add_generator(Http3FrameGenerator *generator) |
no test coverage detected