/foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
H A D | result_set_proxy.cpp | 41 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() 113 return Send(Cod in IsAtFirstRow() 169 int ResultSetProxy::Send(uint32_t code, T &...output) const Send() function in OHOS::NativeRdb::ResultSetProxy [all...] |
/foundation/communication/ipc/interfaces/innerkits/rust/src/ipc_async/ |
H A D | mod.rs | 27 /// without littering it with Pin and Send bounds.
28 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 in spawn() [all...] |
H A D | ipc_ylong.rs | 31 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()
|
/foundation/multimodalinput/input/intention/cooperate/plugin/src/ |
H A D | cooperate.cpp | 53 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() 180 auto ret = context_.Sender().Send(CooperateEvent(CooperateEventType::START, event)); in Start() 190 auto ret = context_.Sender().Send(CooperateEven in Stop() [all...] |
/foundation/CastEngine/castengine_wifi_display/services/network/interfaces/ |
H A D | iclient.h | 36 virtual bool Send(const std::string &msg) = 0; 37 virtual bool Send(const char *buf, int32_t nSize) = 0; 38 virtual bool Send(const DataBuffer::Ptr &buf, int32_t nSize) = 0;
|
H A D | inetwork_session.h | 34 virtual bool Send(const char *buf, int32_t nSize) = 0; 35 virtual bool Send(const DataBuffer::Ptr &buf, int32_t nSize) = 0;
|
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/session/mock/ |
H A D | mock_client.h | 27 bool Send(const DataBuffer::Ptr &buf, int32_t nSize) in Send() function in OHOS::Sharing::MockClient 38 MOCK_METHOD(bool, Send, (const std::string &msg)); 39 MOCK_METHOD(bool, Send, (const char *buf, int32_t nSize));
|
H A D | mock_network_session.h | 27 bool Send(const DataBuffer::Ptr &buf, int32_t nSize) in Send() function in OHOS::Sharing::MockNetworkSession 51 MOCK_METHOD(bool, Send, (const char *buf, int32_t nSize));
|
/foundation/CastEngine/castengine_wifi_display/services/network/client/ |
H A D | tcp_client.h | 35 bool Send(const std::string &msg) override; 36 bool Send(const char *buf, int32_t nSize) override; 37 bool Send(const DataBuffer::Ptr &buf, int32_t nSize) override;
|
H A D | udp_client.h | 35 bool Send(const std::string &msg) override; 36 bool Send(const char *buf, int32_t nSize) override; 37 bool Send(const DataBuffer::Ptr &buf, int32_t nSize) override;
|
H A D | tcp_client.cpp | 100 bool TcpClient::Send(const DataBuffer::Ptr &buf, int32_t nSize) in Send() function in OHOS::Sharing::TcpClient 104 return Send(buf->Peek(), nSize); in Send() 107 bool TcpClient::Send(const char *buf, int32_t nSize) in Send() function in OHOS::Sharing::TcpClient 125 bool TcpClient::Send(const std::string &msg) in Send() function in OHOS::Sharing::TcpClient 128 return Send(msg.c_str(), msg.size()); in Send()
|
H A D | udp_client.cpp | 86 bool UdpClient::Send(const DataBuffer::Ptr &buf, int32_t nSize) in Send() function in OHOS::Sharing::UdpClient 90 return Send(buf->Peek(), nSize); in Send() 93 bool UdpClient::Send(const char *buf, int32_t nSize) in Send() function in OHOS::Sharing::UdpClient 116 bool UdpClient::Send(const std::string &msg) in Send() function in OHOS::Sharing::UdpClient 119 return Send(msg.c_str(), msg.size()); in Send()
|
/foundation/communication/wifi/wifi/test/wifi_standard/wifi_framework/wifi_toolkit/unittest/ |
H A D | raw_socket_test.cpp | 63 EXPECT_TRUE(pRawSocket->Send(buff, count, destHwaddr) == -1); in HWTEST_F() 72 EXPECT_TRUE(pRawSocket->Send(buff, count, destHwaddr) == -1); in HWTEST_F() 93 EXPECT_TRUE(pRawSocket->Send(buff, count, destHwaddr) == -1); in HWTEST_F() 101 EXPECT_TRUE(pRawSocket->Send(buff, count, destHwaddr) == -1); in HWTEST_F()
|
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/session/ |
H A D | wfd_source_session_test.cpp | 101 EXPECT_CALL(*networkSession_, Send(_, _)).WillOnce(Return(false)); in HWTEST_F() 255 EXPECT_CALL(*networkSession_, Send(_, _)).Times(2) in HWTEST_F() 286 EXPECT_CALL(*networkSession_, Send(_, _)).Times(2) in HWTEST_F() 302 EXPECT_CALL(*networkSession_, Send(_, _)).WillOnce(Return(false)); in HWTEST_F() 319 EXPECT_CALL(*networkSession_, Send(_, _)).WillOnce(Return(false)); in HWTEST_F() 335 EXPECT_CALL(*networkSession_, Send(_, _)).WillOnce(Return(false)); in HWTEST_F() 351 EXPECT_CALL(*networkSession_, Send(_, _)).WillOnce(Return(false)); in HWTEST_F() 365 EXPECT_CALL(*networkSession_, Send(_, _)).WillOnce(Return(false)); in HWTEST_F() 408 EXPECT_CALL(*networkSession_, Send(_, _)).WillOnce(Return(false)); in HWTEST_F() 425 EXPECT_CALL(*networkSession_, Send( in HWTEST_F() [all...] |
/foundation/multimodalinput/input/intention/common/channel/test/ |
H A D | channel_test.cpp | 57 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in HWTEST_F() 86 EXPECT_EQ(sender.Send(index), Channel<size_t>::NO_ERROR); in HWTEST_F() 111 EXPECT_EQ(sender.Send(data), Channel<size_t>::INACTIVE_CHANNEL); in HWTEST_F() 127 EXPECT_EQ(sender.Send(data++), Channel<size_t>::NO_ERROR); in HWTEST_F() 129 EXPECT_EQ(sender.Send(data), Channel<size_t>::QUEUE_IS_FULL); in HWTEST_F()
|
/foundation/ability/ability_runtime/interfaces/inner_api/wantagent/include/ |
H A D | pending_want.h | 210 void Send(const sptr<AAFwk::IWantSender> &target); 212 void Send(int resultCode, const sptr<AAFwk::IWantSender> &target); 214 void Send(int resultCode, 217 void Send(int resultCode, const sptr<CompletedDispatcher> &onCompleted, const sptr<AAFwk::IWantSender> &target); 219 void Send(int resultCode, 223 void Send(int resultCode, 227 ErrCode Send(int resultCode, const std::shared_ptr<AAFwk::Want> &want, 275 void Send(const int32_t resultCode) override;
|
/foundation/communication/netstack/test/unittest/tlssocket/server/ |
H A D | TlsSocketServerTest.cpp | 107 server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_SUCCESS); }); in HWTEST_F() 123 server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_SUCCESS); }); in HWTEST_F() 143 server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_SUCCESS); }); in HWTEST_F() 181 server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_SUCCESS); }); in HWTEST_F() 204 server.Send(tlsServerSendOptions, [](int32_t errCode) { in HWTEST_F() 228 server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(TlsSocket::TLSSOCKET_SUCCESS); }); in HWTEST_F() 249 server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(TlsSocket::TLSSOCKET_SUCCESS); }); in HWTEST_F() 286 server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(TlsSocket::TLSSOCKET_SUCCESS); }); in HWTEST_F()
|
/foundation/CastEngine/castengine_wifi_display/services/network/session/ |
H A D | tcp_session.cpp | 55 bool TcpSession::Send(const DataBuffer::Ptr &buf, int32_t nSize) in Send() function in OHOS::Sharing::TcpSession 59 return TcpSession::Send(buf->Peek(), nSize); in Send() 62 bool TcpSession::Send(const char *buf, int32_t nSize) in Send() function in OHOS::Sharing::TcpSession
|
H A D | tcp_session.h | 36 bool Send(const char *buf, int32_t nSize) override; 37 bool Send(const DataBuffer::Ptr &buf, int32_t nSize) override;
|
H A D | udp_session.h | 36 bool Send(const char *buf, int32_t nSize) override; 37 bool Send(const DataBuffer::Ptr &buf, int32_t nSize) override;
|
/foundation/communication/ipc/ipc/native/c/rpc/trans_adapter/src/ |
H A D | rpc_softbus_trans.c | 95 static int32_t Send(int32_t sessionId, const void *data, uint32_t len) in Send() function 98 RPC_LOG_ERROR("Send invalid sessionId=%d", sessionId); in Send() 102 RPC_LOG_ERROR("Send data is null"); in Send() 108 RPC_LOG_ERROR("Send failed, error=%d", ret); in Send() 138 .Send = Send,
|
/foundation/ability/ability_runtime/interfaces/inner_api/wantagent/src/ |
H A D | pending_want.cpp | 241 void PendingWant::Send(const sptr<AAFwk::IWantSender> &target) in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant 243 Send(0, nullptr, nullptr, "", nullptr, nullptr, target); in Send() 246 void PendingWant::Send(int resultCode, const sptr<AAFwk::IWantSender> &target) in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant 248 Send(resultCode, nullptr, nullptr, "", nullptr, nullptr, target); in Send() 251 void PendingWant::Send(int resultCode, const std::shared_ptr<Want> &want, in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant 254 Send(resultCode, want, nullptr, "", nullptr, nullptr, target); in Send() 257 void PendingWant::Send( in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant 260 Send(resultCode, nullptr, onCompleted, "", nullptr, nullptr, target); in Send() 263 void PendingWant::Send(int resultCode, const std::shared_ptr<Want> &want, in Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant 266 Send(resultCod in Send() 269 void PendingWant::Send(int resultCode, const std::shared_ptr<Want> &want, Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant 276 ErrCode PendingWant::Send(int resultCode, const std::shared_ptr<Want> &want, Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant 352 void PendingWant::CancelReceiver::Send(const int32_t resultCode) Send() function in OHOS::AbilityRuntime::WantAgent::PendingWant::CancelReceiver [all...] |
/foundation/communication/netstack/test/unittest/tls_test/client/ |
H A D | TlsSocketTest.cpp | 100 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 118 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 135 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 154 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 172 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 210 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 237 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 255 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 276 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 297 testService.Send(tcpSendOption in HWTEST_F() [all...] |
H A D | TlsSocketCertChainTest.cpp | 103 certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 122 certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 140 certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 178 certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 204 certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 222 certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 242 certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 263 certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 287 certChainServer.Send(testTcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); });
in HWTEST_F() 334 certChainServer.Send(testOption in HWTEST_F() [all...] |
/foundation/communication/netstack/test/unittest/tlssocket/client/ |
H A D | TlsSocketTest.cpp | 100 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in HWTEST_F() 118 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in HWTEST_F() 135 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in HWTEST_F() 154 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in HWTEST_F() 172 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in HWTEST_F() 210 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in HWTEST_F() 237 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in HWTEST_F() 255 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in HWTEST_F() 276 testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in HWTEST_F() 297 testService.Send(tcpSendOption in HWTEST_F() [all...] |