Method _on_qpack_decode_complete

src/proxy/http3/Http3HeaderVIOAdaptor.cc:103–156

}

int
Http3HeaderVIOAdaptor::_on_qpack_decode_complete()
{
  // Currently trailer support for h3 is not implemented.
  constexpr static bool NON_TRAILER = false;
  if (!HeaderValidator::is_h2_h3_header_valid(this->_header, http_hdr_type_get(this->_header.m_http) == HTTP_TYPE_RESPONSE,
                                              NON_TRAILER)) {
    Dbg(dbg_ctl_http3, "Header is invalid");
    return -1;
  }
  int res = this->_hvc.convert(this->_header, 3, 1);
  if (res != 0) {
    Dbg(dbg_ctl_http3, "PARSE_RESULT_ERROR");
    return -1;
  }

  // FIXME: response header might be delayed from first response body because of callback from QPACK
  // Workaround fix for mixed response header and body
  if (http_hdr_type_get(this->_header.m_http) == HTTP_TYPE_RESPONSE) {
    return 0;
  }

  SCOPED_MUTEX_LOCK(lock, this->_sink_vio->mutex, this_ethread());
  MIOBuffer *writer = this->_sink_vio->get_writer();

  // TODO: Http2Stream::send_request has same logic. It originally comes from HttpSM::write_header_into_buffer.
  // a). Make HttpSM::write_header_into_buffer static
  //   or
  // b). Add interface to HTTPHdr to dump data
  //   or
  // c). Add interface to HttpSM to handle HTTPHdr directly
  int            bufindex;
  int            dumpoffset = 0;
  int            done, tmp;
  IOBufferBlock *block;
  do {
    bufindex = 0;
    tmp      = dumpoffset;
    block    = writer->get_current_block();
    if (!block) {
      writer->add_block();
      block = writer->get_current_block();
    }
    done        = this->_header.print(block->end(), block->write_avail(), &bufindex, &tmp);
    dumpoffset += bufindex;
    writer->fill(bufindex);
    if (!done) {
      writer->add_block();
    }
  } while (!done);

  this->_is_complete = true;
  return 1;
}