| /external/libsrtp2/test/ |
| D | rtp.c | 61 int rtp_sendto(rtp_sender_t sender, const void *msg, int len) in rtp_sendto() argument
68 strncpy(sender->message.body, msg, len); in rtp_sendto()
71 sender->message.header.seq = ntohs(sender->message.header.seq) + 1; in rtp_sendto()
72 sender->message.header.seq = htons(sender->message.header.seq); in rtp_sendto()
73 sender->message.header.ts = ntohl(sender->message.header.ts) + 1; in rtp_sendto()
74 sender->message.header.ts = htonl(sender->message.header.ts); in rtp_sendto()
77 stat = srtp_protect(sender->srtp_ctx, &sender->message.header, &pkt_len); in rtp_sendto()
85 srtp_print_packet(&sender->message.header, pkt_len); in rtp_sendto()
88 sendto(sender->socket, (void *)&sender->message, pkt_len, 0, in rtp_sendto()
89 (struct sockaddr *)&sender->addr, sizeof(struct sockaddr_in)); in rtp_sendto()
[all …]
|
| /external/openscreen/cast/streaming/ |
| D | receiver_unittest.cc | 285 [sender = &sender_, copy_of_packet = std::vector<uint8_t>( in __anonfe104a120402()
287 sender->OnPacketFromReceiver(std::move(copy_of_packet)); in __anonfe104a120402()
297 MockSender* sender() { return &sender_; } in sender() function in openscreen::cast::__anonfe104a120111::ReceiverTest
371 EXPECT_CALL(*sender(), OnReceiverReferenceTimeAdvanced(_)) in TEST_F()
374 EXPECT_CALL(*sender(), OnReceiverReport(_)) in TEST_F()
376 EXPECT_CALL(*sender(), in TEST_F()
385 sender()->SendSenderReport(sender_reference_time, sender_rtp_timestamp); in TEST_F()
391 testing::Mock::VerifyAndClearExpectations(sender()); in TEST_F()
415 EXPECT_CALL(*sender(), OnReceiverReferenceTimeAdvanced(_)) in TEST_F()
418 testing::Mock::VerifyAndClearExpectations(sender()); in TEST_F()
[all …]
|
| D | sender_unittest.cc | 366 Sender* sender() { return &sender_; } in sender() function in openscreen::cast::__anon49ccb09e0111::SenderTest
480 sender()->SetObserver(&observer); in TEST_F()
486 EXPECT_TRUE(sender()->NeedsKeyFrame()); in TEST_F()
488 EXPECT_FALSE(sender()->NeedsKeyFrame()); in TEST_F()
493 ASSERT_EQ(Sender::OK, sender()->EnqueueFrame(frames[i])); in TEST_F()
506 sender()->GetInFlightMediaDuration(RtpTimeTicks())); in TEST_F()
508 sender()->GetInFlightMediaDuration( in TEST_F()
515 ASSERT_EQ(Sender::OK, sender()->EnqueueFrame(frame)); in TEST_F()
519 EXPECT_EQ(kFrameDuration, sender()->GetInFlightMediaDuration( in TEST_F()
523 sender()->GetInFlightMediaDuration( in TEST_F()
[all …]
|
| /external/connectedappssdk/tests/robotests/src/test/java/com/google/android/enterprise/connectedapps/ |
| D | CrossProfileSenderTest.java | 55 private CrossProfileSender sender; field in CrossProfileSenderTest
67 sender = in setUp()
83 sender.clearConnectionHolders(); in setUp()
197 () -> sender.manuallyBind(CrossProfileSender.MANUAL_MANAGEMENT_CONNECTION_HOLDER)); in manuallyBind_callingFromUIThread_throwsIllegalStateException()
203 sender.addConnectionHolder(this); in addConnectionHolder_otherProfileIsNotAvailable_doesNotbind()
205 assertThat(sender.isBound()).isFalse(); in addConnectionHolder_otherProfileIsNotAvailable_doesNotbind()
212 sender.addConnectionHolder(this); in addConnectionHolder_bindingIsNotPossible_doesNotCallConnectionListener()
220 sender.addConnectionHolder(this); in addConnectionHolder_otherProfileIsAvailable_binds()
222 assertThat(sender.isBound()).isTrue(); in addConnectionHolder_otherProfileIsAvailable_binds()
228 sender.addConnectionHolder(this); in addConnectionHolder_binds_callsConnectionListener()
[all …]
|
| /external/webrtc/modules/rtp_rtcp/source/ |
| D | flexfec_sender_unittest.cc | 56 FlexfecSender* sender) { in GenerateSingleFlexfecPacket() argument
64 sender->SetProtectionParameters(params, params); in GenerateSingleFlexfecPacket()
72 sender->AddPacketAndGenerateFec(rtp_packet); in GenerateSingleFlexfecPacket()
75 sender->GetFecPackets(); in GenerateSingleFlexfecPacket()
77 EXPECT_TRUE(sender->GetFecPackets().empty()); in GenerateSingleFlexfecPacket()
86 FlexfecSender sender(kFlexfecPayloadType, kFlexfecSsrc, kMediaSsrc, kNoMid, in TEST() local
90 EXPECT_EQ(kFlexfecSsrc, sender.FecSsrc()); in TEST()
95 FlexfecSender sender(kFlexfecPayloadType, kFlexfecSsrc, kMediaSsrc, kNoMid, in TEST() local
99 EXPECT_TRUE(sender.GetFecPackets().empty()); in TEST()
104 FlexfecSender sender(kFlexfecPayloadType, kFlexfecSsrc, kMediaSsrc, kNoMid, in TEST() local
[all …]
|
| D | absolute_capture_time_sender_unittest.cc | 45 AbsoluteCaptureTimeSender sender(&clock); in TEST() local
47 EXPECT_EQ(sender.OnSendPacket(kSource, kRtpTimestamp0, kRtpClockFrequency, in TEST()
52 EXPECT_EQ(sender.OnSendPacket(kSource, kRtpTimestamp1, kRtpClockFrequency, in TEST()
57 EXPECT_EQ(sender.OnSendPacket(kSource, kRtpTimestamp2, kRtpClockFrequency, in TEST()
77 AbsoluteCaptureTimeSender sender(&clock); in TEST() local
79 EXPECT_EQ(sender.OnSendPacket(kSource, kRtpTimestamp0, kRtpClockFrequency, in TEST()
84 EXPECT_EQ(sender.OnSendPacket(kSource, kRtpTimestamp1, kRtpClockFrequency, in TEST()
89 EXPECT_EQ(sender.OnSendPacket(kSource, kRtpTimestamp2, kRtpClockFrequency, in TEST()
110 AbsoluteCaptureTimeSender sender(&clock); in TEST() local
112 EXPECT_EQ(sender.OnSendPacket(kSource, kRtpTimestamp0, kRtpClockFrequency, in TEST()
[all …]
|
| D | rtp_sender_egress_unittest.cc | 208 std::unique_ptr<RtpSenderEgress> sender = CreateRtpSenderEgress(); in TEST_F() local
209 sender->SendPacket(packet.get(), PacedPacketInfo()); in TEST_F()
213 std::unique_ptr<RtpSenderEgress> sender = CreateRtpSenderEgress(); in TEST_F() local
217 sender->SendPacket(media_packet.get(), PacedPacketInfo()); in TEST_F()
224 sender->SendPacket(retransmission.get(), PacedPacketInfo()); in TEST_F()
229 std::unique_ptr<RtpSenderEgress> sender = CreateRtpSenderEgress(); in TEST_F() local
232 sender->SendPacket(packet.get(), PacedPacketInfo()); in TEST_F()
239 std::unique_ptr<RtpSenderEgress> sender = CreateRtpSenderEgress(); in TEST_F() local
244 sender->SendPacket(packet.get(), PacedPacketInfo()); in TEST_F()
251 std::unique_ptr<RtpSenderEgress> sender = CreateRtpSenderEgress(); in TEST_F() local
[all …]
|
| D | rtcp_sender.cc | 253 absl::optional<PacketSender> sender; in SendLossNotification() local
270 sender.emplace(callback, max_packet_size_); in SendLossNotification()
273 *sender); in SendLossNotification()
278 sender->Send(); in SendLossNotification()
442 void RTCPSender::BuildSR(const RtcpContext& ctx, PacketSender& sender) { in BuildSR() argument
469 sender.AppendPacket(report); in BuildSR()
472 void RTCPSender::BuildSDES(const RtcpContext& ctx, PacketSender& sender) { in BuildSDES() argument
478 sender.AppendPacket(sdes); in BuildSDES()
481 void RTCPSender::BuildRR(const RtcpContext& ctx, PacketSender& sender) { in BuildRR() argument
486 sender.AppendPacket(report); in BuildRR()
[all …]
|
| /external/rust/crates/tokio-util/src/sync/ |
| D | mpsc.rs | 45 sender: Option<Sender<T>>, field
59 Some(sender) => sender in make_acquire_future()
69 pub fn new(sender: Sender<T>) -> Self { in new()
71 sender: Some(sender.clone()), in new()
72 state: State::Idle(sender), in new()
97 State::Idle(sender) => { in poll_reserve()
100 self.acquire.set(make_acquire_future(Some(sender))); in poll_reserve()
152 self.state = if self.sender.is_some() { in send_item()
164 matches!(self.state, State::Closed) || self.sender.is_none() in is_closed()
172 self.sender.as_ref() in get_ref()
[all …]
|
| /external/rust/crates/tokio/tests/ |
| D | sync_mpsc_weak.rs | 62 sender: mpsc::WeakSender<ActorMessage>, in actor_weak_sender() field
75 sender: mpsc::WeakSender<ActorMessage>, in actor_weak_sender()
79 sender, in actor_weak_sender()
105 let sender = self.sender.clone(); in actor_weak_sender() localVariable
108 if let Some(sender) = sender.upgrade() { in actor_weak_sender()
109 let _ = sender.send(msg).await; in actor_weak_sender()
110 self.sender = sender.downgrade(); in actor_weak_sender()
132 sender: mpsc::Sender<ActorMessage>, in actor_weak_sender() field
137 let (sender, receiver) = mpsc::channel(8); in actor_weak_sender()
138 let actor = MyActor::new(receiver, sender.clone().downgrade()); in actor_weak_sender()
[all …]
|
| D | udp.rs | 15 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_recv() localVariable
18 sender.connect(receiver.local_addr()?).await?; in send_recv()
19 receiver.connect(sender.local_addr()?).await?; in send_recv()
21 sender.send(MSG).await?; in send_recv()
32 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_recv_poll() localVariable
35 sender.connect(receiver.local_addr()?).await?; in send_recv_poll()
36 receiver.connect(sender.local_addr()?).await?; in send_recv_poll()
38 poll_fn(|cx| sender.poll_send(cx, MSG)).await?; in send_recv_poll()
50 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_to_recv_from() localVariable
54 sender.send_to(MSG, &receiver_addr).await?; in send_to_recv_from()
[all …]
|
| /external/selinux/dbus/ |
| D | selinux_server.py | 19 def is_authorized(self, sender, action_id): argument
23 subject = ('system-bus-name', {'name': sender})
32 def semanage(self, buf, sender): argument
33 if not self.is_authorized(sender, "org.selinux.semanage"):
47 def customized(self, sender): argument
48 if not self.is_authorized(sender, "org.selinux.customized"):
62 def semodule_list(self, sender): argument
63 if not self.is_authorized(sender, "org.selinux.semodule_list"):
76 def restorecon(self, path, sender): argument
77 if not self.is_authorized(sender, "org.selinux.restorecon"):
[all …]
|
| /external/openthread/tests/toranj/ncp/ |
| D | test-039-address-cache-table-snoop.py | 127 sender = r1.prepare_tx((r1_address, PORT), (PREFIX + "800:" + str(num), PORT), "hi nobody!", 1) variable
129 verify(sender.was_successful)
168 sender = r1.prepare_tx((r1_address, PORT), (PREFIX + "800:" + str(num), PORT), "hi nobody!", 1) variable
170 verify(sender.was_successful)
193 …sender = r1.prepare_tx((r1_address, PORT), (PREFIX + "800:" + str(num), PORT), "hi again nobody!",… variable
195 verify(sender.was_successful)
214 …sender = r2.prepare_tx((PREFIX + "2:" + str(num), PORT), (r1_address, PORT), "hi r1 from r2 (snoop… variable
215 recver = r1.prepare_rx(sender)
217 verify(sender.was_successful)
241 …sender = r1.prepare_tx((r1_address, PORT), (PREFIX + "2:" + str(num), PORT), "hi back r2 from r1",… variable
[all …]
|
| D | test-021-address-cache-table.py | 143 sender = r1.prepare_tx(r1_address, c2_address, "Hi from r1 to c2") variable
144 recver = c2.prepare_rx(sender)
146 verify(sender.was_successful and recver.was_successful)
150 sender = r1.prepare_tx(r1_address, c3_address, "Hi from r1 to c3") variable
151 recver = c3.prepare_rx(sender)
153 verify(sender.was_successful and recver.was_successful)
222 sender = r1.prepare_tx(r1_address, c2_address, "Hi again c2") variable
223 recver = c2.prepare_rx(sender)
225 verify(sender.was_successful and recver.was_successful)
241 sender = r1.prepare_tx(r1_address, c2_address, "Hi again c2") variable
[all …]
|
| D | test-013-off-mesh-route-traffic.py | 158 sender = sed2.prepare_tx(src, OFF_MESH_ADDR_1, "Hello Route1") variable
159 recver = r1.prepare_rx(sender)
161 verify(sender.was_successful)
167 sender = r1.prepare_tx(src, OFF_MESH_ADDR_2, "Hello Route2") variable
168 recver = r2.prepare_rx(sender)
170 verify(sender.was_successful)
176 sender = r2.prepare_tx(src, OFF_MESH_ADDR_3, "Hello Route3") variable
177 recver = fed1.prepare_rx(sender)
179 verify(sender.was_successful)
|
| /external/webrtc/pc/ |
| D | rtp_transmission_manager.cc | 180 transceiver->sender()->SetTrack(track.get()); in AddTrackUnifiedPlan()
197 auto sender = CreateSender(media_type, sender_id, track, stream_ids, in AddTrackUnifiedPlan() local
202 transceiver = CreateAndAddTransceiver(sender, receiver); in AddTrackUnifiedPlan()
206 return transceiver->sender(); in AddTrackUnifiedPlan()
217 rtc::scoped_refptr<RtpSenderProxyWithInternal<RtpSenderInternal>> sender; in CreateSender() local
221 sender = RtpSenderProxyWithInternal<RtpSenderInternal>::Create( in CreateSender()
229 sender = RtpSenderProxyWithInternal<RtpSenderInternal>::Create( in CreateSender()
233 bool set_track_succeeded = sender->SetTrack(track.get()); in CreateSender()
235 sender->internal()->set_stream_ids(stream_ids); in CreateSender()
236 sender->internal()->set_init_send_encodings(send_encodings); in CreateSender()
[all …]
|
| D | peer_connection_rtp_unittest.cc | 232 auto sender = caller->AddAudioTrack("audio_track", {}); in TEST_P() local
238 EXPECT_TRUE(caller->pc()->RemoveTrackOrError(sender).ok()); in TEST_P()
250 auto sender = caller->AddAudioTrack("audio_track", {"audio_stream"}); in TEST_P() local
256 EXPECT_TRUE(caller->pc()->RemoveTrackOrError(sender).ok()); in TEST_P()
475 auto sender = caller->AddAudioTrack("audio_track", {}); in TEST_F() local
481 caller->pc()->RemoveTrackOrError(sender); in TEST_F()
575 auto sender = caller->AddAudioTrack("audio_track", {}); in TEST_P() local
576 ASSERT_TRUE(sender); in TEST_P()
581 ASSERT_TRUE(caller->pc()->RemoveTrackOrError(sender).ok()); in TEST_P()
600 auto sender = caller->AddAudioTrack("audio_track", {"audio_stream"}); in TEST_P() local
[all …]
|
| /external/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 317 self.inner.do_io(|mut sender| sender.write(buf)) in write()
321 self.inner.do_io(|mut sender| sender.write_vectored(bufs)) in write_vectored()
325 self.inner.do_io(|mut sender| sender.flush()) in flush()
331 self.inner.do_io(|mut sender| sender.write(buf)) in write()
335 self.inner.do_io(|mut sender| sender.write_vectored(bufs)) in write_vectored()
339 self.inner.do_io(|mut sender| sender.flush()) in flush()
482 self.inner.do_io(|mut sender| sender.read(buf)) in read()
486 self.inner.do_io(|mut sender| sender.read_vectored(bufs)) in read_vectored()
492 self.inner.do_io(|mut sender| sender.read(buf)) in read()
496 self.inner.do_io(|mut sender| sender.read_vectored(bufs)) in read_vectored()
|
| /external/webrtc/net/dcsctp/socket/ |
| D | dcsctp_socket_network_test.cc | 366 SctpActor sender("A", emulated_socket_a_, options_); in TEST_F() local
368 EXPECT_THAT(sender.sctp_socket().state(), SocketState::kClosed); in TEST_F()
370 sender.sctp_socket().Connect(); in TEST_F()
372 EXPECT_THAT(sender.sctp_socket().state(), SocketState::kConnected); in TEST_F()
374 sender.sctp_socket().Shutdown(); in TEST_F()
376 EXPECT_THAT(sender.sctp_socket().state(), SocketState::kClosed); in TEST_F()
384 SctpActor sender("A", emulated_socket_a_, options_); in TEST_F() local
386 sender.sctp_socket().Connect(); in TEST_F()
391 sender.sctp_socket().Send(DcSctpMessage(kStreamId, kPpid, payload), in TEST_F()
401 sender.sctp_socket().Shutdown(); in TEST_F()
[all …]
|
| /external/libbrillo/brillo/dbus/ |
| D | dbus_object_internal_impl.h | 57 ResponseSender sender) = 0;
81 ResponseSender sender) override { in HandleMethod() argument
82 DBusMethodResponse<R> method_response(method_call, sender); in HandleMethod()
115 ResponseSender sender) override { in HandleMethod() argument
116 DBusMethodResponseBase method_response(method_call, sender); in HandleMethod()
161 ResponseSender sender) override { in HandleMethod() argument
162 DBusMethodResponseBase method_response(method_call, sender); in HandleMethod()
212 ResponseSender sender) override { in HandleMethod() argument
213 DBusMethodResponseBase method_response(method_call, sender); in HandleMethod()
262 ResponseSender sender) override { in HandleMethod() argument
[all …]
|
| /external/webrtc/sdk/android/instrumentationtests/src/org/webrtc/ |
| D | RtpSenderTest.java | 51 RtpSender sender = transceiver.getSender(); in testSetDegradationPreference() local
53 RtpParameters parameters = sender.getParameters(); in testSetDegradationPreference()
58 assertTrue(sender.setParameters(parameters)); in testSetDegradationPreference()
59 parameters = sender.getParameters(); in testSetDegradationPreference()
63 assertTrue(sender.setParameters(parameters)); in testSetDegradationPreference()
64 parameters = sender.getParameters(); in testSetDegradationPreference()
68 assertTrue(sender.setParameters(parameters)); in testSetDegradationPreference()
69 parameters = sender.getParameters(); in testSetDegradationPreference()
73 assertTrue(sender.setParameters(parameters)); in testSetDegradationPreference()
74 parameters = sender.getParameters(); in testSetDegradationPreference()
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/qpack/fuzzer/ |
| D | qpack_decoder_stream_sender_fuzzer.cc | 20 QpackDecoderStreamSender sender; in LLVMFuzzerTestOneInput() local
21 sender.set_qpack_stream_sender_delegate(&delegate); in LLVMFuzzerTestOneInput()
29 sender.SendInsertCountIncrement(increment); in LLVMFuzzerTestOneInput()
34 sender.SendHeaderAcknowledgement(stream_id); in LLVMFuzzerTestOneInput()
39 sender.SendStreamCancellation(stream_id); in LLVMFuzzerTestOneInput()
43 sender.Flush(); in LLVMFuzzerTestOneInput()
49 sender.Flush(); in LLVMFuzzerTestOneInput()
|
| D | qpack_encoder_stream_sender_fuzzer.cc | 21 QpackEncoderStreamSender sender; in LLVMFuzzerTestOneInput() local
22 sender.set_qpack_stream_sender_delegate(&delegate); in LLVMFuzzerTestOneInput()
37 sender.SendInsertWithNameReference(is_static, name_index, value); in LLVMFuzzerTestOneInput()
47 sender.SendInsertWithoutNameReference(name, value); in LLVMFuzzerTestOneInput()
52 sender.SendDuplicate(index); in LLVMFuzzerTestOneInput()
57 sender.SendSetDynamicTableCapacity(capacity); in LLVMFuzzerTestOneInput()
61 sender.Flush(); in LLVMFuzzerTestOneInput()
67 sender.Flush(); in LLVMFuzzerTestOneInput()
|
| /external/autotest/client/deps/graphics/graphics_test_extension/ |
| D | background.js | 15 function onMessageHandler(message, sender, sendResponse) { argument
24 console.log("Set window " + sender.tab.windowId + " to fullscreen.");
25 chrome.windows.update(sender.tab.windowId, {state: "fullscreen"});
27 console.log("Update window " + sender.tab.windowId + ": " +
29 chrome.windows.update(sender.tab.windowId, message.updateInfo);
31 console.log("Move window " + sender.tab.windowId +
46 chrome.windows.update(sender.tab.windowId, {
51 chrome.windows.update(sender.tab.windowId, {state: "fullscreen"});
|
| /external/webrtc/test/pc/e2e/analyzer/video/ |
| D | default_video_quality_analyzer_internal_shared_objects.cc | 19 out << "stream=" << stream << "_sender=" << sender in ToString()
28 if (a.sender != b.sender) { in operator <()
29 return a.sender < b.sender; in operator <()
35 return a.stream == b.stream && a.sender == b.sender && in operator ==()
|