Function transfer_all_bytes

plugins/slice/transfer.cc:86–123

transfer all bytes from the server (error condition)

// transfer all bytes from the server (error condition)
int64_t
transfer_all_bytes(Data *const data)
{
  // nothing to transfer if there's no source.
  if (nullptr == data->m_upstream.m_read.m_reader || !data->m_dnstream.m_write.isOpen()) {
    return 0;
  }

  int64_t consumed = 0; // input vio bytes visited

  TSIOBufferReader const reader     = data->m_upstream.m_read.m_reader;
  TSIOBuffer const       output_buf = data->m_dnstream.m_write.m_iobuf;

  int64_t const read_avail = TSIOBufferReaderAvail(reader);

  if (0 < read_avail) {
    int64_t const copied = TSIOBufferCopy(output_buf, reader, read_avail, 0);

    if (0 < copied) {
      TSIOBufferReaderConsume(reader, copied);
      consumed = copied;

      TSVIO const output_vio = data->m_dnstream.m_write.m_vio;
      if (nullptr != output_vio) {
        TSVIOReenable(output_vio);
      }
    }
  }

  if (0 < consumed) {
    TSVIO const input_vio = data->m_upstream.m_read.m_vio;
    if (nullptr != input_vio) {
      TSVIONDoneSet(input_vio, TSVIONDoneGet(input_vio) + consumed);
    }
  }

  return consumed;
}