| /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 …]
|
| D | rtp.h | 103 int rtp_sendto(rtp_sender_t sender, const void *msg, int len);
112 int rtp_sender_init(rtp_sender_t sender,
135 int rtp_sender_init_srtp(rtp_sender_t sender, const srtp_policy_t *policy);
137 int rtp_sender_deinit_srtp(rtp_sender_t sender);
139 int rtp_receiver_init_srtp(rtp_receiver_t sender, const srtp_policy_t *policy);
141 int rtp_receiver_deinit_srtp(rtp_receiver_t sender);
|
| /external/openscreen/cast/streaming/ |
| D | receiver_unittest.cc | 285 [sender = &sender_, copy_of_packet = std::vector<uint8_t>( in __anon0182bad90402()
287 sender->OnPacketFromReceiver(std::move(copy_of_packet)); in __anon0182bad90402()
297 MockSender* sender() { return &sender_; } in sender() function in openscreen::cast::__anon0182bad90111::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::__anon168e43a50111::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 | 53 private CrossProfileSender sender; field in CrossProfileSenderTest
64 sender = in setUp()
73 sender.beginMonitoringAvailabilityChanges(); in setUp()
192 assertThrows(IllegalStateException.class, sender::manuallyBind); in manuallyBind_callingFromUIThread_throwsIllegalStateException()
198 sender.startManuallyBinding(); in startManuallyBinding_otherProfileIsNotAvailable_doesNotbind()
200 assertThat(sender.isBound()).isFalse(); in startManuallyBinding_otherProfileIsNotAvailable_doesNotbind()
207 sender.startManuallyBinding(); in startManuallyBinding_bindingIsNotPossible_doesNotCallConnectionListener()
215 sender.startManuallyBinding(); in startManuallyBinding_otherProfileIsAvailable_binds()
217 assertThat(sender.isBound()).isTrue(); in startManuallyBinding_otherProfileIsAvailable_binds()
223 sender.startManuallyBinding(); in startManuallyBinding_binds_callsConnectionListener()
[all …]
|
| /external/webrtc/modules/rtp_rtcp/source/ |
| D | flexfec_sender_unittest.cc | 50 FlexfecSender* sender) { in GenerateSingleFlexfecPacket() argument
58 sender->SetProtectionParameters(params, params); in GenerateSingleFlexfecPacket()
66 sender->AddPacketAndGenerateFec(rtp_packet); in GenerateSingleFlexfecPacket()
69 sender->GetFecPackets(); in GenerateSingleFlexfecPacket()
71 EXPECT_TRUE(sender->GetFecPackets().empty()); in GenerateSingleFlexfecPacket()
80 FlexfecSender sender(kFlexfecPayloadType, kFlexfecSsrc, kMediaSsrc, kNoMid, in TEST() local
84 EXPECT_EQ(kFlexfecSsrc, sender.FecSsrc()); in TEST()
89 FlexfecSender sender(kFlexfecPayloadType, kFlexfecSsrc, kMediaSsrc, kNoMid, in TEST() local
93 EXPECT_TRUE(sender.GetFecPackets().empty()); in TEST()
98 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 | rtcp_transceiver_impl.cc | 353 void RtcpTransceiverImpl::CreateCompoundPacket(PacketSender* sender) { in CreateCompoundPacket() argument
354 RTC_DCHECK(sender->IsEmpty()); in CreateCompoundPacket()
360 sender->AppendPacket(receiver_report); in CreateCompoundPacket()
367 sender->AppendPacket(sdes); in CreateCompoundPacket()
371 sender->AppendPacket(*remb_); in CreateCompoundPacket()
384 sender->AppendPacket(xr); in CreateCompoundPacket()
392 PacketSender sender(send_packet, config_.max_packet_size); in SendPeriodicCompoundPacket() local
393 CreateCompoundPacket(&sender); in SendPeriodicCompoundPacket()
394 sender.Send(); in SendPeriodicCompoundPacket()
402 PacketSender sender(send_packet, config_.max_packet_size); in SendCombinedRtcpPacket() local
[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/rust/crates/mio/src/sys/unix/ |
| D | pipe.rs | 247 self.inner.do_io(|sender| (&*sender).write(buf)) in write()
251 self.inner.do_io(|sender| (&*sender).write_vectored(bufs)) in write_vectored()
255 self.inner.do_io(|sender| (&*sender).flush()) in flush()
261 self.inner.do_io(|sender| (&*sender).write(buf)) in write()
265 self.inner.do_io(|sender| (&*sender).write_vectored(bufs)) in write_vectored()
269 self.inner.do_io(|sender| (&*sender).flush()) in flush()
344 self.inner.do_io(|sender| (&*sender).read(buf)) in read()
348 self.inner.do_io(|sender| (&*sender).read_vectored(bufs)) in read_vectored()
354 self.inner.do_io(|sender| (&*sender).read(buf)) in read()
358 self.inner.do_io(|sender| (&*sender).read_vectored(bufs)) in read_vectored()
|
| /external/rust/crates/tokio/tests/ |
| 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/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/pc/ |
| D | peer_connection_rtp_unittest.cc | 212 auto sender = caller->AddAudioTrack("audio_track", {}); in TEST_P() local
218 EXPECT_TRUE(caller->pc()->RemoveTrack(sender)); in TEST_P()
230 auto sender = caller->AddAudioTrack("audio_track", {"audio_stream"}); in TEST_P() local
236 EXPECT_TRUE(caller->pc()->RemoveTrack(sender)); in TEST_P()
445 auto sender = caller->AddAudioTrack("audio_track", {}); in TEST_F() local
451 caller->pc()->RemoveTrack(sender); in TEST_F()
543 auto sender = caller->AddAudioTrack("audio_track", {}); in TEST_P() local
544 ASSERT_TRUE(sender); in TEST_P()
549 ASSERT_TRUE(caller->pc()->RemoveTrack(sender)); in TEST_P()
568 auto sender = caller->AddAudioTrack("audio_track", {"audio_stream"}); in TEST_P() local
[all …]
|
| D | rtp_transceiver.cc | 109 rtc::scoped_refptr<RtpSenderProxyWithInternal<RtpSenderInternal>> sender, in RtpTransceiver() argument
115 media_type_(sender->media_type()), in RtpTransceiver()
120 RTC_DCHECK_EQ(sender->media_type(), receiver->media_type()); in RtpTransceiver()
121 senders_.push_back(sender); in RtpTransceiver()
150 for (const auto& sender : senders_) { in SetChannel() local
151 sender->internal()->SetMediaChannel(channel_ ? channel_->media_channel() in SetChannel()
166 rtc::scoped_refptr<RtpSenderProxyWithInternal<RtpSenderInternal>> sender) { in AddSender() argument
169 RTC_DCHECK(sender); in AddSender()
170 RTC_DCHECK_EQ(media_type(), sender->media_type()); in AddSender()
171 RTC_DCHECK(!absl::c_linear_search(senders_, sender)); in AddSender()
[all …]
|
| /external/webrtc/sdk/android/instrumentationtests/src/org/webrtc/ |
| D | RtpSenderTest.java | 54 RtpSender sender = transceiver.getSender(); in testSetDegradationPreference() local
56 RtpParameters parameters = sender.getParameters(); in testSetDegradationPreference()
61 assertTrue(sender.setParameters(parameters)); in testSetDegradationPreference()
62 parameters = sender.getParameters(); in testSetDegradationPreference()
66 assertTrue(sender.setParameters(parameters)); in testSetDegradationPreference()
67 parameters = sender.getParameters(); in testSetDegradationPreference()
71 assertTrue(sender.setParameters(parameters)); in testSetDegradationPreference()
72 parameters = sender.getParameters(); in testSetDegradationPreference()
76 assertTrue(sender.setParameters(parameters)); in testSetDegradationPreference()
77 parameters = sender.getParameters(); in testSetDegradationPreference()
|
| /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/openscreen/discovery/mdns/ |
| D | mdns_sender_unittest.cc | 109 MdnsSender sender(&socket); in TEST_F() local
112 EXPECT_EQ(sender.SendMulticast(query_message_), Error::Code::kNone); in TEST_F()
119 MdnsSender sender(&socket); in TEST_F() local
122 EXPECT_EQ(sender.SendMessage(response_message_, endpoint), in TEST_F()
133 MdnsSender sender(&socket); in TEST_F() local
136 EXPECT_EQ(sender.SendMessage(response_message_, endpoint), in TEST_F()
150 MdnsSender sender(&socket); in TEST_F() local
151 EXPECT_EQ(sender.SendMulticast(big_message_), in TEST_F()
158 MdnsSender sender(&socket); in TEST_F() local
162 EXPECT_EQ(sender.SendMulticast(query_message_), Error::Code::kNone); in TEST_F()
|
| /external/python/bumble/bumble/ |
| D | link.py | 237 sender, *payload = message.split('/', 1)
243 await handler(sender, payload[0] if payload else None)
245 async def on_advertisement_message_received(self, sender, advertisement): argument
247 self.controller.on_link_advertising_data(Address(sender), bytes.fromhex(advertisement))
251 async def on_acl_message_received(self, sender, acl_data): argument
253 self.controller.on_link_acl_data(Address(sender), bytes.fromhex(acl_data))
257 async def on_connect_message_received(self, sender, _): argument
259 self.peripheral_connections.add(sender)
263 self.controller.on_link_central_connected(Address(sender))
266 await self.send_targetted_message(sender, 'connected')
[all …]
|
| /external/skia/tools/sk_app/ios/ |
| D | Window_ios.mm | 152 - (void)panGestureAction:(UIGestureRecognizer*)sender {
153 CGPoint location = [sender locationInView:self];
154 switch (sender.state) {
176 - (void)tapGestureAction:(UIGestureRecognizer*)sender {
177 CGPoint location = [sender locationInView:self];
178 switch (sender.state) {
190 - (void)pinchGestureAction:(UIGestureRecognizer*)sender {
191 CGPoint location = [sender locationInView:self];
192 UIPinchGestureRecognizer* pinchGestureRecognizer = (UIPinchGestureRecognizer*) sender;
194 switch (sender.state) {
[all …]
|
| /external/libchrome/ipc/ |
| D | ipc_channel_proxy_unittest.cc | 269 sender()->Send(new WorkerMsg_Quit); in SendQuitMessageAndWaitForIdle()
279 IPC::Sender* sender() { return channel_proxy_.get(); } in sender() function in __anone89546b40111::IPCChannelProxyTest
298 sender()->Send(new TestMsg_Bounce); in TEST_F()
299 sender()->Send(new AutomationMsg_Bounce); in TEST_F()
302 sender()->Send(new WorkerMsg_Bounce); in TEST_F()
324 sender()->Send(new TestMsg_Bounce); in TEST_F()
327 sender()->Send(new AutomationMsg_Bounce); in TEST_F()
353 sender()->Send(new TestMsg_Bounce); in TEST_F()
354 sender()->Send(new AutomationMsg_Bounce); in TEST_F()
372 sender()->Send(new TestMsg_SendBadMessage()); in TEST_F()
[all …]
|
| /external/google-breakpad/src/client/mac/testapp/ |
| D | Controller.h | 58 - (IBAction)crash:(id)sender;
59 - (IBAction)forkTestOptions:(id)sender;
60 - (IBAction)forkTestGo:(id)sender;
61 - (IBAction)showForkTestWindow:(id) sender;
62 - (void)generateReportWithoutCrash:(id)sender;
|
| /external/rust/crates/async-task/examples/ |
| D | spawn-on-thread.rs | 19 let (sender, receiver) = flume::unbounded(); in spawn_on_thread()
20 let sender = Arc::new(sender); in spawn_on_thread() localVariable
21 let s = Arc::downgrade(&sender); in spawn_on_thread()
26 let _sender = sender; in spawn_on_thread()
|
| /external/clang/test/SemaObjC/ |
| D | method-attributes.m | 43 - (void)doSomething1:(id)sender;
44 - (void)doSomething2:(id)sender;
48 - (void)doSomething1:(id)sender{}
49 - (void)doSomething2:(id)sender{}
53 - (IBAction)doSomething1:(id)sender;
56 - (IBAction)doSomething1:(id)sender {}
57 - (IBAction)doSomething2:(id)sender {}
58 - (IBAction)doSomething3:(id)sender {}
|
| /external/libchrome/mojo/public/interfaces/bindings/tests/ |
| D | test_associated_interfaces.mojom | 49 GetSender(associated IntegerSender& sender);
50 AsyncGetSender() => (associated IntegerSender sender);
54 GetSender(associated IntegerSender& sender);
55 SetSender(associated IntegerSender sender) => (int32 value);
59 GetIntegerSender(associated IntegerSender& sender);
60 GetStringSender(associated StringSender& sender);
|
| /external/grpc-grpc-java/alts/src/test/java/io/grpc/alts/internal/ |
| D | TsiTest.java | 119 TsiFrameProtector sender, in sendMessage() argument
130 sender.protectFlush( in sendMessage()
256 TsiFrameProtector sender = handshakers.getClient().createFrameProtector(alloc); in corruptedCounterTest() local
264 sender.protectFlush( in corruptedCounterTest()
288 sender.destroy(); in corruptedCounterTest()
297 TsiFrameProtector sender = handshakers.getClient().createFrameProtector(alloc); in corruptedCiphertextTest() local
305 sender.protectFlush( in corruptedCiphertextTest()
327 sender.destroy(); in corruptedCiphertextTest()
336 TsiFrameProtector sender = handshakers.getClient().createFrameProtector(alloc); in corruptedTagTest() local
344 sender.protectFlush( in corruptedTagTest()
[all …]
|