Searched refs:incoming_header_ (Results 1 – 2 of 2) sorted by relevance
561 if (!incoming_header_.has_value()) { in ProcessRead()566 amessage& msg = incoming_header_.emplace(); in ProcessRead()569 incoming_header_ = msg; in ProcessRead()575 size_t bytes_left = incoming_header_->data_length - incoming_payload_.size(); in ProcessRead()583 if (incoming_header_->data_length == incoming_payload_.size()) { in ProcessRead()585 packet->msg = *incoming_header_; in ProcessRead()591 incoming_header_.reset(); in ProcessRead()724 std::optional<amessage> incoming_header_; member
194 CHECK(!self->incoming_header_); in header_read_cb()195 amessage& amsg = self->incoming_header_.emplace(); in header_read_cb()207 self->incoming_header_.reset(); in header_read_cb()244 CHECK(self->incoming_header_.has_value()); in payload_read_cb()245 self->HandlePacket(*self->incoming_header_, std::move(read_block->block)); in payload_read_cb()246 self->incoming_header_.reset(); in payload_read_cb()724 incoming_header_.reset(); in CloseDevice()878 std::optional<amessage> incoming_header_ GUARDED_BY(read_mutex_);