| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/ |
| H A D | dsched_transport_softbus_adapter.cpp | 46 std::string peerDeviceId(info.networkId); in OnBind() local
150 ret, GetAnonymStr(peerDeviceId).c_str()); in ConnectDevice()
154 ret = AddNewPeerSession(peerDeviceId, sessionId); in ConnectDevice()
164 sessionId = CreateClientSocket(peerDeviceId); in AddNewPeerSession()
200 ShutdownSession(peerDeviceId, sessionId); in AddNewPeerSession()
227 ShutdownSession(peerDeviceId, sessionId); in CreateSessionRecord()
242 ret, GetAnonymStr(peerDeviceId).c_str(), sessionId); in CreateSessionRecord()
262 ShutdownSession(peerDeviceId, sessionId); in DisconnectDevice()
313 GetAnonymStr(peerDeviceId).c_str(), sessionId); in OnShutdown()
314 ShutdownSession(peerDeviceId, sessionId); in OnShutdown()
[all …]
|
| /ohos5.0/base/security/device_auth/services/mk_agree/src/mock/ |
| H A D | key_manager_mock.c | 25 int32_t GenerateMk(int32_t osAccountId, const char *peerDeviceId, const Uint8Buff *peerPubKey) in GenerateMk() argument
28 (void)peerDeviceId; in GenerateMk()
33 int32_t DeleteMk(int32_t osAccountId, const char *peerDeviceId) in DeleteMk() argument
36 (void)peerDeviceId; in DeleteMk()
40 int32_t GeneratePseudonymPsk(int32_t osAccountId, const char *peerDeviceId, const Uint8Buff *salt) in GeneratePseudonymPsk() argument
43 (void)peerDeviceId; in GeneratePseudonymPsk()
48 int32_t DeletePseudonymPsk(int32_t osAccountId, const char *peerDeviceId) in DeletePseudonymPsk() argument
51 (void)peerDeviceId; in DeletePseudonymPsk()
55 int32_t GenerateAndSavePseudonymId(int32_t osAccountId, const char *peerDeviceId, const PseudonymKe… in GenerateAndSavePseudonymId() argument
59 (void)peerDeviceId; in GenerateAndSavePseudonymId()
|
| /ohos5.0/base/security/device_auth/services/mk_agree/src/ |
| H A D | key_manager.c | 116 Uint8Buff peerDevIdBuff = { (uint8_t *)peerDeviceId, HcStrlen(peerDeviceId) }; in GenerateMkAlias()
135 Uint8Buff peerDevIdBuff = { (uint8_t *)peerDeviceId, HcStrlen(peerDeviceId) }; in GeneratePseudonymPskAlias()
196 if (peerDeviceId == NULL || peerPubKey == NULL) { in GenerateMk()
202 int32_t res = GenerateMkAlias(peerDeviceId, &mkAliasBuff); in GenerateMk()
226 int32_t DeleteMk(int32_t osAccountId, const char *peerDeviceId) in DeleteMk() argument
228 if (peerDeviceId == NULL) { in DeleteMk()
234 int32_t res = GenerateMkAlias(peerDeviceId, &mkAliasBuff); in DeleteMk()
254 if (peerDeviceId == NULL || salt == NULL) { in GeneratePseudonymPsk()
260 int32_t res = GeneratePseudonymPskAlias(peerDeviceId, &pskAliasBuff); in GeneratePseudonymPsk()
267 res = GenerateMkAlias(peerDeviceId, &mkAliasBuff); in GeneratePseudonymPsk()
[all …]
|
| /ohos5.0/foundation/ability/dmsfwk/test/fuzztest/dschedtransportsoftbusadapter_fuzzer/ |
| H A D | dschedtransportsoftbusadapter_fuzzer.cpp | 35 std::string peerDeviceId(reinterpret_cast<const char*>(data), size); in FuzzOnBind()
37 dschedTransportSoftbusAdapter.OnBind(sessionId, peerDeviceId); in FuzzOnBind()
68 std::string peerDeviceId(reinterpret_cast<const char*>(data), size); in FuzzConnectDevice()
72 dschedTransportSoftbusAdapter.ConnectDevice(peerDeviceId, sessionId); in FuzzConnectDevice()
79 dschedTransportSoftbusAdapter.CreateClientSocket(peerDeviceId); in FuzzConnectDevice()
82 dschedTransportSoftbusAdapter.AddNewPeerSession(peerDeviceId, sessionId); in FuzzConnectDevice()
83 dschedTransportSoftbusAdapter.ShutdownSession(peerDeviceId, sessionId); in FuzzConnectDevice()
94 std::string peerDeviceId(reinterpret_cast<const char*>(data), size); in FuzzDisconnectDevice()
96 dschedTransportSoftbusAdapter.DisconnectDevice(peerDeviceId); in FuzzDisconnectDevice()
152 std::string peerDeviceId(reinterpret_cast<const char*>(data), size); in FuzzGetSessionIdByDeviceId()
[all …]
|
| /ohos5.0/foundation/distributedhardware/device_manager/test/unittest/mock/ |
| H A D | device_auth.cpp | 29 int32_t (*getRelatedGroups)(const char *appId, const char *peerDeviceId, char **returnGroupVec, uin…
32 (void)peerDeviceId;
48 int32_t (*getRelatedGroups)(const char *appId, const char *peerDeviceId, char **returnGroupVec, uin…
50 if (peerDeviceId == "123") {
54 if (peerDeviceId == "12345") {
58 if (peerDeviceId == "34567") {
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | auth_delegate.cpp | 34 int localUserId, int peerUserId, const std::string &peerDeviceId,
38 bool CheckUsers(int localUserId, int peerUserId, const std::string &peerDeviceId);
43 bool AuthHandlerStub::CheckUsers(int localUserId, int peerUserId, const std::string &peerDeviceId) in CheckUsers() argument
50 auto peerUsers = UserDelegate::GetInstance().GetRemoteUserStatus(peerDeviceId); in CheckUsers()
55 int localUserId, int peerUserId, const std::string &peerDeviceId, int32_t authType, bool isSend) in CheckAccess() argument
58 !DmAdapter::GetInstance().IsSameAccount(peerDeviceId)) { in CheckAccess()
62 return CheckUsers(localUserId, peerUserId, peerDeviceId); in CheckAccess()
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/transport/ |
| H A D | dsched_transport_softbus_adapter.h | 50 int32_t ConnectDevice(const std::string &peerDeviceId, int32_t &sessionId);
51 void DisconnectDevice(const std::string &peerDeviceId);
55 void OnBind(int32_t sessionId, const std::string &peerDeviceId);
62 bool GetSessionIdByDeviceId(const std::string &peerDeviceId, int32_t &sessionId);
68 int32_t CreateClientSocket(const std::string &peerDeviceId);
69 int32_t CreateSessionRecord(int32_t sessionId, const std::string &peerDeviceId, bool isServer);
70 int32_t AddNewPeerSession(const std::string &peerDeviceId, int32_t &sessionId);
71 void ShutdownSession(const std::string &peerDeviceId, int32_t sessionId);
|
| /ohos5.0/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/softbus/ |
| H A D | session_manager.cpp | 99 const std::string &peerDeviceId) in CreateSession() argument
101 if (!IsDeviceIdVailid(peerDeviceId)) { in CreateSession()
108 if ((session->GetDataType() == type) && (session->GetPeerDeviceId() == peerDeviceId)) { in CreateSession()
113 auto sendSession = make_shared<SoftbusSession>(peerDeviceId, SESSION_NAME.c_str(), type); in CreateSession()
124 bool SessionManager::IsDeviceIdVailid(const std::string &peerDeviceId) in IsDeviceIdVailid() argument
129 void SessionManager::ReleaseSession(SoftbusSession::DataType type, const std::string &peerDeviceId) in ReleaseSession() argument
131 auto sendSession = GetSendSession(type, peerDeviceId); in ReleaseSession()
178 const std::string &peerDeviceId) in GetSendSession() argument
182 if ((session->GetDataType() == type) && (session->GetPeerDeviceId() == peerDeviceId)) { in GetSendSession()
|
| H A D | softbus_adapter.cpp | 141 string peerDeviceId = SoftbusAdapter::GetInstance().GetPeerNetworkId(socket); in OnBytes() local
142 if (peerDeviceId.empty()) { in OnBytes()
153 listener->OnDataReceived(peerDeviceId, socket, data, dataLen); in OnBytes()
205 char *peerDeviceId, in OpenSession() argument
212 .peerNetworkId = peerDeviceId, in OpenSession()
237 SoftbusAdapter::GetInstance().AcceptSesion(socket, sessionName, peerDeviceId); in OpenSession()
246 char *peerDeviceId, in OpenSessionByP2P() argument
256 return OpenSession(sessionName, peerDeviceId, groupId, dataType); in OpenSessionByP2P()
|
| /ohos5.0/foundation/distributedhardware/device_manager/test/commonunittest/ |
| H A D | UTTest_dm_credential_manager.cpp | 269 "peerDeviceId" : ""
358 "peerDeviceId" : ""
391 "peerDeviceId" : ""
438 "peerDeviceId" : ""
447 "peerDeviceId" : ""
496 "peerDeviceId" : ""
527 "peerDeviceId" : ""
579 "peerDeviceId" : ""
588 "peerDeviceId" : ""
620 "peerDeviceId" : ""
[all …]
|
| /ohos5.0/base/security/device_auth/services/mk_agree/inc/ |
| H A D | key_manager.h | 31 int32_t GenerateMk(int32_t osAccountId, const char *peerDeviceId, const Uint8Buff *peerPubKey);
32 int32_t DeleteMk(int32_t osAccountId, const char *peerDeviceId);
33 int32_t GeneratePseudonymPsk(int32_t osAccountId, const char *peerDeviceId, const Uint8Buff *salt);
34 int32_t DeletePseudonymPsk(int32_t osAccountId, const char *peerDeviceId);
35 int32_t GenerateAndSavePseudonymId(int32_t osAccountId, const char *peerDeviceId, const PseudonymKe…
|
| /ohos5.0/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/ |
| H A D | session_pool_test.cpp | 216 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; variable
217 auto session = make_shared<SoftbusSession>(TEST_SESSION_ID, peerDeviceId);
309 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; variable
381 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; variable
388 pool->ReleaseSession(peerDeviceId, 1);
390 pool->ReleaseSession(peerDeviceId, 1);
399 pool->ReleaseSession(peerDeviceId, 1);
428 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; variable
439 pool->ReleaseSession(peerDeviceId, LINK_TYPE_P2P);
489 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; variable
[all …]
|
| /ohos5.0/foundation/communication/ipc/ipc/native/c/rpc/trans_adapter/src/ |
| H A D | rpc_softbus_trans.c | 64 static int32_t Connect(const char *saSessionName, const char *peerDeviceId, void *args) in Connect() argument
70 if (peerDeviceId == NULL) { in Connect()
75 int ret = OpenSession(saSessionName, saSessionName, peerDeviceId, "", &g_sessionAttr); in Connect()
76 printf("SOFTBUS Connect deviceid %s\n", peerDeviceId); in Connect()
|
| /ohos5.0/foundation/filemanagement/dfs_service/services/cloudsyncservice/include/transport/softbus/ |
| H A D | session_manager.h | 46 void ReleaseSession(SoftbusSession::DataType type, const std::string &peerDeviceId);
63 …_ptr<SoftbusSession> CreateSession(SoftbusSession::DataType type, const std::string &peerDeviceId);
64 …ptr<SoftbusSession> GetSendSession(SoftbusSession::DataType type, const std::string &peerDeviceId);
69 bool IsDeviceIdVailid(const std::string &peerDeviceId);
|
| H A D | softbus_adapter.h | 40 char *peerDeviceId,
44 int OpenSessionByP2P(char *sessionName, char *peerDeviceId, char *groupId, bool isFileType);
|
| /ohos5.0/foundation/communication/dsoftbus/sdk/transmission/session/src/ |
| H A D | client_trans_socket_manager.c | 47 (param->peerDeviceId == NULL) || in IsValidSessionParam()
68 strcpy_s(session->info.peerDeviceId, DEVICE_ID_SIZE_MAX, param->peerDeviceId) != EOK || in CreateNewSession()
350 if (strcmp(sessionNode->info.peerDeviceId, networkId) != 0) { in DestroyClientSessionByNetworkId()
507 if (param->peerDeviceId != NULL && in CreateNewSocketSession()
508 strcpy_s(session->info.peerDeviceId, DEVICE_ID_SIZE_MAX, param->peerDeviceId) != EOK) { in CreateNewSocketSession()
510 Anonymize(param->peerDeviceId, &anonyNetworkId); in CreateNewSocketSession()
512 anonyNetworkId, strlen(param->peerDeviceId)); in CreateNewSocketSession()
543 !IsValidString(session->info.peerDeviceId, DEVICE_ID_SIZE_MAX - 1)) { in CheckBindSocketInfo()
547 Anonymize(session->info.peerDeviceId, &anonyNetworkId); in CheckBindSocketInfo()
578 param->peerDeviceId = sessionNode->info.peerDeviceId; in FillSessionParam()
[all …]
|
| /ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/ |
| H A D | dsched_continue_manager.cpp | 104 void DSchedContinueManager::NotifyAllConnectDecision(std::string peerDeviceId, bool isSupport) in NotifyAllConnectDecision() argument
107 GetAnonymStr(peerDeviceId).c_str(), isSupport); in NotifyAllConnectDecision()
110 peerConnectDecision_[peerDeviceId] = isSupport; in NotifyAllConnectDecision()
319 if (peerConnectDecision_.find(peerDeviceId) != peerConnectDecision_.end()) { in HandleContinueMissionWithBundleName()
320 peerConnectDecision_.erase(peerDeviceId); in HandleContinueMissionWithBundleName()
338 [this, peerDeviceId]() { in WaitAllConnectDecision()
340 peerConnectDecision_.at(peerDeviceId).load(); in WaitAllConnectDecision()
343 if (peerConnectDecision_.find(peerDeviceId) == peerConnectDecision_.end()) { in WaitAllConnectDecision()
348 if (!peerConnectDecision_.at(peerDeviceId).load()) { in WaitAllConnectDecision()
350 peerConnectDecision_.erase(peerDeviceId); in WaitAllConnectDecision()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/ |
| H A D | trans_channel_callback.c | 68 GetRemoteUdidWithNetworkId(channel->peerDeviceId, peerUdid, sizeof(peerUdid)); in TransServerOnChannelOpened()
71 GetOsTypeByNetworkId(channel->peerDeviceId, &osType); in TransServerOnChannelOpened()
75 …TransGetRemoteDeviceVersion(channel->peerDeviceId, channel->isEncrypt ? CATEGORY_NETWORK_ID : CATE… in TransServerOnChannelOpened()
81 .peerNetworkId = channel->peerDeviceId, in TransServerOnChannelOpened()
91 .peerUdid = channel->isEncrypt ? peerUdid : channel->peerDeviceId in TransServerOnChannelOpened()
93 extra.deviceState = TransGetDeviceState(channel->peerDeviceId); in TransServerOnChannelOpened()
|
| /ohos5.0/foundation/communication/dsoftbus/core/adapter/transmission/src/ |
| H A D | data_bus_native_virtual.c | 24 int NotifyNearByOnMigrateEvents(const char *peerDeviceId, int routeType, bool isUpgrade) in NotifyNearByOnMigrateEvents() argument
26 (void)peerDeviceId; in NotifyNearByOnMigrateEvents()
|
| /ohos5.0/base/security/device_auth/test/fuzztest/group_manage/getrelatedgroups_fuzzer/ |
| H A D | getrelatedgroups_fuzzer.cpp | 33 std::string peerDeviceId(reinterpret_cast<const char *>(data), size); in FuzzDoGetRelatedGroups()
36 …gmInstance->getRelatedGroups(*osAccountId, appId.c_str(), peerDeviceId.c_str(), &outGroups, &group… in FuzzDoGetRelatedGroups()
|
| /ohos5.0/foundation/distributedhardware/device_manager/services/implementation/src/credential/ |
| H A D | dm_credential_manager.cpp | 52 std::string peerDeviceId; member
60 std::string peerDeviceId; member
79 credentialData.peerDeviceId = jsonObject[FIELD_PEER_DEVICE_ID].get<std::string>(); in from_json()
364 credentialDataInfo.peerDeviceId = jsonObject[FIELD_PEER_DEVICE_ID].get<std::string>(); in from_json()
370 jsonObject[FIELD_DEVICE_ID] = credentialDataInfo.peerDeviceId; in to_json()
371 jsonObject[FIELD_UDID] =credentialDataInfo.peerDeviceId; in to_json()
458 peerCredentialInfo.peerDeviceId = jsonObject[FIELD_PEER_USER_ID].get<std::string>(); in from_json()
464 jsonObject[FIELD_DEVICE_ID] = peerCredentialInfo.peerDeviceId; in to_json()
|
| /ohos5.0/base/security/device_auth/services/identity_manager/src/ |
| H A D | identity_common.c | 124 const char *peerDeviceId = GetPeerDevIdFromJson(in, &isUdid); in GetPeerDeviceEntry() local
125 if (peerDeviceId == NULL) { in GetPeerDeviceEntry()
129 … return GaGetTrustedDeviceEntryById(osAccountId, peerDeviceId, isUdid, groupId, returnDeviceEntry); in GetPeerDeviceEntry()
|
| /ohos5.0/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/softbus/ |
| H A D | softbus_session.cpp | 29 …::SoftbusSession(int32_t sessionId, std::string peerDeviceId) : sessionId_(sessionId), cid_(peerDe… in SoftbusSession() argument
|
| /ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/session/ |
| H A D | client_trans_session_service_test.cpp | 128 sessionParam->peerDeviceId = g_deviceId; in TestGenerateCommParam()
141 strcpy_s(session->info.peerDeviceId, DEVICE_ID_SIZE_MAX, param->peerDeviceId) != EOK || in TestGenerateSession()
219 ret = strcpy_s(session->info.peerDeviceId, DEVICE_ID_SIZE_MAX, param->peerDeviceId); in GenerateSession()
243 sessionParam->peerDeviceId = g_deviceId; in GenerateCommParam()
|
| /ohos5.0/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/softbus/ |
| H A D | softbus_session_test.cpp | 44 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; in SetUpTestCase() local
45 g_session = make_shared<SoftbusSession>(TEST_SESSION_ID, peerDeviceId); in SetUpTestCase()
|