Searched refs:amessage (Results 1 – 7 of 7) sorted by relevance
108 if (!read_header_ && read_buffer_.size() >= sizeof(amessage)) { in Run()109 auto header_buf = read_buffer_.take_front(sizeof(amessage)).coalesce(); in Run()110 CHECK_EQ(sizeof(amessage), header_buf.size()); in Run()111 read_header_ = std::make_unique<amessage>(); in Run()112 memcpy(read_header_.get(), header_buf.data(), sizeof(amessage)); in Run()225 std::unique_ptr<amessage> read_header_;
48 std::string dump_header(const amessage* msg);
123 struct amessage { struct134 amessage msg; argument
189 std::string dump_header(const amessage* msg) { in dump_header()
461 if (!DispatchRead(&packet->msg, sizeof(amessage))) { in Read()
44 static int UsbReadMessage(usb_handle* h, amessage* msg) { in UsbReadMessage()130 if (usb_read(usb, &p->msg, sizeof(amessage)) != sizeof(amessage)) { in remote_read()
577 if (block->payload.size() != sizeof(amessage)) { in ProcessRead()581 amessage& msg = incoming_header_.emplace(); in ProcessRead()721 std::optional<amessage> incoming_header_;