| /external/android-clat/ |
| D | dump.c | 137 size_t payload_size) { in dump_udp_generic() argument
141 temp_checksum = ip_checksum_add(temp_checksum, payload, payload_size); in dump_udp_generic()
153 size_t payload_size) { in dump_udp() argument
155 temp_checksum = ipv4_pseudo_header_checksum(ip, sizeof(*udp) + payload_size); in dump_udp()
156 dump_udp_generic(udp, temp_checksum, payload, payload_size); in dump_udp()
161 size_t payload_size) { in dump_udp6() argument
163 temp_checksum = ipv6_pseudo_header_checksum(ip6, sizeof(*udp) + payload_size, IPPROTO_UDP); in dump_udp6()
164 dump_udp_generic(udp, temp_checksum, payload, payload_size); in dump_udp6()
169 uint32_t temp_checksum, const uint8_t *payload, size_t payload_size) { in dump_tcp_generic() argument
176 temp_checksum = ip_checksum_add(temp_checksum, payload, payload_size); in dump_tcp_generic()
[all …]
|
| D | translate.c | 229 uint32_t checksum, const uint8_t *payload, size_t payload_size) { in icmp_to_icmp6() argument
245 clat_packet_len = ipv4_packet(out, pos + 1, payload, payload_size); in icmp_to_icmp6()
259 out[CLAT_POS_PAYLOAD].iov_len = payload_size; in icmp_to_icmp6()
281 const uint8_t *payload, size_t payload_size) { in icmp6_to_icmp() argument
298 clat_packet_len = ipv6_packet(out, pos + 1, payload, payload_size); in icmp6_to_icmp()
304 out[CLAT_POS_PAYLOAD].iov_len = payload_size; in icmp6_to_icmp()
344 size_t payload_size; in udp_packet() local
352 payload_size = len - sizeof(struct udphdr); in udp_packet()
354 return udp_translate(out, pos, udp, old_sum, new_sum, payload, payload_size); in udp_packet()
368 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 uint8_t *options, size_t options_size);
39 size_t payload_size);
41 size_t payload_size, const uint8_t *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_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.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.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/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/test/fuzzers/ |
| D | flexfec_sender_fuzzer.cc | 50 size_t payload_size = data[i++]; in FuzzOneInput() local
51 if (i + kRtpHeaderSize + payload_size >= size) in FuzzOneInput()
54 new uint8_t[kRtpHeaderSize + payload_size]); in FuzzOneInput()
55 memcpy(packet.get(), &data[i], kRtpHeaderSize + payload_size); in FuzzOneInput()
56 i += kRtpHeaderSize + payload_size; in FuzzOneInput()
60 if (!rtp_packet.Parse(packet.get(), kRtpHeaderSize + payload_size)) in FuzzOneInput()
|
| D | ulpfec_generator_fuzzer.cc | 41 size_t payload_size = data[i++] % 10; in FuzzOneInput() local
42 if (i + payload_size + rtp_header_length + 2 > size) in FuzzOneInput()
44 rtc::CopyOnWriteBuffer packet(&data[i], payload_size + rtp_header_length); in FuzzOneInput()
51 i += payload_size + rtp_header_length; in FuzzOneInput()
|
| D | rtp_packetizer_av1_fuzzer.cc | 50 RTC_CHECK_LE(rtp_packet.payload_size(), in FuzzOneInput()
56 RTC_CHECK_LE(rtp_packet.payload_size(), in FuzzOneInput()
62 RTC_CHECK_LE(rtp_packet.payload_size(), limits.max_payload_len) in FuzzOneInput()
67 RTC_CHECK_LE(rtp_packet.payload_size(), in FuzzOneInput()
|
| /external/libwebm/m2ts/ |
| D | vpxpes2ts.cc | 160 int payload_size = std::min(bytes_to_packetize, kTsPayloadSize); in ReceivePacket() local
165 payload_size != kTsPayloadSize, continuity_counter); in ReceivePacket()
171 if (payload_size < kTsPayloadSize) { in ReceivePacket()
173 if (payload_size == (kTsPayloadSize - 1)) { in ReceivePacket()
174 payload_size--; in ReceivePacket()
182 const int pad_size = kTsPayloadSize - payload_size - 1 - 1; in ReceivePacket()
192 for (int i = 0; i < payload_size; ++i) { in ReceivePacket()
196 bytes_to_packetize -= payload_size; in ReceivePacket()
|
| /external/perfetto/src/ipc/ |
| D | buffered_frame_deserializer.cc | 98 uint32_t payload_size = 0; in EndReceive() local
100 memcpy(base::AssumeLittleEndian(&payload_size), rd_ptr, kHeaderSize); in EndReceive()
105 std::min(static_cast<size_t>(payload_size), capacity_); in EndReceive()
122 DecodeFrame(rd_ptr, payload_size); in EndReceive()
178 const uint32_t payload_size = static_cast<uint32_t>(payload.size()); in Serialize() local
180 buf.resize(kHeaderSize + payload_size); in Serialize()
181 memcpy(&buf[0], base::AssumeLittleEndian(&payload_size), kHeaderSize); in Serialize()
|
| /external/webrtc/modules/remote_bitrate_estimator/ |
| D | remote_bitrate_estimator_abs_send_time.h | 40 Probe(int64_t send_time_ms, int64_t recv_time_ms, size_t payload_size) in Probe()
43 payload_size(payload_size) {} in Probe()
46 size_t payload_size; member
82 size_t payload_size,
107 size_t payload_size,
|
| /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/openscreen/cast/streaming/ |
| D | sender_report_parser.cc | 36 if (static_cast<int>(buffer.size()) < header->payload_size) { in Parse()
39 auto chunk = buffer.subspan(0, header->payload_size); in Parse()
40 buffer.remove_prefix(header->payload_size); in Parse()
46 if (header->payload_size < kRtcpSenderReportSize) { in Parse()
|
| /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/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/webrtc/modules/congestion_controller/ |
| D | receive_side_congestion_controller.cc | 39 size_t payload_size, in IncomingPacket() argument
43 rbe_->IncomingPacket(arrival_time_ms, payload_size, header); in IncomingPacket()
138 size_t payload_size, in OnReceivedPacket() argument
140 remote_estimator_proxy_.IncomingPacket(arrival_time_ms, payload_size, header); in OnReceivedPacket()
143 remote_bitrate_estimator_.IncomingPacket(arrival_time_ms, payload_size, in OnReceivedPacket()
|
| /external/webrtc/modules/rtp_rtcp/source/ |
| D | video_rtp_depacketizer_av1.cc | 148 size_t payload_size = 0; member
299 obu_info->payload_size = obu_info->data.size() - obu_info->prefix_size; in CalculateObuSizes()
320 obu_info->payload_size = in CalculateObuSizes()
322 if (obu_size_bytes != obu_info->payload_size) { in CalculateObuSizes()
325 << ", actual: " << obu_info->payload_size; in CalculateObuSizes()
331 WriteLeb128(rtc::dchecked_cast<uint32_t>(obu_info->payload_size), in CalculateObuSizes()
350 frame_size += (obu_info.prefix_size + obu_info.payload_size); in AssembleFrame()
362 write_at += obu_info.payload_size; in AssembleFrame()
|
| /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/webrtc/modules/audio_coding/test/ |
| D | TestAllCodecs.cc | 67 size_t payload_size, in SendData() argument
84 memcpy(payload_data_, payload_data, payload_size); in SendData()
87 receiver_acm_->IncomingPacket(payload_data_, payload_size, rtp_header); in SendData()
89 payload_size_ = payload_size; in SendData()
92 total_bytes_ += payload_size; in SendData()
96 size_t TestPack::payload_size() { in payload_size() function in webrtc::TestPack
398 receive_size = channel->payload_size(); in Run()
|
| /external/webrtc/audio/ |
| D | channel_send_frame_transformer_delegate.cc | 25 size_t payload_size, in TransformableAudioFrame() argument
32 payload_(payload_data, payload_size), in TransformableAudioFrame()
90 size_t payload_size, in Transform() argument
95 payload_data, payload_size, absolute_capture_timestamp_ms, ssrc)); in Transform()
|