Searched refs:incoming_payload_ (Results 1 – 2 of 2) sorted by relevance
571 size_t bytes_left = incoming_header_->data_length - incoming_payload_.size(); in ProcessRead()576 incoming_payload_.append(std::move(block->payload)); in ProcessRead()579 if (incoming_header_->data_length == incoming_payload_.size()) { in ProcessRead()584 packet->payload = std::move(incoming_payload_).coalesce(); in ProcessRead()589 auto free_block = incoming_payload_.clear(); in ProcessRead()707 IOVector incoming_payload_; member
683 IOVector incoming_payload_ GUARDED_BY(read_mutex_);