| /external/android-clat/ |
| D | dump.c | 135 size_t payload_size) { in dump_udp_generic() argument
139 temp_checksum = ip_checksum_add(temp_checksum, payload, payload_size); in dump_udp_generic()
151 size_t payload_size) { in dump_udp() argument
153 temp_checksum = ipv4_pseudo_header_checksum(ip, sizeof(*udp) + payload_size); in dump_udp()
154 dump_udp_generic(udp, temp_checksum, payload, payload_size); in dump_udp()
159 size_t payload_size) { in dump_udp6() argument
161 temp_checksum = ipv6_pseudo_header_checksum(ip6, sizeof(*udp) + payload_size, IPPROTO_UDP); in dump_udp6()
162 dump_udp_generic(udp, temp_checksum, payload, payload_size); in dump_udp6()
167 uint32_t temp_checksum, const uint8_t *payload, size_t payload_size) { in dump_tcp_generic() argument
174 temp_checksum = ip_checksum_add(temp_checksum, payload, payload_size); in dump_tcp_generic()
[all …]
|
| D | translate.c | 230 uint32_t checksum, const uint8_t *payload, size_t payload_size) { in icmp_to_icmp6() argument
246 clat_packet_len = ipv4_packet(out, pos + 1, payload, payload_size); in icmp_to_icmp6()
260 out[CLAT_POS_PAYLOAD].iov_len = payload_size; in icmp_to_icmp6()
282 const uint8_t *payload, size_t payload_size) { in icmp6_to_icmp() argument
299 clat_packet_len = ipv6_packet(out, pos + 1, payload, payload_size); in icmp6_to_icmp()
305 out[CLAT_POS_PAYLOAD].iov_len = payload_size; in icmp6_to_icmp()
345 size_t payload_size; in udp_packet() local
353 payload_size = len - sizeof(struct udphdr); in udp_packet()
355 return udp_translate(out, pos, udp, old_sum, new_sum, payload, payload_size); in udp_packet()
369 size_t payload_size, header_size; in tcp_packet() local
[all …]
|
| D | dump.h | 32 size_t payload_size);
34 size_t payload_size, const char *options, size_t options_size);
39 size_t payload_size);
41 size_t payload_size, const char *options, size_t options_size);
|
| D | translate.h | 71 uint32_t checksum, const uint8_t *payload, size_t payload_size);
73 const uint8_t *payload, size_t payload_size);
86 size_t payload_size);
88 uint32_t old_sum, uint32_t new_sum, const uint8_t *payload, size_t payload_size);
|
| /external/libchrome/mojo/core/ |
| D | node_channel.cc | 127 size_t payload_size, in CreateMessage() argument
131 const size_t total_size = payload_size + sizeof(Header); in CreateMessage()
176 size_t payload_size, in CreateEventMessage() argument
179 return CreateMessage(MessageType::EVENT_MESSAGE, payload_size, num_handles, in CreateEventMessage()
190 *num_data_bytes = message->payload_size() - sizeof(Header); in GetEventMessageData()
427 sizeof(EventMessageFromRelayData) + message->payload_size(); in EventMessageFromRelay()
433 if (message->payload_size()) in EventMessageFromRelay()
434 memcpy(data + 1, message->payload(), message->payload_size()); in EventMessageFromRelay()
460 size_t payload_size, in OnChannelMessage() argument
471 if (payload_size <= sizeof(Header)) { in OnChannelMessage()
[all …]
|
| D | channel.cc | 61 Channel::Message::Message(size_t payload_size, size_t max_handles) in Message() argument
62 : Message(payload_size, payload_size, max_handles) {} in Message()
64 Channel::Message::Message(size_t payload_size, in Message() argument
67 : Message(payload_size, payload_size, max_handles, message_type) {} in Message()
70 size_t payload_size, in Message() argument
73 : Message(capacity, payload_size, max_handles, MessageType::NORMAL_LEGACY) { in Message()
76 : Message(capacity, payload_size, max_handles, MessageType::NORMAL) {
81 size_t payload_size, in Message() argument
85 DCHECK_GE(capacity, payload_size); in Message()
117 size_ = header_size + extra_header_size + payload_size; in Message()
[all …]
|
| D | channel_unittest.cc | 34 size_t payload_size,
61 size_t payload_size, in OnChannelMessage() argument
63 payload_.reset(new char[payload_size]); in OnChannelMessage()
64 memcpy(payload_.get(), payload, payload_size); in OnChannelMessage()
65 payload_size_ = payload_size; in OnChannelMessage()
77 const size_t payload_size = 100; in CreateDefaultMessage() local
79 payload_size, 0, in CreateDefaultMessage()
83 for (size_t i = 0; i < payload_size; i++) { in CreateDefaultMessage()
110 ASSERT_EQ(message1->payload_size(), message2->payload_size()); in TestMessagesAreEqual()
113 TestMemoryEqual(message1->payload(), message1->payload_size(), in TestMessagesAreEqual()
[all …]
|
| D | channel.h | 137 Message(size_t payload_size, size_t max_handles);
138 Message(size_t payload_size, size_t max_handles, MessageType message_type);
139 Message(size_t capacity, size_t payload_size, size_t max_handles);
142 size_t payload_size,
174 size_t payload_size() const;
252 size_t payload_size,
339 size_t payload_size,
350 size_t payload_size,
|
| /external/webrtc/webrtc/test/fuzzers/ |
| D | producer_fec_fuzzer.cc | 31 size_t payload_size = data[i++] % 10; in FuzzOneInput() local
32 if (i + payload_size + rtp_header_length + 2 > size) in FuzzOneInput()
35 new uint8_t[payload_size + rtp_header_length]); in FuzzOneInput()
36 memcpy(packet.get(), &data[i], payload_size + rtp_header_length); in FuzzOneInput()
38 i += payload_size + rtp_header_length; in FuzzOneInput()
42 packet.get(), payload_size, rtp_header_length, kRedPayloadType)); in FuzzOneInput()
45 producer.AddRtpPacketAndGenerateFec(packet.get(), payload_size, in FuzzOneInput()
|
| /external/libchrome/mojo/public/cpp/bindings/tests/ |
| D | router_test_util.cc | 19 size_t payload_size = strlen(text) + 1; // Plus null terminator. in AllocRequestMessage() local
21 Message(name, Message::kFlagExpectsResponse, payload_size, 0, nullptr); in AllocRequestMessage()
22 memcpy(message->payload_buffer()->AllocateAndGet(payload_size), text, in AllocRequestMessage()
23 payload_size); in AllocRequestMessage()
30 size_t payload_size = strlen(text) + 1; // Plus null terminator. in AllocResponseMessage() local
31 *message = Message(name, Message::kFlagIsResponse, payload_size, 0, nullptr); in AllocResponseMessage()
33 memcpy(message->payload_buffer()->AllocateAndGet(payload_size), text, in AllocResponseMessage()
34 payload_size); in AllocResponseMessage()
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/test/ |
| D | bwe_test_framework.cc | 65 void RateCounter::UpdateRates(int64_t send_time_us, uint32_t payload_size) { in UpdateRates() argument
67 recently_received_bytes_ += payload_size; in UpdateRates()
69 window_.push_back(std::make_pair(send_time_us, payload_size)); in UpdateRates()
104 Packet::Packet(int flow_id, int64_t send_time_us, size_t payload_size) in Packet() argument
109 payload_size_(payload_size), in Packet()
131 size_t payload_size, in MediaPacket() argument
133 : Packet(flow_id, send_time_us, payload_size) { in MediaPacket()
140 size_t payload_size, in MediaPacket() argument
142 : Packet(flow_id, send_time_us, payload_size), header_(header) { in MediaPacket()
296 static_cast<int>(packet->payload_size())); in RunFor()
[all …]
|
| D | bwe.h | 54 size_t payload_size) in PacketIdentifierNode()
58 payload_size(payload_size) {} in PacketIdentifierNode()
63 size_t payload_size; member
83 size_t payload_size);
|
| /external/perfetto/src/ipc/ |
| D | buffered_frame_deserializer.cc | 97 uint32_t payload_size = 0; in EndReceive() local
99 memcpy(base::AssumeLittleEndian(&payload_size), rd_ptr, kHeaderSize); in EndReceive()
104 std::min(static_cast<size_t>(payload_size), capacity_); in EndReceive()
121 DecodeFrame(rd_ptr, payload_size); in EndReceive()
182 const uint32_t payload_size = static_cast<uint32_t>(buf.size() - kHeaderSize); in Serialize() local
183 PERFETTO_DCHECK(payload_size == static_cast<uint32_t>(frame.GetCachedSize())); in Serialize()
185 PERFETTO_DCHECK(kHeaderSize + payload_size <= kIPCBufferSize); in Serialize()
187 memcpy(header, base::AssumeLittleEndian(&payload_size), kHeaderSize); in Serialize()
|
| D | buffered_frame_deserializer_unittest.cc | 47 const uint32_t payload_size = static_cast<uint32_t>(size - kHeaderSize); in GetSimpleFrame() local
48 for (uint32_t size_left = payload_size; size_left > 0;) { in GetSimpleFrame()
65 PERFETTO_CHECK(frame.ByteSize() == static_cast<int>(payload_size)); in GetSimpleFrame()
70 static_cast<int>(payload_size))); in GetSimpleFrame()
71 memcpy(enc_buf, base::AssumeLittleEndian(&payload_size), kHeaderSize); in GetSimpleFrame()
135 uint32_t payload_size = static_cast<uint32_t>(frame.ByteSize()); in TEST() local
137 serialized_frame.resize(kHeaderSize + payload_size); in TEST()
139 static_cast<int>(payload_size))); in TEST()
140 memcpy(serialized_frame.data(), base::AssumeLittleEndian(&payload_size), in TEST()
|
| /external/webrtc/webrtc/modules/remote_bitrate_estimator/ |
| D | remote_bitrate_estimator_abs_send_time.h | 31 Probe(int64_t send_time_ms, int64_t recv_time_ms, size_t payload_size) in Probe()
34 payload_size(payload_size) {} in Probe()
37 size_t payload_size; member
76 size_t payload_size,
104 size_t payload_size,
108 bool IsProbe(int64_t send_time_ms, int payload_size) const
|
| D | send_time_history_unittest.cc | 55 size_t payload_size, in PacketInfo() argument
61 payload_size, in PacketInfo()
67 payload_size == other.payload_size && was_paced == other.was_paced; in operator ==()
102 EXPECT_EQ(kPayloadSize, info.payload_size); in TEST_F()
123 sent_packets[i].payload_size, in TEST_F()
213 AddPacketWithSendTime(packets[0].sequence_number, packets[0].payload_size, in TEST_F()
215 AddPacketWithSendTime(packets[1].sequence_number, packets[1].payload_size, in TEST_F()
221 AddPacketWithSendTime(packets[2].sequence_number, packets[2].payload_size, in TEST_F()
|
| D | remote_bitrate_estimator_abs_send_time.cc | 143 current.mean_size += it->payload_size; in ComputeClusters()
235 packet_info.payload_size, 0, packet_info.was_paced); in IncomingPacketFeedbackVector()
240 size_t payload_size, in IncomingPacket() argument
249 payload_size, header.ssrc, was_paced); in IncomingPacket()
255 size_t payload_size, in IncomingPacketInfo() argument
269 incoming_bitrate_.Update(payload_size, now_ms); in IncomingPacketInfo()
281 was_paced = was_paced && payload_size > PacedSender::kMinProbePacketSize; in IncomingPacketInfo()
298 probes_.push_back(Probe(send_time_ms, arrival_time_ms, payload_size)); in IncomingPacketInfo()
307 if (inter_arrival_->ComputeDeltas(timestamp, arrival_time_ms, payload_size, in IncomingPacketInfo()
|
| /external/libchrome/ipc/ |
| D | ipc_channel_reader_unittest.cc | 83 header.payload_size = 128 * 1024; in TEST()
84 EXPECT_LT(reader.input_overflow_buf_.capacity(), header.payload_size); in TEST()
90 EXPECT_GE(reader.input_overflow_buf_.capacity(), header.payload_size); in TEST()
101 header.payload_size = Channel::kMaximumMessageSize + 1; in TEST()
107 header.payload_size = static_cast<uint32_t>(-1); in TEST()
113 header.payload_size = std::numeric_limits<int32_t>::max(); in TEST()
169 reader.AppendData(message.payload(), message.payload_size()); in TEST()
|
| /external/libchrome/base/ |
| D | pickle.cc | 28 end_index_(pickle.payload_size()) { in PickleIterator()
224 header_->payload_size = 0; in Pickle()
235 header_->payload_size = 0; in Pickle()
244 header_size_ = data_len - header_->payload_size; in Pickle()
262 Resize(other.header_->payload_size); in Pickle()
263 memcpy(header_, other.header_, header_size_ + other.header_->payload_size); in Pickle()
284 Resize(other.header_->payload_size); in operator =()
286 other.header_size_ + other.header_->payload_size); in operator =()
390 *pickle_size = ClampAdd(header_size, hdr->payload_size); in PeekNext()
422 header_->payload_size = static_cast<uint32_t>(new_size); in ClaimUninitializedBytesInternal()
|
| D | pickle_unittest.cc | 289 if (sizeof(size_t) > sizeof(header.payload_size)) in TEST()
297 header.payload_size = static_cast<uint32_t>( in TEST()
308 header.payload_size = in TEST()
355 if (sizeof(size_t) > sizeof(header->payload_size) || in TEST()
356 sizeof(uintptr_t) > sizeof(header->payload_size)) in TEST()
359 header->payload_size = -(reinterpret_cast<uintptr_t>(start) + header_size2); in TEST()
362 header->payload_size = -header_size2; in TEST()
365 header->payload_size = 0; in TEST()
409 EXPECT_EQ(pickle.payload_size(), payload_size_after_header); in TEST()
415 EXPECT_EQ(cur_payload, pickle.payload_size()); in TEST()
[all …]
|
| /external/webrtc/webrtc/modules/rtp_rtcp/source/ |
| D | rtp_format_vp8_unittest.cc | 108 helper_->payload_size(), in TEST_F()
138 packetizer.SetPayloadData(helper_->payload_data(), helper_->payload_size(), in TEST_F()
162 helper_->payload_size(), in TEST_F()
189 helper_->payload_size(), in TEST_F()
216 helper_->payload_size(), in TEST_F()
243 helper_->payload_size(), in TEST_F()
271 helper_->payload_data(), helper_->payload_size(), NULL); in TEST_F()
300 helper_->payload_data(), helper_->payload_size(), NULL); in TEST_F()
332 helper_->payload_size(), in TEST_F()
336 const size_t kExpectedSizes[1] = {helper_->payload_size() + 4}; in TEST_F()
[all …]
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | message_internal.cc | 32 size_t payload_size, in ComputeSerializedMessageSize() argument
37 return Align(header_size + Align(payload_size) + in ComputeSerializedMessageSize()
41 return internal::Align(header_size + payload_size); in ComputeSerializedMessageSize()
|
| /external/image_io/src/jpeg/ |
| D | jpeg_scanner.cc | 57 size_t payload_size = 0; in FindAndProcessSegments() local
61 payload_size = GetPayloadSize(marker, begin_segment_location); in FindAndProcessSegments()
64 begin_segment_location + JpegMarker::kLength + payload_size; in FindAndProcessSegments()
74 begin_segment_location + JpegMarker::kLength + payload_size; in FindAndProcessSegments()
|
| /external/perfetto/src/profiling/memory/ |
| D | wire_protocol_unittest.cc | 87 msg.payload_size = sizeof(payload); in TEST()
105 ASSERT_EQ(recv_msg.payload_size, msg.payload_size); in TEST()
136 ASSERT_EQ(recv_msg.payload_size, msg.payload_size); in TEST()
|
| /external/libaom/libaom/av1/decoder/ |
| D | obu.c | 706 size_t payload_size = 0; in aom_decode_frame_from_obus() local
720 &obu_header, &payload_size, &bytes_read); in aom_decode_frame_from_obus()
735 if ((size_t)(data_end - data) < payload_size) { in aom_decode_frame_from_obus()
748 data += payload_size; in aom_decode_frame_from_obus()
753 av1_init_read_bit_buffer(pbi, &rb, data, data + payload_size); in aom_decode_frame_from_obus()
779 if (frame_header_size > payload_size) { in aom_decode_frame_from_obus()
805 decoded_payload_size = payload_size; in aom_decode_frame_from_obus()
822 if (obu_payload_offset > payload_size) { in aom_decode_frame_from_obus()
828 data + payload_size, p_data_end, &frame_decoding_finished, in aom_decode_frame_from_obus()
835 decoded_payload_size = read_metadata(data, payload_size); in aom_decode_frame_from_obus()
[all …]
|