Method xmit

src/proxy/http2/Http2CommonSession.cc:158–179

}

int64_t
Http2CommonSession::xmit(const Http2TxFrame &frame, bool flush)
{
  int64_t len                       = frame.write_to(this->write_buffer);
  this->_pending_sending_data_size += len;
  if (!flush) {
    // Flush if we already use half of the buffer to avoid adding a new block to the chain.
    // A frame size can be 16MB at maximum so blocks can be added, but that's fine.
    if (this->_pending_sending_data_size >= this->_write_size_threshold) {
      flush = true;
    } else {
      // Observe that schedule_transmit will only schedule the first time we
      // don't flush because the threshold is not met.
      this->connection_state.schedule_retransmit(HRTIME_MSECONDS(Http2::write_time_threshold));
    }
  }
  if (flush) {
    this->flush();
  }

  return len;
}

void
Http2CommonSession::flush()