Method ext_read_data

src/proxy/FetchSM.cc:711–770

}

ssize_t
FetchSM::ext_read_data(char *buf, size_t len)
{
  const char     *start;
  IOBufferReader *reader;
  IOBufferBlock  *blk, *next_blk;
  int64_t         already, blk_len, need, wavail;

  if (fetch_flags & TS_FETCH_FLAGS_NEWLOCK) {
    MUTEX_TRY_LOCK(lock, mutex, this_ethread());
    if (!lock.is_locked()) {
      return 0;
    }
  }

  if (!header_done) {
    return 0;
  }

  if (check_chunked() && (fetch_flags & TS_FETCH_FLAGS_DECHUNK)) {
    reader = chunked_handler.dechunked_reader;
  } else {
    reader = resp_reader;
  }

  already = 0;
  if (reader->block) {
    reader->skip_empty_blocks();
  }
  blk = reader->get_current_block();
  while (blk) {
    wavail   = len - already;
    next_blk = blk->next.get();
    start    = blk->start();
    blk_len  = blk->read_avail();
    if (reader->block.get() == blk) {
      start   += reader->start_offset;
      blk_len -= reader->start_offset;
      if (blk_len < 0) {
        blk_len = 0;
      }
    }
    need = blk_len > wavail ? wavail : blk_len;

    memcpy(&buf[already], start, need);
    already += need;

    if (already >= static_cast<int64_t>(len)) {
      break;
    }

    blk = next_blk;
  }

  resp_received_body_len += already;
  reader->consume(already);

  read_vio->reenable();