Home
last modified time | relevance | path

Searched refs:isAsync (Results 1 - 25 of 122) sorted by relevance

12345

/foundation/ability/ability_runtime/services/abilitymgr/include/
H A Dfree_install_manager.h68 void OnInstallFinished(int32_t recordId, int resultCode, const Want &want, int32_t userId, bool isAsync = false);
86 * @param isAsync, the request is async.
91 bool isAsync = false, uint32_t specifyTokenId = 0, bool isOpenAtomicServiceShortUrl = false,
216 void NotifyFreeInstallResult(int32_t recordId, const Want &want, int resultCode, bool isAsync = false);
218 const sptr<IRemoteObject> &callerToken, bool isAsync, uint32_t specifyTokenId = 0,
234 void HandleFreeInstallResult(int32_t recordId, FreeInstallInfo &freeInstallInfo, int resultCode, bool isAsync);
235 void HandleOnFreeInstallSuccess(int32_t recordId, FreeInstallInfo &freeInstallInfo, bool isAsync);
236 void HandleOnFreeInstallFail(int32_t recordId, FreeInstallInfo &freeInstallInfo, int resultCode, bool isAsync);
/foundation/CastEngine/castengine_wifi_display/services/network/socket/
H A Dtcp_socket.cpp70 bool TcpSocket::Connect(const std::string &peerIp, uint16_t peerPort, int32_t &retCode, bool isAsync, bool enableReuse, in Connect() argument
91 SocketUtils::SetNonBlocking(fd, isAsync); in Connect()
96 if (!SocketUtils::ConnectSocket(fd, isAsync, peerIp, peerPort, retCode)) { in Connect()
H A Dudp_socket.cpp66 bool UdpSocket::Connect(const std::string &peerIp, uint16_t peerPort, int32_t &retCode, bool isAsync, bool enableReuse, in Connect() argument
81 SocketUtils::SetNonBlocking(fd, isAsync); in Connect()
87 if (SocketUtils::ConnectSocket(fd, isAsync, peerIp, peerPort, retCode)) { in Connect()
H A Dudp_socket.h32 bool Connect(const std::string &peerIp, uint16_t peerPort, int32_t &retCode, bool isAsync = true,
H A Dtcp_socket.h32 bool Connect(const std::string &peerIp, uint16_t peerPort, int32_t &retCode, bool isAsync = true,
H A Dbase_socket.h33 virtual bool Connect(const std::string &peerIp, uint16_t peerPort, int32_t &retCode, bool isAsync = true,
/foundation/communication/dsoftbus/core/transmission/trans_channel/common/include/
H A Dtrans_lane_pending_ctl.h56 int32_t TransCancelLaneItemCondByLaneHandle(uint32_t laneHandle, bool bSucc, bool isAsync, int32_t errCode);
57 int32_t TransDeleteLaneReqItemByLaneHandle(uint32_t laneHandle, bool isAsync);
58 int32_t TransFreeLaneByLaneHandle(uint32_t laneHandle, bool isAsync);
/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/include/
H A Dtrans_lane_manager.h49 int32_t TransLaneMgrDelLane(int32_t channelId, int32_t channelType, bool isAsync);
66 const char *sessionName, int32_t sessionId, uint32_t laneHandle, bool isQosLane, bool isAsync);
83 const char *sessionName, int32_t sessionId, uint32_t *laneHandle, bool *isQosLane, bool *isAsync);
/foundation/ability/ability_runtime/services/abilitymgr/src/
H A Datomic_service_status_callback.cpp24 const std::weak_ptr<FreeInstallManager> &server, bool isAsync, int32_t recordId) in AtomicServiceStatusCallback()
25 : server_(server), isAsync_(isAsync), recordId_(recordId) in AtomicServiceStatusCallback()
23 AtomicServiceStatusCallback( const std::weak_ptr<FreeInstallManager> &server, bool isAsync, int32_t recordId) AtomicServiceStatusCallback() argument
H A Dfree_install_manager.cpp82 const sptr<IRemoteObject> &callerToken, bool isAsync, uint32_t specifyTokenId, bool isOpenAtomicServiceShortUrl, in StartFreeInstall()
90 isAsync, specifyTokenId, isOpenAtomicServiceShortUrl, originalWant); in StartFreeInstall()
96 sptr<AtomicServiceStatusCallback> callback = new AtomicServiceStatusCallback(weak_from_this(), isAsync, recordId); in StartFreeInstall()
120 if (isAsync) { in StartFreeInstall()
168 const sptr<IRemoteObject> &callerToken, bool isAsync, uint32_t specifyTokenId, bool isOpenAtomicServiceShortUrl, in BuildFreeInstallInfo()
180 if (!isAsync) { in BuildFreeInstallInfo()
255 void FreeInstallManager::NotifyFreeInstallResult(int32_t recordId, const Want &want, int resultCode, bool isAsync) in NotifyFreeInstallResult() argument
279 if (!isAsync && freeInstallInfo.promise == nullptr) { in NotifyFreeInstallResult()
285 HandleFreeInstallResult(recordId, freeInstallInfo, resultCode, isAsync); in NotifyFreeInstallResult()
290 void FreeInstallManager::HandleOnFreeInstallSuccess(int32_t recordId, FreeInstallInfo &freeInstallInfo, bool isAsync) in HandleOnFreeInstallSuccess() argument
81 StartFreeInstall(const Want &want, int32_t userId, int requestCode, const sptr<IRemoteObject> &callerToken, bool isAsync, uint32_t specifyTokenId, bool isOpenAtomicServiceShortUrl, std::shared_ptr<Want> originalWant) StartFreeInstall() argument
167 BuildFreeInstallInfo(const Want &want, int32_t userId, int requestCode, const sptr<IRemoteObject> &callerToken, bool isAsync, uint32_t specifyTokenId, bool isOpenAtomicServiceShortUrl, std::shared_ptr<Want> originalWant) BuildFreeInstallInfo() argument
313 HandleOnFreeInstallFail(int32_t recordId, FreeInstallInfo &freeInstallInfo, int resultCode, bool isAsync) HandleOnFreeInstallFail() argument
344 HandleFreeInstallResult(int32_t recordId, FreeInstallInfo &freeInstallInfo, int resultCode, bool isAsync) HandleFreeInstallResult() argument
532 OnInstallFinished(int32_t recordId, int resultCode, const Want &want, int32_t userId, bool isAsync) OnInstallFinished() argument
[all...]
/foundation/ai/ai_engine/test/function/init/
H A Dinit_function_test.cpp119 .isAsync = true, in HWTEST_F()
167 .isAsync = true, in HWTEST_F()
215 .isAsync = true, in HWTEST_F()
261 .isAsync = true, in HWTEST_F()
282 * with 'clientId' being -1 and 'isAsync' being true.
306 .isAsync = true, in HWTEST_F()
327 * with 'clientId' being -1 and 'isAsync' being false.
351 .isAsync = false, in HWTEST_F()
/foundation/distributedhardware/device_manager/interfaces/kits/js4.0/src/
H A Ddm_native_util.cpp173 napi_value CreateErrorForCall(napi_env env, int32_t code, const std::string &errMsg, bool isAsync) in CreateErrorForCall() argument
177 if (isAsync) { in CreateErrorForCall()
185 napi_value CreateBusinessError(napi_env env, int32_t errCode, bool isAsync) in CreateBusinessError() argument
190 error = CreateErrorForCall(env, ERR_NO_PERMISSION, ERR_MESSAGE_NO_PERMISSION, isAsync); in CreateBusinessError()
193 error = CreateErrorForCall(env, DM_ERR_DISCOVERY_INVALID, ERR_MESSAGE_DISCOVERY_INVALID, isAsync); in CreateBusinessError()
196 error = CreateErrorForCall(env, DM_ERR_PUBLISH_INVALID, ERR_MESSAGE_PUBLISH_INVALID, isAsync); in CreateBusinessError()
200 ERR_MESSAGE_AUTHENTICALTION_INVALID, isAsync); in CreateBusinessError()
204 error = CreateErrorForCall(env, ERR_INVALID_PARAMS, ERR_MESSAGE_INVALID_PARAMS, isAsync); in CreateBusinessError()
207 error = CreateErrorForCall(env, DM_ERR_OBTAIN_SERVICE, ERR_MESSAGE_OBTAIN_SERVICE, isAsync); in CreateBusinessError()
210 error = CreateErrorForCall(env, ERR_NOT_SYSTEM_APP, ERR_MESSAGE_NOT_SYSTEM_APP, isAsync); in CreateBusinessError()
[all...]
/foundation/communication/dsoftbus/sdk/transmission/session/src/
H A Dclient_trans_session_callback.c61 session->isAsync = false; in AcceptSessionAsServer()
170 bool isAsync = true; in TransOnBindFailed() local
171 int32_t ret = ClientGetSessionIsAsyncBySessionId(sessionId, &isAsync); in TransOnBindFailed()
176 if (!isAsync) { in TransOnBindFailed()
280 bool isAsync = true; in HandleOnBindSuccess() local
281 int32_t ret = ClientGetSessionIsAsyncBySessionId(sessionId, &isAsync); in HandleOnBindSuccess()
297 } else if (isAsync) { in HandleOnBindSuccess()
389 bool isAsync = true; in TransOnSessionOpenFailed() local
390 int ret = ClientGetSessionIsAsyncBySessionId(sessionId, &isAsync); in TransOnSessionOpenFailed()
398 } else if (isAsync) { in TransOnSessionOpenFailed()
[all...]
/foundation/ai/ai_engine/test/function/destroy/
H A Ddestroy_function_test.cpp98 .isAsync = false, in HWTEST_F()
146 .isAsync = false, in HWTEST_F()
213 .isAsync = true, in HWTEST_F()
281 .isAsync = true, in HWTEST_F()
328 .isAsync = false, in HWTEST_F()
/foundation/communication/dsoftbus/sdk/transmission/session/include/
H A Dclient_trans_session_manager.h82 bool isAsync; member
150 bool isAsync; member
189 int32_t ClientGetSessionIsAsyncBySessionId(int32_t sessionId, bool *isAsync);
229 int32_t sessionId, const QosTV *qos, uint32_t qosCount, TransInfo *transInfo, bool isAsync);
251 int32_t SetSessionIsAsyncById(int32_t sessionId, bool isAsync);
/foundation/ai/ai_engine/test/function/prepare/
H A Dprepare_function_test.cpp100 .isAsync = false, in HWTEST_F()
157 .isAsync = true, in HWTEST_F()
219 .isAsync = false, in HWTEST_F()
280 .isAsync = true, in HWTEST_F()
317 * with 'isAsync = false' and 'callback != nullptr'.
342 .isAsync = false, in HWTEST_F()
379 * with 'isAsync = true' and 'callback = nullptr'.
404 .isAsync = true, in HWTEST_F()
440 * with 'isAsync = true' and 'callback != nullptr'.
465 .isAsync in HWTEST_F()
[all...]
/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/
H A Dtrans_lane_manager.c53 bool isAsync; member
246 int32_t TransLaneMgrDelLane(int32_t channelId, int32_t channelType, bool isAsync) in TransLaneMgrDelLane() argument
282 TransFreeLaneByLaneHandle(laneHandle, isAsync); in TransLaneMgrDelLane()
433 newSocket->isAsync = false; in TransAddSocketChannelInfo()
505 const char *sessionName, int32_t sessionId, uint32_t laneHandle, bool isQosLane, bool isAsync) in TransUpdateSocketChannelLaneInfoBySession()
523 socketItem->isAsync = isAsync; in TransUpdateSocketChannelLaneInfoBySession()
705 const char *sessionName, int32_t sessionId, uint32_t *laneHandle, bool *isQosLane, bool *isAsync) in TransGetSocketChannelLaneInfoBySession()
727 if (isAsync != NULL) { in TransGetSocketChannelLaneInfoBySession()
728 *isAsync in TransGetSocketChannelLaneInfoBySession()
504 TransUpdateSocketChannelLaneInfoBySession( const char *sessionName, int32_t sessionId, uint32_t laneHandle, bool isQosLane, bool isAsync) TransUpdateSocketChannelLaneInfoBySession() argument
704 TransGetSocketChannelLaneInfoBySession( const char *sessionName, int32_t sessionId, uint32_t *laneHandle, bool *isQosLane, bool *isAsync) TransGetSocketChannelLaneInfoBySession() argument
[all...]
/foundation/ai/ai_engine/services/common/protocol/struct_definition/
H A Daie_info_define.h41 bool isAsync; // indicate asynchronous member
/foundation/ability/ability_runtime/frameworks/native/ability/native/insight_intent_executor/
H A Dinsight_intent_executor_mgr.cpp72 bool isAsync = false; in ExecuteInsightIntent() local
75 std::move(callback), isAsync); in ExecuteInsightIntent()
/foundation/ai/ai_engine/test/function/async_process/
H A Dasync_process_function_test.cpp75 bool isAsync, int requestId) in PreBuildInfo()
95 .isAsync = isAsync, in PreBuildInfo()
200 * @tc.desc: Test asynchronous execution of certain algorithm plugin with 'isAsync' being false.
74 PreBuildInfo(ConfigInfo &configInfo, ClientInfo &clientInfo, AlgorithmInfo &algoInfo, bool isAsync, int requestId) PreBuildInfo() argument
/foundation/ai/intelligent_voice_framework/services/intell_voice_engine/server/sa/
H A Dintell_voice_service_manager.h72 void HandleSwitchOn(bool isAsync, int32_t uuid, bool needUpdateAdapter);
73 void HandleSwitchOff(bool isAsync, int32_t uuid);
75 void HandleUnloadIntellVoiceService(bool isAsync);
/foundation/ai/ai_engine/test/function/release/
H A Drelease_function_test.cpp98 .isAsync = false, in HWTEST_F()
160 .isAsync = true, in HWTEST_F()
222 .isAsync = false, in HWTEST_F()
288 .isAsync = true, in HWTEST_F()
/foundation/ai/ai_engine/services/client/client_executor/source/
H A Dclient_factory.cpp84 if (algorithmInfo.isAsync) { in ClientPrepare()
116 if (!algorithmInfo.isAsync) { in ClientAsyncProcess()
183 if (algorithmInfo.isAsync) { in ClientSyncProcess()
200 if (algorithmInfo.isAsync) { in ClientRelease()
/foundation/ai/ai_engine/test/function/set_get_option/
H A Doption_function_test.cpp105 .isAsync = false, in GetSyncAlgorithmInfo()
124 .isAsync = true, in GetAsyncAlgorithmInfo()
180 if (algoInfo.isAsync) { in HWTEST_F()
258 if (algoInfo.isAsync) { in HWTEST_F()
/foundation/ai/ai_engine/services/server/communication_adapter/source/
H A Dadapter_wrapper.cpp125 if (algoInfo->isAsync) { in SyncExecAlgoWrapper()
148 if (!algoInfo->isAsync) { in AsyncExecAlgoWrapper()
187 if (algoInfo->isAsync) { in LoadAlgoWrapper()
211 if (algoInfo->isAsync) { in UnloadAlgoWrapper()

Completed in 14 milliseconds

12345