| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/av_sender/test/unittest/av_sender_engine/src/ |
| H A D | av_sender_engine_test.cpp | 62 sender->videoEncoder_ =
64 sender->avInput_ =
167 sender->Stop();
180 sender->Stop();
191 sender->Start();
250 sender->InitPipeline();
266 sender->InitPipeline();
282 sender->InitPipeline();
298 sender->InitPipeline();
319 sender->InitPipeline();
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | udp_test.rs | 37 let connected_sender = sender in sdv_udp_send_recv()
75 let n = sender in sdv_udp_send_to_recv_from()
108 let connected_sender = sender in sdv_udp_recv()
211 let connected_sender = sender in sdv_udp_try_recv()
249 let connected_sender = sender in sdv_udp_block_on_try_recv()
279 let connected_sender = sender in sdv_udp_send_recv_poll()
320 sender in sdv_send_to_peek_from()
354 let number_of_bytes = sender in sdv_send_to_try_peek_from()
491 sender.set_ttl(80).unwrap(); in sdv_udp_basic_v4()
511 sender in sdv_udp_basic_v4()
[all …]
|
| /ohos5.0/base/notification/distributed_notification_service/frameworks/ans/test/unittest/ |
| H A D | notification_conversational_message_test.cpp | 45 MessageUser sender; variable
62 MessageUser sender; variable
82 MessageUser sender; variable
101 MessageUser sender; variable
118 MessageUser sender; variable
134 MessageUser sender; variable
138 std::make_shared<NotificationConversationalMessage>(text, timestamp, sender);
158 MessageUser sender; variable
174 MessageUser sender; variable
193 MessageUser sender; variable
[all …]
|
| H A D | notification_conversational_content_test.cpp | 184 MessageUser sender; variable
186 std::make_shared<NotificationConversationalMessage>("messageptr", 0, sender);
203 MessageUser sender; variable
248 MessageUser sender; variable
250 std::make_shared<NotificationConversationalMessage>("testMessage", 0, sender);
287 MessageUser sender; variable
289 … auto messagePtr = std::make_shared<NotificationConversationalMessage>("test", timestamp, sender);
|
| /ohos5.0/base/telephony/sms_mms/test/fuzztest/gsmsmssender_fuzzer/ |
| H A D | gsmsmssender_fuzzer.cpp | 143 sender->Init(); in SendSmsTest()
166 sender->TextBasedSmsSplitDelivery( in SendSmsTest()
172 sender->SendSmsToRil(smsIndexer); in SendSmsTest()
173 sender->ResendTextDelivery(smsIndexer); in SendSmsTest()
174 sender->ResendDataDelivery(smsIndexer); in SendSmsTest()
181 sender->SendSmsToRil(smsIndexer); in SendSmsTest()
190 sender->Init(); in SendSmsTest2()
191 sender->RegisterSatelliteCallback(); in SendSmsTest2()
192 sender->UnregisterSatelliteCallback(); in SendSmsTest2()
213 sender->StatusReportAnalysis(event); in SendSmsTest2()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_multi_threaded.rs | 31 fn runtime_spawn_many(runtime: &Runtime, sender: mpsc::SyncSender<()>) {
33 sender.send(()).unwrap();
37 fn runtime_yield_many(runtime: &Runtime, sender: mpsc::SyncSender<()>) {
42 sender.send(()).unwrap();
96 sender.send(()).unwrap(); in chained_spawn()
108 let sender = send.clone(); in chained_spawn() localVariable
138 fn iter(sender: mpsc::SyncSender<()>, n: usize) { in chained_spawn()
140 sender.send(()).unwrap(); in chained_spawn()
142 tokio::spawn(async move { iter(sender, n - 1) }); in chained_spawn()
150 let sender = send.clone(); in chained_spawn() localVariable
[all …]
|
| H A D | ylong_tokio_udp.rs | 46 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_connect() localVariable
48 let _connected_sender = sender.connect(receiver_addr).await.unwrap(); in ylong_udp_connect()
66 let sender = tokioUdpSocket::bind(sender_addr).await.unwrap(); in tokio_udp_connect() localVariable
68 sender.connect(receiver_addr).await.unwrap(); in tokio_udp_connect()
99 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_recv() localVariable
102 let connected_sender = sender.connect(receiver_addr).await.unwrap(); in ylong_udp_send_recv()
143 sender.connect(receiver_addr).await.unwrap(); in tokio_udp_send_recv()
147 sender.send(b"Hello").await.unwrap(); in tokio_udp_send_recv()
186 let sender = UdpSocket::bind(sender_addr).await.unwrap(); in ylong_udp_send_to_recv_from() localVariable
190 sender.send_to(b"Hello", receiver_addr).await.unwrap(); in ylong_udp_send_to_recv_from()
[all …]
|
| H A D | ylong_tokio_bounded_mpsc.rs | 30 let (sender, mut receiver) = channel(10);
41 let producer = sender.clone();
64 let (sender, mut receiver) = bounded_channel(10);
75 let producer = sender.clone();
|
| H A D | ylong_tokio_unbounded_mpsc.rs | 30 let (sender, mut receiver) = unbounded_channel();
41 let producer = sender.clone();
64 let (sender, mut receiver) = unbounded_channel();
75 let producer = sender.clone();
|
| /ohos5.0/foundation/multimodalinput/input/intention/common/channel/test/ |
| H A D | channel_test.cpp | 51 auto [sender, receiver] = Channel<size_t>::OpenChannel();
55 std::thread worker([sender = sender, count]() mutable { in __anon6484951c0202()
57 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in __anon6484951c0202()
80 auto [sender, receiver] = Channel<size_t>::OpenChannel();
84 std::thread worker([sender = sender, count]() mutable { in __anon6484951c0302()
86 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in __anon6484951c0302()
109 auto [sender, receiver] = Channel<size_t>::OpenChannel();
111 EXPECT_EQ(sender.Send(data), Channel<size_t>::INACTIVE_CHANNEL);
122 auto [sender, receiver] = Channel<size_t>::OpenChannel();
127 EXPECT_EQ(sender.Send(data++), Channel<size_t>::NO_ERROR);
[all …]
|
| /ohos5.0/base/msdp/device_status/test/unittest/intention/common/src/ |
| H A D | channel_test.cpp | 51 auto [sender, receiver] = Channel<size_t>::OpenChannel();
55 std::thread worker([sender = sender, count]() mutable { in __anonb4f9918d0202()
57 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in __anonb4f9918d0202()
80 auto [sender, receiver] = Channel<size_t>::OpenChannel();
84 std::thread worker([sender = sender, count]() mutable { in __anonb4f9918d0302()
86 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in __anonb4f9918d0302()
109 auto [sender, receiver] = Channel<size_t>::OpenChannel();
111 EXPECT_EQ(sender.Send(data), Channel<size_t>::INACTIVE_CHANNEL);
122 auto [sender, receiver] = Channel<size_t>::OpenChannel();
127 EXPECT_EQ(sender.Send(data++), Channel<size_t>::NO_ERROR);
[all …]
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_engine/av_sender/src/ |
| H A D | av_sender_engine_provider.cpp | 39 for (auto &sender : senderEngineList_) { in ~AVSenderEngineProvider() local
40 if (sender == nullptr) { in ~AVSenderEngineProvider()
43 sender->Release(); in ~AVSenderEngineProvider()
58 auto sender = std::make_shared<AVSenderEngine>(ownerName_, peerDevId); in CreateAVSenderEngine() local
59 if (sender && sender->Initialize() == DH_AVT_SUCCESS) { in CreateAVSenderEngine()
62 senderEngineList_.push_back(sender); in CreateAVSenderEngine()
64 return sender; in CreateAVSenderEngine()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| H A D | udp.rs | 1499 let socket_deal = |sender: &UdpSocket| { in ut_udp_basic_v4()
1500 sender.set_ttl(101).unwrap(); in ut_udp_basic_v4()
1501 assert_eq!(sender.ttl().unwrap(), 101); in ut_udp_basic_v4()
1505 sender.set_multicast_ttl_v4(42).unwrap(); in ut_udp_basic_v4()
1517 sender in ut_udp_basic_v4()
1558 let socket_deal = |sender: &UdpSocket| { in ut_udp_basic_v6()
1571 sender in ut_udp_basic_v6()
1739 sender in ut_send_to_peek_from()
1774 let number_of_bytes = sender in ut_send_to_try_peek_from()
1844 sender in ut_connected_peek()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | input.rs | 73 let sender = self.get_mut(); in poll() localVariable
75 match sender.state { in poll()
77 let frame = match sender.poll_recv_frame(cx) { in poll()
86 let state = sender.update_settings(&frame); in poll()
89 let mut sync = sender.settings.lock().unwrap(); in poll()
99 sender.encoder.set_frame(frame).map_err(|_| { in poll()
102 sender.state = InputState::WriteFrame; in poll()
105 match sender.poll_writer_frame(cx) { in poll()
110 sender.state = InputState::RecvFrame; in poll()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | registry.rs | 69 sender: UnixStream, field
75 let (sender, receiver) = UnixStream::pair() in default()
77 Self { sender, receiver } in default()
142 let mut sender = &self.stream.sender; in write() localVariable
143 sender.write(buf) in write()
|
| /ohos5.0/foundation/ability/ability_runtime/test/fuzztest/cancelwantsender_fuzzer/ |
| H A D | cancelwantsender_fuzzer.cpp | 37 sptr<IWantSender> sender = nullptr; in DoSomethingInterestingWithMyAPI() local
39 …sender = iface_cast<AAFwk::IWantSender>((static_cast<MessageParcel*>(&parcel))->ReadRemoteObject()… in DoSomethingInterestingWithMyAPI()
41 if (sender) { in DoSomethingInterestingWithMyAPI()
42 WantAgentClient::GetInstance().CancelWantSender(sender); in DoSomethingInterestingWithMyAPI()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| H A D | uds_test.rs | 139 let (sender, _) = UnixDatagram::pair().unwrap(); in sdv_uds_send_recv()
140 let addr = sender.local_addr().unwrap(); in sdv_uds_send_recv()
144 let addr = sender.peer_addr().unwrap(); in sdv_uds_send_recv()
148 let sender2 = sender.try_clone().unwrap(); in sdv_uds_send_recv()
153 let (sender, receiver) = UnixDatagram::pair().unwrap(); in sdv_uds_send_recv()
154 let n = sender.send(b"Hello").expect("sender send failed"); in sdv_uds_send_recv()
|
| H A D | udp_socket_test.rs | 30 let sender = match UdpSocket::bind(sender_addr) { in sdv_send_recv() localVariable
44 let connected_sender = match sender.connect(receiver_addr) { in sdv_send_recv()
90 let sender = match UdpSocket::bind(sender_addr) { in sdv_send_to_recv_from() localVariable
104 match sender.send_to(b"Hello", receiver_addr) { in sdv_send_to_recv_from()
|
| /ohos5.0/foundation/ability/ability_runtime/interfaces/inner_api/wantagent/src/ |
| H A D | want_agent_client.cpp | 111 ErrCode WantAgentClient::CancelWantSender(const sptr<IWantSender> &sender, uint32_t flags) in CancelWantSender() argument
113 CHECK_POINTER_AND_RETURN(sender, ERR_ABILITY_RUNTIME_EXTERNAL_INVALID_PARAMETER); in CancelWantSender()
124 if (!data.WriteRemoteObject(sender->AsObject())) { in CancelWantSender()
219 void WantAgentClient::RegisterCancelListener(const sptr<IWantSender> &sender, const sptr<IWantRecei… in RegisterCancelListener() argument
221 if (!CheckSenderAndRecevier(sender, receiver)) { in RegisterCancelListener()
235 if (!data.WriteRemoteObject(sender->AsObject())) { in RegisterCancelListener()
251 const sptr<IWantSender> &sender, const sptr<IWantReceiver> &receiver) in UnregisterCancelListener() argument
253 if (!CheckSenderAndRecevier(sender, receiver)) { in UnregisterCancelListener()
267 if (!data.WriteRemoteObject(sender->AsObject())) { in UnregisterCancelListener()
419 bool WantAgentClient::CheckSenderAndRecevier(const sptr<IWantSender> &sender, const sptr<IWantRecei… in CheckSenderAndRecevier() argument
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | dispatcher.rs | 196 pub(crate) sender: BoundedSender<RespMessage>,
213 pub(crate) sender: UnboundedSender<ReqMessage>,
224 pub(crate) sender: UnboundedSender<ReqMessage>,
319 sender: req_tx, in new()
375 let sender = self.sender.clone(); in dispatch() localVariable
401 sender: UnboundedSender<ReqMessage>, in new()
406 sender, in new()
419 self.sender in send_frame_to_controller()
422 sender: tx, in send_frame_to_controller()
472 if let Some(sender) = self.senders.get(&stream_id) { in send_message_to_stream()
[all …]
|
| /ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/hfp_hf/ |
| H A D | hfp_hf_command_processor.cpp | 103 HfpHfProfileEventSender &sender = HfpHfProfileEventSender::GetInstance(); in ProcessOK() local
112 sender.CurrentCallsReplyDone(dataConn.remoteAddr_); in ProcessOK()
158 HfpHfProfileEventSender &sender = HfpHfProfileEventSender::GetInstance(); in ProcessErrorCode() local
523 sender.NetworkStateChanged(dataConn.remoteAddr_, value); in ProcessIndicator()
525 sender.CallStateNotify(dataConn.remoteAddr_, value); in ProcessIndicator()
527 sender.CallSetupStateNotify(dataConn.remoteAddr_, value); in ProcessIndicator()
529 sender.CallHeldStateNotify(dataConn.remoteAddr_, value); in ProcessIndicator()
531 sender.NetworkSignalChanged(dataConn.remoteAddr_, value); in ProcessIndicator()
533 sender.NetworkRoamingChanged(dataConn.remoteAddr_, value); in ProcessIndicator()
535 sender.BatteryLevelChanged(dataConn.remoteAddr_, value); in ProcessIndicator()
[all …]
|
| /ohos5.0/foundation/ability/ability_runtime/test/fuzztest/getwantsender_fuzzer/ |
| H A D | getwantsender_fuzzer.cpp | 63 sptr<IWantSender> sender = nullptr; in DoSomethingInterestingWithMyAPI() local
67 WantAgentClient::GetInstance().GetWantSender(*wantSenderInfo, token, sender); in DoSomethingInterestingWithMyAPI()
76 if (sender && senderInfo) { in DoSomethingInterestingWithMyAPI()
77 WantAgentClient::GetInstance().SendWantSender(sender, *senderInfo); in DoSomethingInterestingWithMyAPI()
|
| /ohos5.0/foundation/ability/ability_runtime/interfaces/inner_api/wantagent/include/ |
| H A D | want_agent_client.h | 42 ErrCode CancelWantSender(const sptr<IWantSender> &sender, uint32_t flags = 0);
54 … void RegisterCancelListener(const sptr<IWantSender> &sender, const sptr<IWantReceiver> &receiver);
56 …void UnregisterCancelListener(const sptr<IWantSender> &sender, const sptr<IWantReceiver> &receiver…
77 … bool CheckSenderAndRecevier(const sptr<IWantSender> &sender, const sptr<IWantReceiver> &receiver);
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_control_center/inner_kits/src/ |
| H A D | av_trans_control_center_callback.cpp | 58 void AVTransControlCenterCallback::SetSenderEngine(const std::shared_ptr<IAVSenderEngine> &sender) in SetSenderEngine() argument
60 if (sender != nullptr) { in SetSenderEngine()
61 senderEngine_ = sender; in SetSenderEngine()
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/av_transport/av_trans_control_center/test/unittest/inner_kits/ |
| H A D | av_trans_control_center_callback_test.cpp | 121 std::shared_ptr<IAVSenderEngine> sender = std::shared_ptr<SenderEngineTest>(); variable
122 callBack_->SetSenderEngine(sender);
123 sender = nullptr;
124 callBack_->SetSenderEngine(sender);
|