Home
last modified time | relevance | path

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

1234

/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/access_token/services/tokensyncmanager/src/remote/
Dsoft_bus_session_listener.cpp37 int32_t SoftBusSessionListener::OnSessionOpened(int32_t sessionId, int32_t result) in OnSessionOpened() argument
46 int32_t resultCode = ::GetPeerSessionName(sessionId, contents, len); in OnSessionOpened()
57 ACCESSTOKEN_LOG_INFO(LABEL, "OnSessionOpened, id = %{public}d", sessionId); in OnSessionOpened()
61 auto iter = g_SessionOpenedMap_.find(sessionId); in OnSessionOpened()
63 g_SessionOpenedMap_.insert(std::pair<int32_t, int64_t>(sessionId, (int64_t) 1)); in OnSessionOpened()
71 void SoftBusSessionListener::OnSessionClosed(int32_t sessionId) in OnSessionClosed() argument
77 auto iter = g_SessionOpenedMap_.find(sessionId); in OnSessionClosed()
83 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()
[all …]
/base/security/device_auth/services/session_manager/src/
Ddev_session_mgr.c38 static int32_t GetSessionInfo(int64_t sessionId, SessionInfo **returnObj) in GetSessionInfo() argument
44 if (session->id == sessionId) { in GetSessionInfo()
71 static int32_t CheckEnvForOpenSession(int64_t sessionId) in CheckEnvForOpenSession() argument
74 int32_t res = GetSessionInfo(sessionId, &sessionInfo); in CheckEnvForOpenSession()
76 LOGE("session has existed. [Id]: %" PRId64, sessionId); in CheckEnvForOpenSession()
124 bool IsSessionExist(int64_t sessionId) in IsSessionExist() argument
128 int32_t res = GetSessionInfo(sessionId, &sessionInfo); in IsSessionExist()
133 int32_t OpenDevSession(int64_t sessionId, const char *appId, SessionInitParams *params) in OpenDevSession() argument
141 int32_t res = CheckEnvForOpenSession(sessionId); in OpenDevSession()
147 res = CreateDevSession(sessionId, appId, params, &session); in OpenDevSession()
[all …]
/base/security/device_auth/services/session_manager/inc/
Ddev_session_mgr.h30 int32_t OpenDevSession(int64_t sessionId, const char *appId, SessionInitParams *params);
31 int32_t StartDevSession(int64_t sessionId);
32 int32_t ProcessDevSession(int64_t sessionId, const CJson *receviedMsg, bool *isFinish);
33 void CloseDevSession(int64_t sessionId);
34 bool IsSessionExist(int64_t sessionId);
35 void CancelDevSession(int64_t sessionId, const char *appId);
/base/msdp/device_status/services/interaction/coordination/src/
Dcoordination_softbus_adapter.cpp50 void ResponseStartRemoteCoordination(int32_t sessionId, const JsonParser &parser) in ResponseStartRemoteCoordination() argument
62 void ResponseStartRemoteCoordinationResult(int32_t sessionId, const JsonParser &parser) in ResponseStartRemoteCoordinationResult() argument
76 void ResponseStopRemoteCoordination(int32_t sessionId, const JsonParser &parser) in ResponseStopRemoteCoordination() argument
88 void ResponseStopRemoteCoordinationResult(int32_t sessionId, const JsonParser &parser) in ResponseStopRemoteCoordinationResult() argument
100 void ResponseNotifyUnchainedResult(int32_t sessionId, const JsonParser &parser) in ResponseNotifyUnchainedResult() argument
112 void ResponseStartCoordinationOtherResult(int32_t sessionId, const JsonParser &parser) in ResponseStartCoordinationOtherResult() argument
125 static int32_t SessionOpened(int32_t sessionId, int32_t result) in SessionOpened() argument
127 return COOR_SOFTBUS_ADAPTER->OnSessionOpened(sessionId, result); in SessionOpened()
130 static void SessionClosed(int32_t sessionId) in SessionClosed() argument
132 COOR_SOFTBUS_ADAPTER->OnSessionClosed(sessionId); in SessionClosed()
[all …]
/base/account/os_account/services/accountmgr/src/appaccount/
Dapp_account_authenticator_session_manager.cpp148 std::string sessionId = session->GetSessionId(); in OpenSession() local
164 sessionMap_.emplace(sessionId, session); in OpenSession()
170 it->second.emplace(sessionId); in OpenSession()
173 sessionSet.emplace(sessionId); in OpenSession()
182 const std::string &sessionId) in GetSession() argument
185 auto it = sessionMap_.find(sessionId); in GetSession()
197 auto it = sessionMap_.find(request.sessionId); in GetAuthenticatorCallback()
199 ACCOUNT_LOGE("failed to find a session by id=%{private}s.", request.sessionId.c_str()); in GetAuthenticatorCallback()
216 for (auto sessionId : it->second) { in OnAbilityStateChanged() local
217 auto sessionIt = sessionMap_.find(sessionId); in OnAbilityStateChanged()
[all …]
Dapp_account_authenticator_callback.cpp23 AppAccountAuthenticatorCallback::AppAccountAuthenticatorCallback(const std::string &sessionId) in AppAccountAuthenticatorCallback() argument
24 : sessionId_(sessionId) in AppAccountAuthenticatorCallback()
/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);
/base/security/device_security_level/baselib/msglib/src/common/
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);
66 int32_t sessionId; member
151 static bool GetDeviceIdentityFromSessionId(int sessionId, DeviceIdentify *identity, uint32_t *maskI… in GetDeviceIdentityFromSessionId() argument
157 int ret = GetPeerDeviceId(sessionId, networkId, DEVICE_ID_MAX_LEN + 1); in GetDeviceIdentityFromSessionId()
159 …_LOG_INFO("GetPeerDeviceId failed, sessionId is %{public}d, result is %{public}d", sessionId, ret); in GetDeviceIdentityFromSessionId()
173 static int MessengerOnSessionOpened(int sessionId, int result) in MessengerOnSessionOpened() argument
175 int side = GetSessionSide(sessionId); in MessengerOnSessionOpened()
[all …]
/base/account/os_account/services/accountmgr/test/moduletest/app_account/
Dapp_account_authenticator_session_manager_module_test.cpp296 std::string sessionId = SESSION_ID; variable
297 auto sessionPtr = appAccountAuthenticatorSessionManagerPtr_->GetSession(sessionId);
304 appAccountAuthenticatorSessionManagerPtr_->sessionMap_[sessionId] = session;
305 sessionPtr = appAccountAuthenticatorSessionManagerPtr_->GetSession(sessionId);
321 request.sessionId = SESSION_ID;
342 std::string sessionId = SESSION_ID; variable
352 auto sessionPtr = appAccountAuthenticatorSessionManagerPtr_->GetSession(sessionId);
355 appAccountAuthenticatorSessionManagerPtr_->OnSessionServerDied(sessionId);
357 appAccountAuthenticatorSessionManagerPtr_->sessionMap_[sessionId] = session;
358 sessionPtr = appAccountAuthenticatorSessionManagerPtr_->GetSession(sessionId);
[all …]
Dapp_account_authenticator_callback_test.cpp108 const std::string sessionId = "testsessionid"; variable
109 … AppAccountAuthenticatorCallbackPtr = std::make_shared<AppAccountAuthenticatorCallback>(sessionId);
113 ASSERT_EQ(AppAccountAuthenticatorCallbackPtr->sessionId_, sessionId);
115 ASSERT_EQ(AppAccountAuthenticatorCallbackPtr->sessionId_, sessionId);
/base/account/os_account/services/accountmgr/include/appaccount/
Dapp_account_authenticator_session_manager.h59 void CloseSession(const std::string &sessionId);
61 std::shared_ptr<AppAccountAuthenticatorSession> GetSession(const std::string &sessionId);
62 void OnSessionServerDied(const std::string &sessionId);
63 …void OnSessionAbilityConnectDone(const std::string &sessionId, const AppExecFwk::ElementName &elem…
66 const std::string &sessionId, const AppExecFwk::ElementName &element, int resultCode);
67 … void OnSessionResult(const std::string &sessionId, int32_t resultCode, const AAFwk::Want &result);
68 void OnSessionRequestRedirected(const std::string &sessionId, AAFwk::Want &request);
69 void OnSessionRequestContinued(const std::string &sessionId);
/base/security/device_auth/services/frameworks/src/plugin_adapter_mock/
Daccount_auth_plugin_proxy_mock.c36 int32_t CreateAuthSession(int32_t *sessionId, const CJson *in, CJson *out) in CreateAuthSession() argument
38 (void)sessionId; in CreateAuthSession()
44 int32_t ProcessAuthSession(int32_t *sessionId, const CJson *in, CJson *out, int32_t *status) in ProcessAuthSession() argument
46 (void)sessionId; in ProcessAuthSession()
/base/msdp/device_status/services/interaction/coordination/include/
Dcoordination_softbus_adapter.h60 int32_t OnSessionOpened(int32_t sessionId, int32_t result);
61 void OnSessionClosed(int32_t sessionId);
62 void OnBytesReceived(int32_t sessionId, const void* data, uint32_t dataLen);
74 std::string FindDevice(int32_t sessionId);
75 int32_t SendMsg(int32_t sessionId, const std::string &message);
77 void HandleSessionData(int32_t sessionId, const std::string &messageData);
78 void HandleCoordinationSessionData(int32_t sessionId, const JsonParser &parser);
79 int32_t WaitSessionOpend(const std::string &remoteNetworkId, int32_t sessionId);
/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/security/device_auth/services/key_agree_sdk/inc/
Dkey_agree_session_manager.h23 uint32_t (*addSession)(KeyAgreeSession *sessionId, SpekeSession *spekeSession);
24 uint32_t (*deleteSession)(KeyAgreeSession *sessionId);
25 SpekeSession *(*getSession)(KeyAgreeSession *sessionId);
/base/security/device_auth/services/group_manager/src/channel_manager/soft_bus_channel/
Dsoft_bus_channel.c153 static bool IsServer(int sessionId) in IsServer() argument
155 return GetSessionSide(sessionId) == 0; in IsServer()
158 static int OnChannelOpenedCb(int sessionId, int result) in OnChannelOpenedCb() argument
160 if (IsServer(sessionId)) { in OnChannelOpenedCb()
165 if (GetReqIdByChannelId(sessionId, &requestId) != HC_SUCCESS) { in OnChannelOpenedCb()
174 LOGI("[Start]: OnChannelOpened! [ChannelId]: %d, [ReqId]: %" PRId64, sessionId, requestId); in OnChannelOpenedCb()
191 static void OnChannelClosedCb(int sessionId) in OnChannelClosedCb() argument
193 LOGI("[SoftBus][Out]: OnChannelClosed! sessionId: %d", sessionId); in OnChannelClosedCb()
194 if (IsServer(sessionId)) { in OnChannelClosedCb()
197 RemoveChannelEntry(sessionId); in OnChannelClosedCb()
[all …]
/base/update/updater/services/flashd/daemon/
Ddaemon.cpp154 …Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), bufString… in HandDaemonAuth()
172 … Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), in HandDaemonAuth()
205 uint32_t unOld = hSession->sessionId; in DaemonSessionHandshake()
206 hSession->sessionId = handshake.sessionId; in DaemonSessionHandshake()
210 (reinterpret_cast<HdcDaemonUSB *>(clsUSBServ))->OnNewHandshakeOK(hSession->sessionId); in DaemonSessionHandshake()
213 handshake.sessionId = 0; in DaemonSessionHandshake()
226 …Send(hSession->sessionId, channelId, CMD_KERNEL_HANDSHAKE, (uint8_t *)bufString.c_str(), bufString… in DaemonSessionHandshake()
250 Send(hSession->sessionId, channelId, CMD_KERNEL_CHANNEL_CLOSE, payload, 1); in FetchCommand()
291 bool HdcDaemon::ServerCommand(const uint32_t sessionId, const uint32_t channelId, const uint16_t co… in ServerCommand() argument
294 return Send(sessionId, channelId, command, (uint8_t *)bufPtr, size) > 0; in ServerCommand()
/base/update/updateservice/frameworks/js/napi/base/include/
Dsession_manager.h30 void RemoveSession(uint32_t sessionId);
45 bool GetFirstSessionId(uint32_t &sessionId);
46 bool GetNextSessionId(uint32_t &sessionId);
/base/security/device_auth/services/frameworks/src/plugin_adapter/
Daccount_auth_plugin_proxy.c62 int32_t CreateAuthSession(int32_t *sessionId, const CJson *in, CJson *out) in CreateAuthSession() argument
68 return g_accountAuthPlugin->createSession(sessionId, in, out); in CreateAuthSession()
71 int32_t ProcessAuthSession(int32_t *sessionId, const CJson *in, CJson *out, int32_t *status) in ProcessAuthSession() argument
77 return g_accountAuthPlugin->processSession(sessionId, in, out, status); in ProcessAuthSession()
/base/security/device_auth/test/unittest/deviceauth/source/
Dkey_agree_sdk_test.cpp72 g_session->sessionId = g_sessionIdClient;
79 g_session_s->sessionId = g_sessionIdServer;
86 g_session->sessionId = g_sessionIdClient;
93 g_session->sessionId = g_sessionIdClient;
100 g_session->sessionId = g_sessionIdClient;
107 g_session->sessionId = g_sessionIdClient;
114 g_session->sessionId = g_sessionIdClient;
162 g_session->sessionId = g_sessionIdClient;
172 g_session->sessionId = g_sessionIdClient;
182 g_session->sessionId = g_sessionIdClient;
[all …]
/base/security/device_auth/services/key_agree_sdk/src/
Dkey_agree_session_manager.c110 (sessionNode->session->sessionId == session->sessionId)) { in DeleteSessionInner()
134 (sessionNode->session->sessionId == session->sessionId)) { in GetSessionInner()
/base/security/device_auth/services/frameworks/inc/plugin_adapter/
Daccount_auth_plugin_proxy.h29 int32_t CreateAuthSession(int32_t *sessionId, const CJson *in, CJson *out);
30 int32_t ProcessAuthSession(int32_t *sessionId, const CJson *in, CJson *out, int32_t *status);
/base/account/os_account/services/accountmgr/test/unittest/common/ability_manager_adapter/
Dability_manager_adapter_test.cpp77 explicit AbilityConnectCallbackTest(const std::string &sessionId) {} in AbilityConnectCallbackTest() argument
97 std::string sessionId = "testsessionId"; variable
98 … sptr<AbilityConnectCallbackTest> conn_ = new (std::nothrow) AbilityConnectCallbackTest(sessionId);
/base/account/os_account/test/fuzztest/appaccount_stub/getauthenticatorcallbackstub_fuzzer/
Dgetauthenticatorcallbackstub_fuzzer.cpp36 std::string sessionId(reinterpret_cast<const char*>(data), size); in GetAuthenticatorCallbackStubFuzzTest()
37 if (!dataTemp.WriteString(sessionId)) { in GetAuthenticatorCallbackStubFuzzTest()

1234