Searched refs:amessage (Results 1 – 9 of 9) sorted by relevance
| /packages/modules/adb/ |
| D | transport_fd.cpp | 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_;
|
| D | README.md | 62 …amessage constructs exist only to wrap data while it transits on a Transport. An asocket handles a…
86 … on an unique byte stream. Without entering too much into details, the amessage fields arg1 and a…
|
| D | types.h | 125 struct amessage { struct
136 amessage msg; argument
|
| D | adb_utils.h | 48 std::string dump_header(const amessage* msg);
|
| D | adb_utils.cpp | 189 std::string dump_header(const amessage* msg) { in dump_header()
|
| D | transport.cpp | 473 if (!DispatchRead(&packet->msg, sizeof(amessage))) { in Read()
|
| /packages/modules/adb/client/ |
| D | usb_libusb.cpp | 135 void HandlePacket(amessage& msg, std::optional<Block> payload) { in HandlePacket()
185 if (transfer->actual_length != sizeof(amessage)) { in header_read_cb()
195 amessage& amsg = self->incoming_header_.emplace(); in header_read_cb()
208 self->SubmitRead(read_block, sizeof(amessage)); in header_read_cb()
249 self->SubmitRead(&self->header_read_, sizeof(amessage)); in payload_read_cb()
747 SubmitRead(&header_read_, sizeof(amessage)); in StartImpl()
878 std::optional<amessage> incoming_header_ GUARDED_BY(read_mutex_);
|
| D | transport_usb.cpp | 42 static int UsbReadMessage(usb_handle* h, amessage* msg) { in UsbReadMessage()
|
| /packages/modules/adb/daemon/ |
| D | usb.cpp | 562 if (block->payload.size() != sizeof(amessage)) { in ProcessRead()
566 amessage& msg = incoming_header_.emplace(); in ProcessRead()
724 std::optional<amessage> incoming_header_;
|