/system/update_engine/payload_consumer/ |
D | payload_metadata.cc | 51 const brillo::Blob& payload, ErrorCode* error) { in ParsePayloadHeader() argument 53 if (payload.size() < kDeltaManifestSizeOffset) in ParsePayloadHeader() 57 if (memcmp(payload.data(), kDeltaMagic, sizeof(kDeltaMagic)) != 0) { in ParsePayloadHeader() 65 if (payload.size() < manifest_offset) in ParsePayloadHeader() 72 &payload[kDeltaVersionOffset], in ParsePayloadHeader() 89 &payload[kDeltaManifestSizeOffset], in ParsePayloadHeader() 107 &payload[metadata_signature_size_offset], in ParsePayloadHeader() 120 bool PayloadMetadata::ParsePayloadHeader(const brillo::Blob& payload) { in ParsePayloadHeader() argument 122 return ParsePayloadHeader(payload, &error) == MetadataParseResult::kSuccess; in ParsePayloadHeader() 125 bool PayloadMetadata::GetManifest(const brillo::Blob& payload, in GetManifest() argument [all …]
|
D | install_plan.cc | 72 for (const auto& payload : payloads) { in Dump() local 76 PayloadUrlsToString(payload.payload_urls).c_str(), in Dump() 77 payload.size, in Dump() 78 payload.metadata_size, in Dump() 79 payload.metadata_signature.c_str(), in Dump() 80 base::HexEncode(payload.hash.data(), payload.hash.size()).c_str(), in Dump() 81 InstallPayloadTypeToString(payload.type).c_str()); in Dump()
|
D | payload_metadata.h | 57 MetadataParseResult ParsePayloadHeader(const brillo::Blob& payload, 60 bool ParsePayloadHeader(const brillo::Blob& payload); 70 const brillo::Blob& payload, 88 bool GetManifest(const brillo::Blob& payload,
|
/system/nvram/messages/tests/ |
D | nvram_messages_test.cpp | 39 request.payload.Activate<COMMAND_GET_INFO>(); in TEST() 44 EXPECT_EQ(COMMAND_GET_INFO, decoded.payload.which()); in TEST() 45 EXPECT_TRUE(decoded.payload.get<COMMAND_GET_INFO>()); in TEST() 51 response.payload.Activate<COMMAND_GET_INFO>(); in TEST() 54 response.payload.Activate<COMMAND_GET_INFO>(); in TEST() 69 EXPECT_EQ(COMMAND_GET_INFO, decoded.payload.which()); in TEST() 71 decoded.payload.get<COMMAND_GET_INFO>(); in TEST() 89 request.payload.Activate<COMMAND_CREATE_SPACE>(); in TEST() 101 EXPECT_EQ(COMMAND_CREATE_SPACE, decoded.payload.which()); in TEST() 103 decoded.payload.get<COMMAND_CREATE_SPACE>(); in TEST() [all …]
|
/system/update_engine/payload_generator/ |
D | payload_signer.cc | 100 brillo::Blob payload; in AddSignatureBlobToPayload() local 101 TEST_AND_RETURN_FALSE(utils::ReadFile(payload_path, &payload)); in AddSignatureBlobToPayload() 103 TEST_AND_RETURN_FALSE(payload_metadata.ParsePayloadHeader(payload)); in AddSignatureBlobToPayload() 109 memcpy(payload.data() + manifest_offset, in AddSignatureBlobToPayload() 114 payload.erase(payload.begin() + metadata_size, in AddSignatureBlobToPayload() 115 payload.begin() + metadata_size + metadata_signature_size); in AddSignatureBlobToPayload() 116 payload.insert(payload.begin() + metadata_size, in AddSignatureBlobToPayload() 123 TEST_AND_RETURN_FALSE(payload_metadata.GetManifest(payload, &manifest)); in AddSignatureBlobToPayload() 142 payload.size() - metadata_size - metadata_signature_size, in AddSignatureBlobToPayload() 150 payload.erase(payload.begin() + manifest_offset, in AddSignatureBlobToPayload() [all …]
|
/system/nvram/messages/ |
D | nvram_messages.cpp | 147 MakeOneOfField(1, &Request::payload, COMMAND_GET_INFO), 148 MakeOneOfField(2, &Request::payload, COMMAND_CREATE_SPACE), 149 MakeOneOfField(3, &Request::payload, COMMAND_GET_SPACE_INFO), 150 MakeOneOfField(4, &Request::payload, COMMAND_DELETE_SPACE), 151 MakeOneOfField(5, &Request::payload, COMMAND_DISABLE_CREATE), 152 MakeOneOfField(6, &Request::payload, COMMAND_WRITE_SPACE), 153 MakeOneOfField(7, &Request::payload, COMMAND_READ_SPACE), 154 MakeOneOfField(8, &Request::payload, COMMAND_LOCK_SPACE_WRITE), 155 MakeOneOfField(9, &Request::payload, COMMAND_LOCK_SPACE_READ), 156 MakeOneOfField(10, &Request::payload, COMMAND_WIPE_STORAGE), [all …]
|
/system/gatekeeper/ |
D | gatekeeper_messages.cpp | 119 gatekeeper_error_t GateKeeperMessage::Deserialize(const uint8_t *payload, const uint8_t *end) { in Deserialize() argument 120 if (!fitsBuffer(payload, end, sizeof(serial_header_t))) return ERROR_INVALID; in Deserialize() 121 const serial_header_t *header = reinterpret_cast<const serial_header_t *>(payload); in Deserialize() 124 payload += sizeof(*header); in Deserialize() 126 return nonErrorDeserialize(payload, end); in Deserialize() 130 if (!fitsBuffer(payload, end, sizeof(retry_timeout))) { in Deserialize() 133 memcpy(&retry_timeout, payload, sizeof(retry_timeout)); in Deserialize() 165 gatekeeper_error_t VerifyRequest::nonErrorDeserialize(const uint8_t *payload, const uint8_t *end) { in nonErrorDeserialize() argument 171 if (!fitsBuffer(payload, end, sizeof(challenge))) return ERROR_INVALID; in nonErrorDeserialize() 173 memcpy(&challenge, payload, sizeof(challenge)); in nonErrorDeserialize() [all …]
|
/system/core/liblog/include/log/ |
D | log.h | 81 int __android_log_bwrite(int32_t tag, const void* payload, size_t len); 82 int __android_log_btwrite(int32_t tag, char type, const void* payload, 84 int __android_log_bswrite(int32_t tag, const char* payload); 86 int __android_log_stats_bwrite(int32_t tag, const void* payload, size_t len); 88 #define android_bWriteLog(tag, payload, len) \ argument 89 __android_log_bwrite(tag, payload, len) 90 #define android_btWriteLog(tag, type, payload, len) \ argument 91 __android_log_btwrite(tag, type, payload, len)
|
/system/bt/gd/l2cap/internal/ |
D | le_credit_based_channel_data_controller_test.cc | 31 std::unique_ptr<packet::BasePacketBuilder> CreateSdu(std::vector<uint8_t> payload) { in CreateSdu() argument 32 return std::make_unique<packet::RawBuilder>(std::move(payload)); in CreateSdu() 87 auto payload = first_le_info_view.GetPayload(); in TEST_F() local 88 std::string data = std::string(payload.begin(), payload.end()); in TEST_F() 109 auto payload = first_le_info_view.GetPayload(); in TEST_F() local 110 std::string data = std::string(payload.begin(), payload.end()); in TEST_F() 119 payload = pdu_view.GetPayload(); in TEST_F() 120 data = std::string(payload.begin(), payload.end()); in TEST_F() 135 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F() local 136 EXPECT_NE(payload, nullptr); in TEST_F() [all …]
|
D | enhanced_retransmission_mode_channel_data_controller_test.cc | 31 std::unique_ptr<packet::BasePacketBuilder> CreateSdu(std::vector<uint8_t> payload) { in CreateSdu() argument 33 raw_builder->AddOctets(payload); in CreateSdu() 90 auto payload = i_frame_view.GetPayload(); in TEST_F() local 91 std::string data = std::string(payload.begin(), payload.end()); in TEST_F() 108 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F() local 109 EXPECT_NE(payload, nullptr); in TEST_F() 110 std::string data = std::string(payload->begin(), payload->end()); in TEST_F() 134 auto payload = channel_queue.GetUpEnd()->TryDequeue(); in TEST_F() local 135 EXPECT_NE(payload, nullptr); in TEST_F() 136 std::string data = std::string(payload->begin(), payload->end()); in TEST_F() [all …]
|
/system/netd/server/ |
D | WakeupController.cpp | 53 static void extractIpPorts(WakeupController::ReportArgs& args, Slice payload) { in extractIpPorts() argument 57 if (extract(payload, header) < sizeof(struct tcphdr)) { in extractIpPorts() 66 if (extract(payload, header) < sizeof(struct udphdr)) { in extractIpPorts() 78 static void extractIpHeader(WakeupController::ReportArgs& args, Slice payload) { in extractIpHeader() argument 82 if (extract(payload, header) < sizeof(struct iphdr)) { in extractIpHeader() 91 extractIpPorts(args, drop(payload, header.ihl * 4)); // ipv4 IHL counts 32 bit words. in extractIpHeader() 96 if (extract(payload, header) < sizeof(struct ip6_hdr)) { in extractIpHeader() 107 extractIpPorts(args, drop(payload, sizeof(header))); in extractIpHeader() 135 const auto attrHandler = [&args, &parseAgain](const nlattr attr, const Slice payload) { in init() argument 139 extract(payload, ts); in init() [all …]
|
/system/core/gatekeeperd/include/gatekeeper/ |
D | GateKeeperResponse.h | 35 std::vector<uint8_t> payload = {}, bool should_reenroll = false) 38 payload_(std::move(payload)), in response_code_() 51 static GateKeeperResponse ok(std::vector<uint8_t> payload, bool reenroll = false) { 52 return GateKeeperResponse(ResponseCode::OK, 0, std::move(payload), reenroll); 58 const std::vector<uint8_t>& payload() const { return payload_; } in payload() function 60 void payload(std::vector<uint8_t> payload) { payload_ = payload; } in payload() argument
|
/system/core/adb/client/ |
D | transport_usb.cpp | 86 p->payload.resize(len); in UsbReadPayload() 87 int rc = usb_read(h, &p->payload[0], p->payload.size()); in UsbReadPayload() 92 p->payload.resize(rc); in UsbReadPayload() 95 p->payload.resize(p->msg.data_length); in UsbReadPayload() 96 return usb_read(h, &p->payload[0], p->payload.size()); in UsbReadPayload() 141 p->payload.resize(p->msg.data_length); in remote_read() 142 if (usb_read(usb, &p->payload[0], p->payload.size()) != in remote_read() 143 static_cast<int>(p->payload.size())) { in remote_read() 170 if (packet->msg.data_length != 0 && usb_write(handle_, packet->payload.data(), size) != size) { in Write()
|
/system/bt/gd/cert/ |
D | captures.py | 32 …lambda packet: packet.payload[0:5] == b'\x0e\x0a\x01\x09\x10', lambda packet: hci_packets.ReadBdAd… 34 … hci_packets.EventPacketView(bt_packets.PacketViewLittleEndian(list(packet.payload)))))) 39 …lambda packet: packet.payload[0:2] == b'\x04\x0a', lambda packet: hci_packets.ConnectionRequestVie… 40 … hci_packets.EventPacketView(bt_packets.PacketViewLittleEndian(list(packet.payload))))) 45 …lambda packet: packet.payload[0:3] == b'\x03\x0b\x00', lambda packet: hci_packets.ConnectionComple… 46 … hci_packets.EventPacketView(bt_packets.PacketViewLittleEndian(list(packet.payload))))) 51 …lambda packet: packet.payload[0:2] == b'\x05\x04', lambda packet: hci_packets.DisconnectionComplet… 52 … hci_packets.EventPacketView(bt_packets.PacketViewLittleEndian(list(packet.payload))))) 57 …lambda packet: packet.payload[0] == 0x3e and (packet.payload[2] == 0x01 or packet.payload[2] == 0x… 60 … hci_packets.EventPacketView(bt_packets.PacketViewLittleEndian(list(packet.payload))))))
|
D | matchers.py | 230 def IFrame(tx_seq=None, payload=None, f=None): argument 231 …return lambda packet: L2capMatchers._is_matching_information_frame(packet, tx_seq, payload, f, fcs… 234 def IFrameWithFcs(tx_seq=None, payload=None, f=None): argument 235 …return lambda packet: L2capMatchers._is_matching_information_frame(packet, tx_seq, payload, f, fcs… 238 def IFrameStart(tx_seq=None, payload=None, f=None): argument 239 …a packet: L2capMatchers._is_matching_information_start_frame(packet, tx_seq, payload, f, fcs=False) 242 def Data(payload): argument 243 return lambda packet: packet.GetPayload().GetBytes() == payload 246 def FirstLeIFrame(payload, sdu_size): argument 247 return lambda packet: L2capMatchers._is_matching_first_le_i_frame(packet, payload, sdu_size) [all …]
|
/system/update_engine/scripts/ |
D | payload_info_unittest.py | 205 def TestCommand(self, payload_cmd, payload, expected_out): argument 211 with mock.patch.object(update_payload, 'Payload', return_value=payload), \ 225 payload = FakePayload() 234 self.TestCommand(payload_cmd, payload, expected_out) 240 payload = FakePayload() 263 self.TestCommand(payload_cmd, payload, expected_out) 269 payload = FakePayload() 281 self.TestCommand(payload_cmd, payload, expected_out) 287 payload = FakePayload() 298 self.TestCommand(payload_cmd, payload, expected_out) [all …]
|
D | payload_info.py | 62 self.payload = None 66 header = self.payload.header 72 manifest = self.payload.manifest 83 header = self.payload.header 90 signatures_blob = self.payload.ReadDataBlob( 97 manifest = self.payload.manifest 103 signatures_blob = self.payload.ReadDataBlob(manifest.signatures_offset, 199 self.payload = update_payload.Payload(self.options.payload_file) 200 self.payload.Init() 206 self._DisplayStats(self.payload.manifest) [all …]
|
/system/bt/gd/l2cap/classic/cert/ |
D | l2cap_test.py | 159 assertThat(cert_channel).emits(L2capMatchers.IFrame(tx_seq=0, payload=b'abc' * 34)) 161 cert_channel.send_i_frame(tx_seq=0, req_seq=1, payload=SAMPLE_PACKET) 542 assertThat(cert_channel).emits(L2capMatchers.IFrame(tx_seq=0, payload=b'abc')) 556 assertThat(cert_channel).emits(L2capMatchers.IFrameWithFcs(payload=b"abc")) 572 assertThat(cert_channel).emits(L2capMatchers.IFrameWithFcs(payload=b"abc")) 585 assertThat(cert_channel).emits(L2capMatchers.IFrame(tx_seq=0, payload=b"abc")) 597 cert_channel.send_i_frame(tx_seq=0, req_seq=0, payload=SAMPLE_PACKET) 611 assertThat(cert_channel).emits(L2capMatchers.IFrameWithFcs(tx_seq=0, payload=b"abc")) 623 cert_channel.send_i_frame(tx_seq=0, req_seq=0, payload=SAMPLE_PACKET, fcs=FcsType.DEFAULT) 639 assertThat(cert_channel).emits(L2capMatchers.IFrame(tx_seq=0, payload=b"abc")) [all …]
|
/system/core/liblog/ |
D | README.protocol.md | 15 android_event_*_t payload[...]; 63 The payload, excluding the header, has a max size of LOGGER_ENTRY_MAX_PAYLOAD. 69 ## `string` payload 75 This payload is used for the `__android_log_buf_write()` family of functions. 77 ## `binary` payload 84 element in payload must be an android_event_list_t. 86 This payload is used for the `__android_log_bwrite()` family of functions. It is additionally used 91 logd sends a `logger_entry` struct to liblog followed by the payload. The payload is identical to
|
/system/core/liblog/tests/ |
D | liblog_benchmark.cpp | 214 buffer.payload.type = EVENT_TYPE_INT; in BM_pmsg_short() 216 buffer.payload.data = snapshot; in BM_pmsg_short() 223 buffer.payload.data = snapshot; in BM_pmsg_short() 268 android_log_event_int_t payload; in BM_pmsg_short_aligned() member 289 buffer->payload.header.tag = 0; in BM_pmsg_short_aligned() 290 buffer->payload.payload.type = EVENT_TYPE_INT; in BM_pmsg_short_aligned() 292 buffer->payload.payload.data = snapshot; in BM_pmsg_short_aligned() 296 buffer->payload.payload.data = snapshot; in BM_pmsg_short_aligned() 343 android_log_event_int_t payload; in BM_pmsg_short_unaligned1() member 364 buffer->payload.header.tag = 0; in BM_pmsg_short_unaligned1() [all …]
|
/system/core/adb/daemon/ |
D | usb.cpp | 121 Payload payload; member 218 if (!packet->payload.empty()) { in Write() 222 auto payload = std::make_shared<Block>(std::move(packet->payload)); in Write() local 224 size_t len = payload->size(); in Write() 229 CreateWriteBlock(payload, offset, write_size, next_write_id_++)); in Write() 490 if (block->payload.capacity() >= kUsbReadSize) { in PrepareReadBlock() 491 block->payload.resize(kUsbReadSize); in PrepareReadBlock() 493 block->payload = Block(kUsbReadSize); in PrepareReadBlock() 496 block->control.aio_buf = reinterpret_cast<uintptr_t>(block->payload.data()); in PrepareReadBlock() 497 block->control.aio_nbytes = block->payload.size(); in PrepareReadBlock() [all …]
|
/system/bt/packet/tests/ |
D | packet_test_helper.h | 44 std::vector<uint8_t> payload) { in Make() argument 45 size_t end = payload.size(); in Make() 46 return Make(std::move(payload), 0, end); in Make() 50 std::vector<uint8_t> payload, size_t start, size_t end) { in Make() argument 55 pkt->data_ = std::make_shared<std::vector<uint8_t>>(std::move(payload)); in Make()
|
/system/bt/gd/hal/ |
D | facade.proto | 18 bytes payload = 1; field 22 bytes payload = 1; field 26 bytes payload = 1; field 30 bytes payload = 1; field
|
/system/bt/gd/hci/acl_manager/ |
D | assembler.h | 76 PacketView<kLittleEndian> payload = packet.GetPayload(); in on_incoming_packet() local 77 auto payload_size = payload.size(); in on_incoming_packet() 92 recombination_stage_.AppendPacketView(payload); in on_incoming_packet() 96 payload = recombination_stage_; in on_incoming_packet() 107 recombination_stage_ = payload; in on_incoming_packet() 116 incoming_queue_.push(payload); in on_incoming_packet()
|
/system/core/adb/pairing_connection/ |
D | pairing_connection.cpp | 49 uint32_t payload; // Size of the payload in bytes member 102 bool WriteHeader(const PairingPacketHeader* header, std::string_view payload); 205 std::string_view payload) { in WriteHeader() argument 207 network_header.payload = htonl(network_header.payload); in WriteHeader() 210 !tls_->WriteFully(payload)) { in WriteHeader() 242 header->payload = ntohl(*(reinterpret_cast<uint32_t*>(p))); in ReadHeader() 243 if (header->payload == 0 || header->payload > kMaxPayloadSize) { in ReadHeader() 244 LOG(ERROR) << "header payload not within a safe payload size (size=" << header->payload in ReadHeader() 258 header->payload = payload_size; in CreateHeader() 296 uint32_t payload = pairing_auth_msg_size(auth_.get()); in DoExchangeMsgs() local [all …]
|