Searched refs:incoming_payload_ (Results 1 – 2 of 2) sorted by relevance
575 size_t bytes_left = incoming_header_->data_length - incoming_payload_.size(); in ProcessRead()580 incoming_payload_.append(std::move(block->payload)); in ProcessRead()583 if (incoming_header_->data_length == incoming_payload_.size()) { in ProcessRead()588 packet->payload = std::move(incoming_payload_).coalesce(); in ProcessRead()593 auto free_block = incoming_payload_.clear(); in ProcessRead()725 IOVector incoming_payload_; member
725 incoming_payload_.clear(); in CloseDevice()879 IOVector incoming_payload_ GUARDED_BY(read_mutex_);