Searched refs:read_header_ (Results 1 – 1 of 1) sorted by relevance
108 if (!read_header_ && read_buffer_.size() >= sizeof(amessage)) { in Run()111 read_header_ = std::make_unique<amessage>(); in Run()112 memcpy(read_header_.get(), header_buf.data(), sizeof(amessage)); in Run()115 if (read_header_ && read_buffer_.size() >= read_header_->data_length) { in Run()116 auto data_chain = read_buffer_.take_front(read_header_->data_length); in Run()121 packet->msg = *read_header_; in Run()123 read_header_ = nullptr; in Run()225 std::unique_ptr<amessage> read_header_; member