Method _on_encoder_stream_read_ready

src/proxy/http3/QPACK.cc:1130–1189

}

int
QPACK::_on_encoder_stream_read_ready(IOBufferReader &reader)
{
  while (reader.is_read_avail_more_than(0)) {
    uint8_t buf;
    reader.memcpy(&buf, 1);
    if (buf & 0x80) { // Insert With Name Reference
      bool        is_static;
      uint16_t    index;
      const char *name;
      size_t      name_len;
      const char *dummy;
      size_t      dummy_len;
      char       *value;
      size_t      value_len;
      if (this->_read_insert_with_name_ref(reader, is_static, index, this->_arena, &value, value_len) < 0) {
        this->_abort_decode();
        return EVENT_DONE;
      }
      QPACKDebug("Received Insert With Name Ref: is_static=%d, index=%d, value=%.*s", is_static, index, static_cast<int>(value_len),
                 value);
      StaticTable::lookup(index, &name, &name_len, &dummy, &dummy_len);
      this->_dynamic_table.insert_entry(name, name_len, value, value_len);
      this->_arena.str_free(value);
    } else if (buf & 0x40) { // Insert Without Name Reference
      char  *name;
      size_t name_len;
      char  *value;
      size_t value_len;
      if (this->_read_insert_without_name_ref(reader, this->_arena, &name, name_len, &value, value_len) < 0) {
        this->_abort_decode();
        return EVENT_DONE;
      }
      QPACKDebug("Received Insert Without Name Ref: name=%.*s, value=%.*s", static_cast<int>(name_len), name,
                 static_cast<int>(value_len), value);
      this->_dynamic_table.insert_entry(name, name_len, value, value_len);
      this->_arena.str_free(name);
    } else if (buf & 0x20) { // Dynamic Table Size Update
      uint16_t max_size;
      if (this->_read_dynamic_table_size_update(reader, max_size) < 0) {
        this->_abort_decode();
        return EVENT_DONE;
      }
      QPACKDebug("Received Dynamic Table Size Update: max_size=%d", max_size);
      this->_dynamic_table.update_maximum_size(max_size);
    } else { // Duplicates
      uint16_t index;
      if (this->_read_duplicate(reader, index) < 0) {
        this->_abort_decode();
        return EVENT_DONE;
      }
      QPACKDebug("Received Duplicate: index=%d", index);
      this->_dynamic_table.duplicate_entry(index);
    }

    this->_resume_decode();
  }