Method init_by_action

src/proxy/http/HttpTunnel.cc:78–121

}

void
ChunkedHandler::init_by_action(IOBufferReader *buffer_in, Action action, bool drop_chunked_trailers, bool parse_chunk_strictly)
{
  running_sum                = 0;
  num_digits                 = 0;
  cur_chunk_size             = 0;
  cur_chunk_bytes_left       = 0;
  truncation                 = false;
  this->action               = action;
  this->strict_chunk_parsing = parse_chunk_strictly;

  switch (action) {
  case ACTION_DOCHUNK:
    dechunked_reader                   = buffer_in->mbuf->clone_reader(buffer_in);
    dechunked_reader->mbuf->water_mark = min_block_transfer_bytes;
    chunked_buffer                     = new_MIOBuffer(CHUNK_IOBUFFER_SIZE_INDEX);
    chunked_size                       = 0;
    break;
  case ACTION_DECHUNK:
    chunked_reader   = buffer_in->mbuf->clone_reader(buffer_in);
    dechunked_buffer = new_MIOBuffer(BUFFER_SIZE_INDEX_256);
    dechunked_size   = 0;
    break;
  case ACTION_PASSTHRU:
    chunked_reader = buffer_in->mbuf->clone_reader(buffer_in);
    if (drop_chunked_trailers) {
      // Note that dropping chunked trailers only applies in the passthrough
      // case in which we are filtering out chunked trailers as we proxy.
      this->drop_chunked_trailers = drop_chunked_trailers;

      // We only need an intermediate buffer when modifying the chunks by
      // filtering out the trailers. Otherwise, a simple passthrough needs no
      // intermediary buffer as consumers will simply read directly from
      // chunked_reader.
      chunked_buffer = new_MIOBuffer(CHUNK_IOBUFFER_SIZE_INDEX);
      chunked_size   = 0;
    }
    break;
  default:
    ink_release_assert(!"Unknown action");
  }

  return;
}

void
ChunkedHandler::clear()