Home
last modified time | relevance | path

Searched refs:sessionId (Results 1 – 25 of 56) sorted by relevance

123

/base/security/access_token/services/tokensyncmanager/test/mock/include/
Dsession.h155 int (*OnSessionOpened)(int sessionId, int result);
167 void (*OnSessionClosed)(int sessionId);
180 void (*OnBytesReceived)(int sessionId, const void *data, unsigned int dataLen);
193 void (*OnMessageReceived)(int sessionId, const void *data, unsigned int dataLen);
195 …void (*OnStreamReceived)(int sessionId, const StreamData *data, const StreamData *ext, const Frame…
199 int (*OnReceiveFileStarted)(int sessionId, const char *files, int fileCnt);
200 …int (*OnReceiveFileProcess)(int sessionId, const char *firstFile, uint64_t bytesUpload, uint64_t b…
201 void (*OnReceiveFileFinished)(int sessionId, const char *files, int fileCnt);
202 void (*OnFileTransError)(int sessionId);
206 int (*OnSendFileProcess)(int sessionId, uint64_t bytesUpload, uint64_t bytesTotal);
[all …]
/base/security/deviceauth/services/frameworks/src/session/
Dsession_manager.c38 int64_t sessionId; member
71 static int32_t GetSessionId(int64_t requestId, int64_t *sessionId) in GetSessionId() argument
77 *sessionId = requestInfo->sessionId; in GetSessionId()
84 static int32_t GetSessionIdByType(int64_t requestId, int32_t type, int64_t *sessionId) in GetSessionIdByType() argument
94 *sessionId = requestInfo->sessionId; in GetSessionIdByType()
136 int64_t sessionId = 0; in IsRequestExist() local
137 return (GetSessionId(requestId, &sessionId) == HC_SUCCESS) ? true : false; in IsRequestExist()
140 static void InformTimeOutAndDestroyRequest(const DeviceAuthCallback *callback, int64_t sessionId) in InformTimeOutAndDestroyRequest() argument
150 if ((requestInfo != NULL) && (requestInfo->sessionId == sessionId)) { in InformTimeOutAndDestroyRequest()
175 InformTimeOutAndDestroyRequest(ptr->callback, ptr->sessionId); in RemoveOverTimeSession()
[all …]
/base/security/access_token/services/tokensyncmanager/include/remote/
Dsoft_bus_session_listener.h43 static int32_t OnSessionOpened(int32_t sessionId, int32_t result);
55 static void OnSessionClosed(int32_t sessionId);
68 static void OnMessageReceived(int32_t sessionId, const void *data, uint32_t dataLen);
81 static void OnBytesReceived(int32_t sessionId, const void *data, uint32_t dataLen);
93 static int64_t GetSessionState(int32_t sessionId);
95 static void DeleteSessionIdFromMap(int32_t sessionId);
Dsoft_bus_manager.h82 int CloseSession(int sessionId);
/base/security/device_security_level/baselib/msglib/src/standard/
Dmessenger_device_session_manager.c32 static int MessengerOnSessionOpened(int sessionId, int result);
33 static void MessengerOnSessionClosed(int sessionId);
34 static void MessengerOnBytesReceived(int sessionId, const void *data, unsigned int dataLen);
35 static void MessengerOnMessageReceived(int sessionId, const void *data, unsigned int dataLen);
65 int32_t sessionId; member
150 static bool GetDeviceIdentityFromSessionId(int sessionId, DeviceIdentify *identity, uint32_t *maskI… in GetDeviceIdentityFromSessionId() argument
156 int ret = GetPeerDeviceId(sessionId, deviceName, DEVICE_ID_MAX_LEN + 1); in GetDeviceIdentityFromSessionId()
158 …LOG_INFO("GetDeviceIdentityFromSessionId %{public}d failed, result is %{public}d", sessionId, ret); in GetDeviceIdentityFromSessionId()
175 static int MessengerOnSessionOpened(int sessionId, int result) in MessengerOnSessionOpened() argument
177 int side = GetSessionSide(sessionId); in MessengerOnSessionOpened()
[all …]
/base/account/os_account/services/accountmgr/src/appaccount/
Dapp_account_authenticator_session_manager.cpp114 std::string sessionId = session->GetSessionId(); in OpenSession() local
126 sessionMap_.emplace(sessionId, session); in OpenSession()
130 it->second.emplace(sessionId); in OpenSession()
133 sessionSet.emplace(sessionId); in OpenSession()
148 auto it = sessionMap_.find(request.sessionId); in GetAuthenticatorCallback()
150 ACCOUNT_LOGE("failed to find a session by id=%{public}s.", request.sessionId.c_str()); in GetAuthenticatorCallback()
167 for (auto sessionId : it->second) { in OnAbilityStateChanged() local
168 auto sessionIt = sessionMap_.find(sessionId); in OnAbilityStateChanged()
170 ACCOUNT_LOGI("session{id=%{public}s} will be cleared", sessionId.c_str()); in OnAbilityStateChanged()
177 void AppAccountAuthenticatorSessionManager::CloseSession(const std::string &sessionId) in CloseSession() argument
[all …]
/base/security/access_token/services/tokensyncmanager/test/mock/src/
Dsoft_bus_session_mock.cpp91 void CloseSession(int sessionId) in CloseSession() argument
93 ACCESSTOKEN_LOG_DEBUG(LABEL, "sessionId: %{public}d", sessionId); in CloseSession()
101 int SendBytes(int sessionId, const void *data, unsigned int len) in SendBytes() argument
104 if (sessionId == Constant::INVALID_SESSION) { in SendBytes()
112 int GetPeerSessionName(int sessionId, char *sessionName, unsigned int len) in GetPeerSessionName() argument
114 if (sessionId == Constant::INVALID_SESSION) { in GetPeerSessionName()
118 if (sessionId < SERVER_COUNT_LIMIT) { in GetPeerSessionName()
121 x = "sessionid-" + std::to_string(sessionId); in GetPeerSessionName()
135 int GetPeerDeviceId(int sessionId, char *devId, unsigned int len) in GetPeerDeviceId() argument
137 if (sessionId == Constant::INVALID_SESSION) { in GetPeerDeviceId()
[all …]
/base/update/updater/services/flashd/daemon/
Ddaemon.cpp123 … Send(hSession->sessionId, channelId, CMD_KERNEL_ECHO_RAW, (uint8_t *)info.data(), info.size()); in RedirectToTask()
125 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in RedirectToTask()
135 Send(hSession->sessionId, channelId, CMD_KERNEL_ECHO_RAW, (uint8_t *)info.data(), info.size()); in RedirectToTask()
137 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in RedirectToTask()
152 …Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), bufString… in HandDaemonAuth()
170 … Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), in HandDaemonAuth()
203 uint32_t unOld = hSession->sessionId; in DaemonSessionHandshake()
204 hSession->sessionId = handshake.sessionId; in DaemonSessionHandshake()
208 (reinterpret_cast<HdcDaemonUSB *>(clsUSBServ))->OnNewHandshakeOK(hSession->sessionId); in DaemonSessionHandshake()
211 handshake.sessionId = 0; in DaemonSessionHandshake()
[all …]
/base/security/deviceauth/services/group_manager/src/channel_manager/soft_bus_channel/
Dsoft_bus_channel.c150 static bool IsServer(int sessionId) in IsServer() argument
152 return GetSessionSide(sessionId) == 0; in IsServer()
155 static int OnChannelOpenedCb(int sessionId, int result) in OnChannelOpenedCb() argument
157 if (IsServer(sessionId)) { in OnChannelOpenedCb()
162 if (GetReqIdByChannelId(sessionId, &requestId) != HC_SUCCESS) { in OnChannelOpenedCb()
171 LOGD("[Start]: OnChannelOpened! [ReqId]: %" PRId64 ", [ChannelId]: %d", requestId, sessionId); in OnChannelOpenedCb()
178 InitSoftBusTask(task, requestId, sessionId); in OnChannelOpenedCb()
188 static void OnChannelClosedCb(int sessionId) in OnChannelClosedCb() argument
190 LOGI("[SoftBus][Out]: OnChannelClosed! sessionId: %d", sessionId); in OnChannelClosedCb()
191 if (IsServer(sessionId)) { in OnChannelClosedCb()
[all …]
/base/security/access_token/services/tokensyncmanager/src/remote/
Dsoft_bus_session_listener.cpp83 void SoftBusSessionListener::OnMessageReceived(int32_t sessionId, const void *data, uint32_t dataLe… in OnMessageReceived() argument
89 void SoftBusSessionListener::OnBytesReceived(int32_t sessionId, const void *data, uint32_t dataLen) in OnBytesReceived() argument
91 if ((sessionId == Constant::INVALID_SESSION) || (dataLen == 0) || in OnBytesReceived()
99 int32_t resultCode = ::GetPeerDeviceId(sessionId, contents, len); in OnBytesReceived()
111 channel->HandleDataReceived(sessionId, (unsigned char *) data, dataLen); in OnBytesReceived()
114 int64_t SoftBusSessionListener::GetSessionState(int32_t sessionId) in GetSessionState() argument
118 auto iter = g_SessionOpenedMap_.find(sessionId); in GetSessionState()
Dsoft_bus_manager.cpp171 int sessionId = ::OpenSession(SESSION_NAME.c_str(), SESSION_NAME.c_str(), networkId.c_str(), in OpenSession() local
181 if (SoftBusSessionListener::GetSessionState(sessionId) < 0) { in OpenSession()
194 int64_t state = SoftBusSessionListener::GetSessionState(sessionId); in OpenSession()
200 SoftBusSessionListener::DeleteSessionIdFromMap(sessionId); in OpenSession()
203 return sessionId; in OpenSession()
206 int SoftBusManager::CloseSession(int sessionId) in CloseSession() argument
208 if (sessionId < 0) { in CloseSession()
213 ::CloseSession(sessionId); in CloseSession()
/base/user_iam/user_idm/services/src/
Duseridm_setprop_handler.cpp22 …opHandler::UserIDMSetPropHandler(AuthType type, const uint64_t challenge, const uint64_t sessionId, in UserIDMSetPropHandler() argument
29 lastScheduleId_ = sessionId; in UserIDMSetPropHandler()
Duseridm_controller.cpp39 uint64_t sessionId = 0; in OpenEditSessionCtrl() local
41 bool res = data_->CheckScheduleIdIsActive(sessionId); in OpenEditSessionCtrl()
43 CoAuth::CoAuth::GetInstance().Cancel(sessionId); in OpenEditSessionCtrl()
55 uint64_t sessionId = 0; in CloseEditSessionCtrl() local
57 bool res = data_->CheckScheduleIdIsActive(sessionId); in CloseEditSessionCtrl()
59 CoAuth::CoAuth::GetInstance().Cancel(sessionId); in CloseEditSessionCtrl()
227 uint64_t sessionId = 0; in DelSchedleIdCtrl() local
234 if (!data_->CheckScheduleIdIsActive(sessionId)) { in DelSchedleIdCtrl()
238 result = CoAuth::CoAuth::GetInstance().Cancel(sessionId); in DelSchedleIdCtrl()
/base/security/huks/services/huks_standard/huks_engine/main/core/src/
Dhks_core_service.c963 uint64_t sessionId; in HksCoreUpdate() local
964 if (memcpy_s(&sessionId, sizeof(sessionId), handle->data, handle->size) != EOK) { in HksCoreUpdate()
969 struct HuksKeyNode *keyNode = HksQueryKeyNode(sessionId); in HksCoreUpdate()
977 HksDeleteKeyNode(sessionId); in HksCoreUpdate()
991 HksDeleteKeyNode(sessionId); in HksCoreUpdate()
1011 uint64_t sessionId; in HksCoreFinish() local
1012 if (memcpy_s(&sessionId, sizeof(sessionId), handle->data, handle->size)) { in HksCoreFinish()
1017 struct HuksKeyNode *keyNode = HksQueryKeyNode(sessionId); in HksCoreFinish()
1025 HksDeleteKeyNode(sessionId); in HksCoreFinish()
1041 HksDeleteKeyNode(sessionId); in HksCoreFinish()
[all …]
/base/update/updater/services/flashd/host/
Dserver.cpp379 …Send(hSession->sessionId, 0, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), bufString.size()); in HandServerAuth()
392 …Send(hSession->sessionId, 0, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), bufString.size()); in HandServerAuth()
458 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in FetchCommand()
481 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in FetchCommand()
490 pdiNew->sessionId = hSession->sessionId; in FetchCommand()
580 hdcServer->FreeSession(hSession->sessionId); in UsbPreConnect()
665 hChannel->targetSessionId = hSession->sessionId; in AttachChannel()
688 Send(hSession->sessionId, hChannel->channelId, CMD_KERNEL_CHANNEL_CLOSE, &count, 1); in DeatchChannel()
704 bool HdcServer::ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t co… in ServerCommand() argument
709 HSession hSession = AdminSession(OP_QUERY, sessionId, nullptr); in ServerCommand()
Dserver_for_client.cpp145 …if (ptrServer->Send(hdi->hSession->sessionId, hChannel->channelId, commandFlag, bufPtr, bufSize) <… in SendToDaemon()
254 ((HdcServer *)ptrServer)->FreeSession(hdiOld->hSession->sessionId); in CommandRemoveSession()
266 HSession hSession = ptrServer->AdminSession(OP_QUERY, hfi->sessionId, nullptr); in CommandRemoveForward()
655 HSession HdcServerForClient::FindAliveSession(uint32_t sessionId) in FindAliveSession() argument
658 HSession hSession = ptrServer->AdminSession(OP_QUERY, sessionId, nullptr); in FindAliveSession()
666 bool HdcServerForClient::ChannelSendSessionCtrlMsg(vector<uint8_t> &ctrlMsg, uint32_t sessionId) in ChannelSendSessionCtrlMsg() argument
668 HSession hSession = FindAliveSession(sessionId); in ChannelSendSessionCtrlMsg()
/base/user_iam/user_auth/services/src/
Duserauth_controller.cpp54 int32_t UserAuthController::Cancel(uint64_t sessionId) in Cancel() argument
56 return UserAuthAdapter::GetInstance().Cancel(sessionId); in Cancel()
/base/security/deviceauth/services/frameworks/inc/session/
Dbase_session.h29 int64_t sessionId; member
/base/user_iam/user_idm/services/include/
Duseridm_setprop_handler.h28 …UserIDMSetPropHandler(AuthType type, const uint64_t challenge, const uint64_t sessionId, uint64_t…
Duseridm_coauth_handler.h31 … explicit UserIDMCoAuthHandler(CoAuthType type, const uint64_t challenge, const uint64_t sessionId,
/base/user_iam/pin_auth/services/include/
Dpinauth_service.h115 … int32_t OnEndExecute(uint64_t sessionId, std::shared_ptr<AuthAttributes> consumerAttr) override in OnEndExecute() argument
117 return service_->OnEndExecute(sessionId, consumerAttr); in OnEndExecute()
/base/user_iam/user_auth/services/include/
Duserauth_controller.h41 int32_t Cancel(uint64_t sessionId);
/base/account/os_account/services/accountmgr/include/appaccount/
Dapp_account_common.h38 std::string sessionId; member
Dapp_account_authenticator_session_manager.h54 void CloseSession(const std::string &sessionId);
/base/update/updateservice/client/
Dupdate_session.h59 return sessionId; in GetSessionId()
96 uint32_t sessionId {0};

123