Home
last modified time | relevance | path

Searched refs:connection (Results 1 - 25 of 34) sorted by relevance

12

/base/customization/enterprise_device_management/services/edm/src/connection/
H A Denterprise_conn_manager.cpp36 sptr<IEnterpriseConnection> connection(new (std::nothrow) EnterpriseAdminConnection(want, code, userId, in CreateAdminConnection()
38 return connection; in CreateAdminConnection()
44 sptr<IEnterpriseConnection> connection(new (std::nothrow) EnterpriseBundleConnection(want, in CreateBundleConnection()
46 return connection; in CreateBundleConnection()
52 sptr<IEnterpriseConnection> connection(new (std::nothrow)EnterpriseUpdateConnection(want, in CreateUpdateConnection()
54 return connection; in CreateUpdateConnection()
57 bool EnterpriseConnManager::ConnectAbility(const sptr<IEnterpriseConnection>& connection) in ConnectAbility() argument
59 if (connection == nullptr) { in ConnectAbility()
62 int32_t ret = ExtensionManagerClient::GetInstance().ConnectEnterpriseAdminExtensionAbility(connection->GetWant(), in ConnectAbility()
63 connection, nullpt in ConnectAbility()
[all...]
H A Denterprise_admin_connection.cpp61 sptr<IEnterpriseConnection> connection = manager->CreateAdminConnection(want_, in OnAbilityDisconnectDone() local
63 manager->ConnectAbility(connection); in OnAbilityDisconnectDone()
/base/notification/common_event_service/services/src/
H A Dability_manager_helper.cpp44 sptr<StaticSubscriberConnection> connection = new (std::nothrow) StaticSubscriberConnection(event); in ConnectAbility() local
45 if (connection == nullptr) { in ConnectAbility()
49 int32_t result = abilityMgr_->ConnectAbility(want, connection, callerToken, userId); in ConnectAbility()
51 subscriberConnection_.emplace(connection); in ConnectAbility()
103 void AbilityManagerHelper::DisconnectServiceAbilityDelay(const sptr<StaticSubscriberConnection> &connection) in DisconnectServiceAbilityDelay() argument
106 if (connection == nullptr) { in DisconnectServiceAbilityDelay()
107 EVENT_LOGE("connection is nullptr"); in DisconnectServiceAbilityDelay()
116 std::function<void()> task = [connection]() { in DisconnectServiceAbilityDelay()
117 AbilityManagerHelper::GetInstance()->DisconnectAbility(connection); in DisconnectServiceAbilityDelay()
122 void AbilityManagerHelper::DisconnectAbility(const sptr<StaticSubscriberConnection> &connection) in DisconnectAbility() argument
[all...]
/base/useriam/user_auth_framework/test/unittest/services/src/
H A Dui_extension_ability_connection_test.cpp62 auto connection = new UIExtensionAbilityConnection("connection"); in HWTEST_F() local
65 connection->OnAbilityDisconnectDone(element, resultCode); in HWTEST_F()
66 EXPECT_NE(connection, nullptr); in HWTEST_F()
81 auto connection = new UIExtensionAbilityConnection("connection"); in HWTEST_F() local
84 connection->OnAbilityConnectDone(element, obj, resultCode); in HWTEST_F()
85 EXPECT_NE(connection, nullptr); in HWTEST_F()
/base/startup/appspawn/standard/
H A Dappspawn_service.c66 static void ProcessRecvMsg(AppSpawnConnection *connection, AppSpawnMsgNode *message);
214 if (ctx == NULL || ctx->message == NULL || ctx->message->connection != data) { in AppSpawningCtxOnClose()
229 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); in OnClose() local
230 APPSPAWN_CHECK(connection != NULL, return, "Invalid connection"); in OnClose()
231 if (connection->receiverCtx.timer) { in OnClose()
232 LE_StopTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer); in OnClose()
233 connection->receiverCtx.timer = NULL; in OnClose()
236 connection->connectionId, LE_GetSocketFd(taskHandle)); in OnClose()
237 DeleteAppSpawnMsg(connection in OnClose()
245 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); OnDisConnect() local
254 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); SendMessageComplete() local
272 SendResponse(const AppSpawnConnection *connection, const AppSpawnMsg *msg, int result, pid_t pid) SendResponse() argument
289 AppSpawnConnection *connection = (AppSpawnConnection *)context; WaitMsgCompleteTimeOut() local
296 StartTimerForCheckMsg(AppSpawnConnection *connection) StartTimerForCheckMsg() argument
323 AppSpawnConnection *connection = (AppSpawnConnection *) LE_GetUserData(taskHandle); HandleRecvMessage() local
383 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(stream); OnConnection() local
430 AppSpawnConnection *connection = (AppSpawnConnection *)LE_GetUserData(taskHandle); OnReceiveRequest() local
884 ProcessSpawnReqMsg(AppSpawnConnection *connection, AppSpawnMsgNode *message) ProcessSpawnReqMsg() argument
1348 ProcessSpawnBegetctlMsg(AppSpawnConnection *connection, AppSpawnMsgNode *message) ProcessSpawnBegetctlMsg() argument
1365 ProcessBegetCmdMsg(AppSpawnConnection *connection, AppSpawnMsgNode *message) ProcessBegetCmdMsg() argument
1409 ProcessSpawnRemountMsg(AppSpawnConnection *connection, AppSpawnMsgNode *message) ProcessSpawnRemountMsg() argument
1453 ProcessSpawnRemountMsg(AppSpawnConnection *connection, AppSpawnMsgNode *message) ProcessSpawnRemountMsg() argument
1509 ProcessSpawnRestartMsg(AppSpawnConnection *connection, AppSpawnMsgNode *message) ProcessSpawnRestartMsg() argument
1620 ProcessRecvMsg(AppSpawnConnection *connection, AppSpawnMsgNode *message) ProcessRecvMsg() argument
[all...]
/base/telephony/cellular_call/services/control/src/
H A Dims_control.cpp76 for (auto &connection : connectionMap_) { in DialJudgment()
77 if (connection.second.GetStatus() == TelCallState::CALL_STATUS_ACTIVE && in DialJudgment()
78 !connection.second.IsPendingHangup()) { in DialJudgment()
79 TELEPHONY_LOGI("DialJudgment, have connection in active state."); in DialJudgment()
83 connection.second.SetHoldToDialInfo(phoneNum, clirMode, videoState, isEmergency); in DialJudgment()
84 connection.second.SetDialFlag(true); in DialJudgment()
85 // - a call can be temporarily disconnected from the ME but the connection is retained by the network in DialJudgment()
86 return connection.second.SwitchCallRequest(slotId); in DialJudgment()
136 TELEPHONY_LOGE("HangUp return, error type: connection is null"); in HangUp()
149 CellularCallConnectionIMS connection; in HangUp() local
154 CellularCallConnectionIMS connection; HangUp() local
272 CellularCallConnectionIMS connection; CombineConference() local
280 CellularCallConnectionIMS connection; HangUpAllConnection() local
299 CellularCallConnectionIMS connection; InviteToConference() local
317 CellularCallConnectionIMS connection; KickOutFromConference() local
324 CellularCallConnectionIMS connection; StartRtt() local
331 CellularCallConnectionIMS connection; StopRtt() local
406 CellularCallConnectionIMS connection; ReportIncomingInfo() local
442 CellularCallConnectionIMS connection; ReportUpdateInfo() local
[all...]
H A Dcs_control.cpp84 TELEPHONY_LOGI("DialCdma, CDMA is have connection in active state."); in DialCdma()
117 TELEPHONY_LOGI("DialGsm, GSM is have connection in active state."); in DialGsm()
122 // - a call can be temporarily disconnected from the ME but the connection is retained by the network in DialGsm()
168 // Match the session connection according to the phone number string in HangUp()
173 TELEPHONY_LOGE("CSControl::HangUp, error type: connection is null"); in HangUp()
197 CellularCallConnectionCS connection; in HangUp() local
198 return connection.CallSupplementRequest(callInfo.slotId, type); in HangUp()
202 CellularCallConnectionCS connection; in HangUp() local
205 return connection.RejectRequest(callInfo.slotId); in HangUp()
223 TELEPHONY_LOGE("Answer return, error type: connection i in Answer()
336 CellularCallConnectionCS connection; HoldCall() local
349 CellularCallConnectionCS connection; UnHoldCall() local
368 CellularCallConnectionCS connection; SwitchCall() local
392 CellularCallConnectionCS connection; SeparateConference() local
410 CellularCallConnectionCS connection; HangUpAllConnection() local
459 CellularCallConnectionCS connection; ReportUpdateInfo() local
562 CellularCallConnectionCS connection; ReportIncomingInfo() local
[all...]
H A Dsatellite_control.cpp96 // Match the session connection according to the phone number string in HangUp()
101 TELEPHONY_LOGE("HangUp, error type: connection is null"); in HangUp()
129 TELEPHONY_LOGE("Answer return, error type: connection is null"); in Answer()
131 CALL_ERR_CALL_CONNECTION_NOT_EXIST, "get connection data is null"); in Answer()
167 TELEPHONY_LOGE("SatelliteControl::Reject, error type: connection is null"); in Reject()
208 CellularCallConnectionSatellite connection; in ReportUpdateInfo() local
209 connection.SetOrUpdateCallReportInfo(reportInfo); in ReportUpdateInfo()
210 connection.SetFlag(true); in ReportUpdateInfo()
211 connection.SetIndex(callInfoList.calls[i].index); in ReportUpdateInfo()
212 connection in ReportUpdateInfo()
285 CellularCallConnectionSatellite connection; ReportIncomingInfo() local
409 CellularCallConnectionSatellite connection; HangUpAllConnection() local
[all...]
/base/customization/enterprise_device_management/test/unittest/services/edm/src/
H A Denterprise_conn_manager_test.cpp65 sptr<IEnterpriseConnection> connection = manager->CreateAdminConnection(connectWant, in HWTEST_F() local
67 bool ret = manager->ConnectAbility(connection); in HWTEST_F()
83 sptr<IEnterpriseConnection> connection = manager->CreateBundleConnection(connectWant, in HWTEST_F() local
85 bool ret = manager->ConnectAbility(connection); in HWTEST_F()
105 sptr<IEnterpriseConnection> connection = manager->CreateUpdateConnection(connectWant, in HWTEST_F() local
107 bool ret = manager->ConnectAbility(connection); in HWTEST_F()
/base/print/print_fwk/frameworks/kits/extension/src/
H A Djs_print_extension_connection.cpp47 wptr<JSPrintExtensionConnection> connection = this; in OnAbilityConnectDone() local
48 auto task = [connection, element, remoteObject, resultCode]() { in OnAbilityConnectDone()
49 sptr<JSPrintExtensionConnection> connectionSptr = connection.promote(); in OnAbilityConnectDone()
98 wptr<JSPrintExtensionConnection> connection = this; in OnAbilityDisconnectDone() local
99 auto task = [connection, element, resultCode]() { in OnAbilityDisconnectDone()
100 sptr<JSPrintExtensionConnection> connectionSptr = connection.promote(); in OnAbilityDisconnectDone()
H A Djs_print_extension_context.cpp271 sptr<JSPrintExtensionConnection> connection = new JSPrintExtensionConnection(engine); in OnConnectAbility() local
272 connection->SetJsConnectionObject(argv[1]); in OnConnectAbility()
278 connects_.emplace(key, connection); in OnConnectAbility()
280 NapiAsyncTask::CompleteCallback complete = [weak = context_, want, connection, connectId]( in OnConnectAbility()
289 PRINT_HILOGD("context->ConnectAbility connection:%{public}d", (int32_t)connectId); in OnConnectAbility()
290 if (!context->ConnectAbility(want, connection)) { in OnConnectAbility()
291 connection->CallJsFailed(E_PRINT_INVALID_CONTEXT); in OnConnectAbility()
326 sptr<JSPrintExtensionConnection> connection = new JSPrintExtensionConnection(engine); in OnConnectAbilityWithAccount() local
327 connection->SetJsConnectionObject(argv[1]); in OnConnectAbilityWithAccount()
333 connects_.emplace(key, connection); in OnConnectAbilityWithAccount()
372 sptr<JSPrintExtensionConnection> connection = nullptr; OnDisconnectAbility() local
[all...]
/base/theme/wallpaper_mgr/frameworks/kits/extension/src/
H A Djs_wallpaper_extension_context.cpp256 // unwarp connection in OnConnectAbility()
257 sptr<JSWallpaperExtensionConnection> connection = new JSWallpaperExtensionConnection(env); in OnConnectAbility() local
258 int64_t connectId = GetConnectId(argv, want, connection); in OnConnectAbility()
259 NapiAsyncTask::CompleteCallback complete = [weak = context_, want, connection, connectId]( in OnConnectAbility()
268 HILOG_INFO("context->ConnectAbility connection:%{public}d", (int32_t)connectId); in OnConnectAbility()
269 if (!context->ConnectAbility(want, connection)) { in OnConnectAbility()
270 connection->CallJsFailed(ERROR_CODE_ONE); in OnConnectAbility()
298 sptr<JSWallpaperExtensionConnection> connection = new JSWallpaperExtensionConnection(env); in OnConnectAbilityWithAccount() local
299 int64_t connectId = GetConnectId(argv, want, connection); in OnConnectAbilityWithAccount()
300 NapiAsyncTask::CompleteCallback complete = [weak = context_, want, accountId, connection, connectI in OnConnectAbilityWithAccount()
323 GetConnectId( const napi_value *argv, const AAFwk::Want &want, const sptr<JSWallpaperExtensionConnection> &connection) GetConnectId() argument
354 sptr<JSWallpaperExtensionConnection> connection = nullptr; OnDisconnectAbility() local
514 wptr<JSWallpaperExtensionConnection> connection = this; OnAbilityConnectDone() local
564 wptr<JSWallpaperExtensionConnection> connection = this; OnAbilityDisconnectDone() local
[all...]
/base/inputmethod/imf/frameworks/kits/extension/src/
H A Djs_inputmethod_extension_context.cpp248 sptr<JSInputMethodExtensionConnection> connection = new JSInputMethodExtensionConnection(env); in OnConnectAbility() local
249 connection->SetJsConnectionObject(argv[1]); in OnConnectAbility()
256 connects_.emplace(key, connection); in OnConnectAbility()
263 NapiAsyncTask::CompleteCallback complete = [weak = context_, want, connection, connectId](napi_env env, in OnConnectAbility()
272 IMSA_HILOGI("context->ConnectAbility connection: %{public}d.", (int32_t)connectId); in OnConnectAbility()
273 if (!context->ConnectAbility(want, connection)) { in OnConnectAbility()
274 connection->CallJsFailed(ERROR_CODE_ONE); in OnConnectAbility()
301 sptr<JSInputMethodExtensionConnection> connection = new JSInputMethodExtensionConnection(env); in OnConnectAbilityWithAccount() local
302 connection->SetJsConnectionObject(argv[1]); in OnConnectAbilityWithAccount()
309 connects_.emplace(key, connection); in OnConnectAbilityWithAccount()
348 sptr<JSInputMethodExtensionConnection> connection = nullptr; OnDisconnectAbility() local
490 wptr<JSInputMethodExtensionConnection> connection = this; OnAbilityConnectDone() local
547 wptr<JSInputMethodExtensionConnection> connection = this; OnAbilityDisconnectDone() local
[all...]
/base/startup/appspawn/test/unittest/
H A Dapp_spawn_test_helper.cpp264 AppSpawnConnection *connection = (AppSpawnConnection *) LE_GetUserData(taskHandle); in HandleRecvMessage() local
274 return -1, "failed to recv fd %d %d", connection->receiverCtx.fdCount, fdCount); in HandleRecvMessage()
275 APPSPAWN_CHECK(memcpy_s(connection->receiverCtx.fds, fdCount * sizeof(int), fd, in HandleRecvMessage()
277 connection->receiverCtx.fdCount = fdCount; in HandleRecvMessage()
302 TestConnection *connection = (TestConnection *)LE_GetUserData(stream); in OnConnection() local
303 APPSPAWN_CHECK(connection != nullptr, return -1, "Failed to alloc stream"); in OnConnection()
304 connection->connectionId = ++connectionId; in OnConnection()
305 connection->stream = stream; in OnConnection()
306 connection->msgRecvLen = 0; in OnConnection()
307 (void)memset_s(&connection in OnConnection()
322 TestConnection *connection = (TestConnection *)LE_GetUserData(taskHandle); OnClose() local
341 TestConnection *connection = (TestConnection *)LE_GetUserData(taskHandle); OnReceiveRequest() local
[all...]
/base/notification/common_event_service/services/include/
H A Dability_manager_helper.h65 * @param connection Indicates the connection want to disconnect.
67 void DisconnectServiceAbilityDelay(const sptr<StaticSubscriberConnection> &connection);
70 void DisconnectAbility(const sptr<StaticSubscriberConnection> &connection);
/base/notification/common_event_service/services/test/unittest/
H A Dability_manager_helper_test.cpp619 sptr<StaticSubscriberConnection> connection = new (std::nothrow) StaticSubscriberConnection(data); in HWTEST_F() local
620 abilityManagerHelper->subscriberConnection_.emplace(connection); in HWTEST_F()
630 * @tc.desc : Test the DisconnectAbility function when the connection is nullptr.
637 sptr<StaticSubscriberConnection> connection = new (std::nothrow) StaticSubscriberConnection(data); in HWTEST_F() local
638 abilityManagerHelper->subscriberConnection_.emplace(connection); in HWTEST_F()
647 * @tc.desc : Test the DisconnectAbility function when the connection is not nullptr.
654 sptr<StaticSubscriberConnection> connection = new (std::nothrow) StaticSubscriberConnection(data); in HWTEST_F() local
655 abilityManagerHelper->subscriberConnection_.emplace(connection); in HWTEST_F()
656 abilityManagerHelper->DisconnectAbility(connection); in HWTEST_F()
664 * @tc.desc : Test the DisconnectServiceAbilityDelay function when the connection i
673 sptr<StaticSubscriberConnection> connection = new (std::nothrow) StaticSubscriberConnection(data); HWTEST_F() local
690 sptr<StaticSubscriberConnection> connection = new (std::nothrow) StaticSubscriberConnection(data); HWTEST_F() local
[all...]
/base/notification/common_event_service/services/test/unittest/mock/
H A Dmock_ability_manager_helper.cpp57 void AbilityManagerHelper::DisconnectServiceAbilityDelay(const sptr<StaticSubscriberConnection> &connection) in DisconnectServiceAbilityDelay() argument
/base/customization/enterprise_device_management/services/edm/include/connection/
H A Denterprise_conn_manager.h40 bool ConnectAbility(const sptr<IEnterpriseConnection>& connection);
/base/startup/appspawn/modules/native_adapter/
H A Dnative_adapter.cpp42 APPSPAWN_CHECK_ONLY_EXPER(message->connection != NULL, return -1); in BuildFdInfoMap()
43 recvCtx = message->connection->receiverCtx; in BuildFdInfoMap()
/base/startup/appspawn/modules/common/
H A Dappspawn_common.c480 && property->message->connection != NULL, in CloseFdArgs()
481 return -1, "Get connection info failed"); in CloseFdArgs()
482 int fdCount = property->message->connection->receiverCtx.fdCount; in CloseFdArgs()
483 int *fds = property->message->connection->receiverCtx.fds; in CloseFdArgs()
491 property->message->connection->receiverCtx.fdCount = 0; in CloseFdArgs()
500 APPSPAWN_CHECK_ONLY_EXPER(message != NULL && message->buffer != NULL && message->connection != NULL, return -1); in SetFdEnv()
503 AppSpawnMsgReceiverCtx recvCtx = message->connection->receiverCtx; in SetFdEnv()
/base/location/services/location_locator/locator/source/
H A Dlocation_config_manager.cpp322 sptr<UIExtensionAbilityConnection> connection( in ConnectExtensionAbility()
324 if (connection == nullptr) { in ConnectExtensionAbility()
331 AAFwk::ExtensionManagerClient::GetInstance().ConnectServiceExtensionAbility(want, connection, nullptr, -1); in ConnectExtensionAbility()
/base/telephony/call_manager/utils/src/
H A Dcall_dialog.cpp61 sptr<CallAbilityConnection> connection = in DialogConnectExtensionAbility() local
63 if (connection == nullptr) { in DialogConnectExtensionAbility()
64 TELEPHONY_LOGE("connection is nullptr"); in DialogConnectExtensionAbility()
69 connection, nullptr, DEFAULT_USER_ID); in DialogConnectExtensionAbility()
85 TELEPHONY_LOGE("connection is nullptr"); in CallSettingDialogConnectExtensionAbility()
/base/startup/appspawn/test/unittest/app_spawn_standard_test/
H A Dapp_spawn_common_test.cpp661 AppSpawnConnection *connection = (AppSpawnConnection *)malloc(sizeof(AppSpawnConnection)); in HWTEST_F() local
662 ASSERT_EQ(connection != nullptr, 1); in HWTEST_F()
667 property.message->connection = nullptr; in HWTEST_F()
669 EXPECT_EQ(ret, -1); // message != null, message->buffer == null, message->connection == null in HWTEST_F()
672 property.message->connection = connection; in HWTEST_F()
673 ret = SetFdEnv(nullptr, &property); // message != null, message->connection != null, message->buffer == null in HWTEST_F()
677 property.message->connection = nullptr; in HWTEST_F()
678 ret = SetFdEnv(nullptr, &property); // message != null, message->connection == null, message->buffer != null in HWTEST_F()
682 free(connection); in HWTEST_F()
[all...]
/base/telephony/cellular_call/services/control/include/
H A Dcontrol_base.h269 * Determines if a connection is currently in this state
315 TELEPHONY_LOGE("StartDtmf, error type: connection is null"); in StartDtmf()
351 TELEPHONY_LOGE("StopDtmf, error type: connection is null"); in StopDtmf()
395 TELEPHONY_LOGE("SendDtmf, error type: connection is null"); in SendDtmf()
415 decltype(t.begin()->second) connection; in GetCallFailReason()
416 return connection.GetCallFailReasonRequest(slotId); in GetCallFailReason()
/base/startup/init/test/systest/
H A Dloopserver_systest.c177 if (connection->receiverCtx.timer != NULL) { in StartTimerForCheckMsg()
180 int ret = LE_CreateTimer(LE_GetDefaultLoop(), &connection->receiverCtx.timer, WaitMsgCompleteTimeOut, connection); in StartTimerForCheckMsg()
182 ret = LE_StartTimer(LE_GetDefaultLoop(), connection->receiverCtx.timer, MAX_WAIT_MSG_COMPLETE, 1); in StartTimerForCheckMsg()
604 MsgNode *msgNode = ProcessBegetctlMsg(connection, message); in ProcessBegetMsg()

Completed in 20 milliseconds

12