Home
last modified time | relevance | path

Searched refs:Send (Results 1 – 25 of 379) sorted by relevance

12345678910>>...16

/ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/ipc_async/
H A Dmod.rs28 pub type BoxFuture<'a, T> = Pin<Box<dyn Future<Output = T> + Send + 'a>>;
45 F1: Send + 'static, in spawn()
46 F2: Send + 'a, in spawn()
47 Fut: Send + 'a, in spawn()
48 A: Send + 'static, in spawn()
49 B: Send + 'a; in spawn()
58 T: Send + 'static, in spawn()
59 R: Send + 'static; in spawn()
65 T: Send + 'static, in spawn_blocking()
66 R: Send + 'static; in spawn_blocking()
H A Dipc_ylong.rs31 F1: Send + 'static, in spawn()
32 F2: Send + 'a, in spawn()
33 Fut: Send + 'a, in spawn()
34 A: Send + 'static, in spawn()
35 B: Send + 'a, in spawn()
70 T: Send + 'static, in spawn()
71 R: Send + 'static, in spawn()
79 T: Send + 'static, in spawn_blocking()
80 R: Send + 'static, in spawn_blocking()
/ohos5.0/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/
H A Dresult_set_proxy.cpp41 return Send(Code::CMD_GET_COLUMN_COUNT, count); in GetColumnCount()
61 return Send(Code::CMD_GET_ROW_COUNT, count); in GetRowCount()
66 return Send(Code::CMD_GET_ROW_INDEX, position); in GetRowIndex()
83 return Send(Code::CMD_GO_TO_FIRST_ROW); in GoToFirstRow()
88 return Send(Code::CMD_GO_TO_LAST_ROW); in GoToLastRow()
93 return Send(Code::CMD_GO_TO_NEXT_ROW); in GoToNextRow()
98 return Send(Code::CMD_GO_TO_PREV_ROW); in GoToPreviousRow()
103 return Send(Code::CMD_IS_ENDED_ROW, result); in IsEnded()
108 return Send(Code::CMD_IS_STARTED_ROW, result); in IsStarted()
118 return Send(Code::CMD_IS_AT_LAST_ROW, result); in IsAtLastRow()
[all …]
/ohos5.0/foundation/multimodalinput/input/intention/cooperate/plugin/src/
H A Dcooperate.cpp53 auto ret = context_.Sender().Send(CooperateEvent( in AddObserver()
66 auto ret = context_.Sender().Send(CooperateEvent( in RemoveObserver()
79 auto ret = context_.Sender().Send(CooperateEvent( in RegisterListener()
93 auto ret = context_.Sender().Send(CooperateEvent( in UnregisterListener()
107 auto ret = context_.Sender().Send(CooperateEvent( in RegisterHotAreaListener()
121 auto ret = context_.Sender().Send(CooperateEvent( in UnregisterHotAreaListener()
135 auto ret = context_.Sender().Send(CooperateEvent( in Enable()
151 auto ret = context_.Sender().Send(CooperateEvent( in Disable()
190 auto ret = context_.Sender().Send(CooperateEvent( in Stop()
206 auto ret = context_.Sender().Send(CooperateEvent( in GetCooperateState()
[all …]
/ohos5.0/base/msdp/device_status/intention/cooperate/plugin/src/
H A Dcooperate.cpp53 auto ret = context_.Sender().Send(CooperateEvent( in AddObserver()
66 auto ret = context_.Sender().Send(CooperateEvent( in RemoveObserver()
79 auto ret = context_.Sender().Send(CooperateEvent( in RegisterListener()
93 auto ret = context_.Sender().Send(CooperateEvent( in UnregisterListener()
107 auto ret = context_.Sender().Send(CooperateEvent( in RegisterHotAreaListener()
121 auto ret = context_.Sender().Send(CooperateEvent( in UnregisterHotAreaListener()
135 auto ret = context_.Sender().Send(CooperateEvent( in Enable()
151 auto ret = context_.Sender().Send(CooperateEvent( in Disable()
190 auto ret = context_.Sender().Send(CooperateEvent( in Stop()
206 auto ret = context_.Sender().Send(CooperateEvent( in GetCooperateState()
[all …]
/ohos5.0/base/msdp/device_status/rust/modules/scheduler/sys/src/
H A Dlib.rs86 F: Fn() -> R + Send + 'static, in post_sync_task()
87 R: Send + 'static, in post_sync_task()
118 F: Fn() -> R + Send + 'static, in post_async_task()
119 R: Send + 'static, in post_async_task()
134 F: Fn() -> R + Send + 'static, in post_delayed_task()
135 R: Send + 'static, in post_delayed_task()
157 F: Fn() + Send + 'static in post_perioric_task()
176 F: Fn() -> R + Send + 'static, in post_blocking_task()
177 R: Send + 'static, in post_blocking_task()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/
H A Dmod.rs34 pub trait ParallelIterator: Sized + Send {
87 ) -> Pin<Box<dyn std::future::Future<Output = Result<(), ScheduleError>> + Send + 'a>> in for_each()
89 F: Fn(Self::Item) + Send + Copy + Sync + 'a, in for_each()
99 ) -> Pin<Box<dyn std::future::Future<Output = Result<Self::Item, ScheduleError>> + Send + 'a>> in sum()
102 Self::Item: Add<Output = Self::Item> + Sum + Send, in sum()
112 ) -> Pin<Box<dyn std::future::Future<Output = Result<C::Output, ScheduleError>> + Send + 'a>> in drive()
115 C: Consumer<Self> + Send + Sync + 'a, in drive()
125 type Output: Send;
H A Dsum.rs22 P: ParallelIterator + Send, in sum() argument
23 P::Item: Add<Output = P::Item> + Sum + Send, in sum()
34 P::Item: Add<Output = P::Item> + Sum + Send,
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/
H A Dcore.rs32 P: ParallelIterator + Send, in core() argument
33 C: Consumer<P> + Send + Sync, in core()
81 P: ParallelIterator + Send, in recur() argument
82 C: Consumer<P> + Send + Sync, in recur()
133 P: ParallelIterator + Send, in spawn_task() argument
134 C: Consumer<P> + Send + Sync, in spawn_task()
158 P: ParallelIterator + Send, in recur_ffrt() argument
159 C: Consumer<P> + Send + Sync, in recur_ffrt()
195 P: ParallelIterator + Send, in spawn_task_ffrt() argument
196 C: Consumer<P> + Send + Sync, in spawn_task_ffrt()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
H A Dspawn.rs50 T: Send + 'static,
51 R: Send + 'static,
63 T: Send + 'static, in spawn_blocking()
64 R: Send + 'static, in spawn_blocking()
76 T: Send + 'static, in spawn_async()
77 R: Send + 'static, in spawn_async()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dmod.rs70 unsafe impl Send for Task {}
104 T: Future + Send + 'static, in create_task()
105 T::Output: Send + 'static, in create_task()
144 T: Send + 'static, in spawn()
145 R: Send + 'static, in spawn()
154 T: Send + 'static, in spawn_blocking()
155 R: Send + 'static, in spawn_blocking()
H A Djoin_set.rs56 unsafe impl<R: Send> Send for JoinSet<R> {}
58 unsafe impl<R: Send> Sync for JoinSet<R> {}
158 T: Future<Output = R> + Send + 'static, in spawn()
159 R: Send + 'static, in spawn()
166 T: Future<Output = R> + Send + 'static, in spawn_inner()
167 R: Send + 'static, in spawn_inner()
415 T: Future<Output = R> + Send + 'static, in spawn()
416 R: Send + 'static, in spawn()
H A Dbuilder.rs65 T: Send + 'static, in spawn()
66 R: Send + 'static, in spawn()
75 T: Send + 'static, in spawn_blocking()
76 R: Send + 'static, in spawn_blocking()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dmod.rs101 type Error: Into<Box<dyn Error + Send + Sync>>;
222 type Error: Into<Box<dyn Error + Send + Sync>>;
409 ) -> Pin<Box<dyn Future<Output = std::io::Result<()>> + Send + Sync + 'a>> in reuse()
417 ) -> Pin<Box<dyn Future<Output = std::io::Result<()>> + Send + Sync + 'a>> in reuse()
430 ) -> Pin<Box<dyn Future<Output = std::io::Result<()>> + Send + Sync + 'a>> in reuse()
497 pub struct FromAsyncReader<T: AsyncRead + Unpin + Send + Sync> {
501 impl<T: AsyncRead + Unpin + Send + Sync> FromAsyncReader<T> {
507 impl<T: AsyncRead + Unpin + Send + Sync> Deref for FromAsyncReader<T> {
515 impl<T: AsyncRead + Unpin + Send + Sync> DerefMut for FromAsyncReader<T> {
/ohos5.0/foundation/multimodalinput/input/intention/common/channel/test/
H A Dchannel_test.cpp57 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in __anon6484951c0202()
86 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in __anon6484951c0302()
111 EXPECT_EQ(sender.Send(data), Channel<size_t>::INACTIVE_CHANNEL);
127 EXPECT_EQ(sender.Send(data++), Channel<size_t>::NO_ERROR);
129 EXPECT_EQ(sender.Send(data), Channel<size_t>::QUEUE_IS_FULL);
/ohos5.0/base/msdp/device_status/test/unittest/intention/common/src/
H A Dchannel_test.cpp57 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in __anonb4f9918d0202()
86 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in __anonb4f9918d0302()
111 EXPECT_EQ(sender.Send(data), Channel<size_t>::INACTIVE_CHANNEL);
127 EXPECT_EQ(sender.Send(data++), Channel<size_t>::NO_ERROR);
129 EXPECT_EQ(sender.Send(data), Channel<size_t>::QUEUE_IS_FULL);
/ohos5.0/foundation/communication/netstack/test/unittest/tlssocket/client/
H A DTlsSocketTest.cpp100 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c0602()
118 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c0802()
135 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c0a02()
154 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c0c02()
172 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c0e02()
210 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c1302()
237 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c1602()
255 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c1802()
276 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c1b02()
297 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anon0295c29c1e02()
[all …]
H A DTlsSocketCertChainTest.cpp103 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anon6010aead0602()
122 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anon6010aead0802()
140 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anon6010aead0a02()
178 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anon6010aead0f02()
204 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anon6010aead1202()
222 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anon6010aead1402()
242 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anon6010aead1702()
263 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anon6010aead1a02()
287 …certChainServer.Send(testTcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SU… in __anon6010aead1d02()
334 …certChainServer.Send(testOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS);… in __anon6010aead2202()
[all …]
H A DTlsSocketCertChainOneWayTest.cpp104 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anondf24d1200602()
123 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anondf24d1200802()
141 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anondf24d1200a02()
181 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anondf24d1200f02()
208 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anondf24d1201202()
226 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anondf24d1201402()
247 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anondf24d1201702()
271 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anondf24d1201a02()
311 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anondf24d1201e02()
H A DTlsSocketOneWayTest.cpp102 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon018adc4f0602()
122 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon018adc4f0802()
141 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon018adc4f0a02()
180 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon018adc4f0f02()
207 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon018adc4f1202()
226 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon018adc4f1402()
247 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon018adc4f1702()
282 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon018adc4f1b02()
319 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon018adc4f1f02()
/ohos5.0/foundation/ability/ability_runtime/interfaces/inner_api/wantagent/include/
H A Dpending_want.h211 void Send(const sptr<AAFwk::IWantSender> &target);
213 void Send(int resultCode, const sptr<AAFwk::IWantSender> &target);
215 void Send(int resultCode,
218 …void Send(int resultCode, const sptr<CompletedDispatcher> &onCompleted, const sptr<AAFwk::IWantSen…
220 void Send(int resultCode,
224 void Send(int resultCode,
228 ErrCode Send(int resultCode, const std::shared_ptr<AAFwk::Want> &want,
276 void Send(const int32_t resultCode) override;
/ohos5.0/foundation/communication/netstack/test/unittest/tlssocket/server/
H A DTlsSocketServerTest.cpp107 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKE… in __anon487d28ab0302()
123 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKE… in __anon487d28ab0402()
143 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKE… in __anon487d28ab0602()
181 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKE… in __anon487d28ab0a02()
204 server.Send(tlsServerSendOptions, [](int32_t errCode) { in __anon487d28ab0d02()
228 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(TlsSocket::TLSSOCKET_SUCCESS);… in __anon487d28ab1102()
249 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(TlsSocket::TLSSOCKET_SUCCESS);… in __anon487d28ab1402()
286 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(TlsSocket::TLSSOCKET_SUCCESS);… in __anon487d28ab1802()
/ohos5.0/foundation/ability/ability_runtime/interfaces/inner_api/wantagent/src/
H A Dpending_want.cpp242 void PendingWant::Send(const sptr<AAFwk::IWantSender> &target) in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant
244 Send(0, nullptr, nullptr, "", nullptr, nullptr, target); in Send()
249 Send(resultCode, nullptr, nullptr, "", nullptr, nullptr, target); in Send()
252 void PendingWant::Send(int resultCode, const std::shared_ptr<Want> &want, in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant
255 Send(resultCode, want, nullptr, "", nullptr, nullptr, target); in Send()
258 void PendingWant::Send( in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant
261 Send(resultCode, nullptr, onCompleted, "", nullptr, nullptr, target); in Send()
264 void PendingWant::Send(int resultCode, const std::shared_ptr<Want> &want, in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant
267 Send(resultCode, want, onCompleted, "", nullptr, nullptr, target); in Send()
270 void PendingWant::Send(int resultCode, const std::shared_ptr<Want> &want, in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant
[all …]
/ohos5.0/foundation/communication/wifi/wifi/test/wifi_standard/wifi_framework/wifi_toolkit/unittest/
H A Draw_socket_test.cpp63 EXPECT_TRUE(pRawSocket->Send(buff, count, destHwaddr) == -1);
72 EXPECT_TRUE(pRawSocket->Send(buff, count, destHwaddr) == -1);
93 EXPECT_TRUE(pRawSocket->Send(buff, count, destHwaddr) == -1);
101 EXPECT_TRUE(pRawSocket->Send(buff, count, destHwaddr) == -1);
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/dns/
H A Dresolver.rs27 pub type Addrs = Box<dyn Iterator<Item = SocketAddr> + Sync + Send>;
30 pub type StdError = Box<dyn std::error::Error + Send + Sync>;
32 pub type SocketFuture = Pin<Box<dyn Future<Output = Result<Addrs, StdError>> + Sync + Send>>;
36 pub trait Resolver: Send + Sync + 'static {

12345678910>>...16