Home
last modified time | relevance | path

Searched refs:peerDeviceId (Results 1 - 25 of 108) sorted by relevance

12345

/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/transport/
H A Ddsched_transport_softbus_adapter.cpp46 std::string peerDeviceId(info.networkId); in OnBind()
47 DSchedTransportSoftbusAdapter::GetInstance().OnBind(socket, peerDeviceId); in OnBind()
114 int32_t DSchedTransportSoftbusAdapter::ConnectDevice(const std::string &peerDeviceId, int32_t &sessionId) in ConnectDevice() argument
116 HILOGI("try to connect peer: %{public}s.", GetAnonymStr(peerDeviceId).c_str()); in ConnectDevice()
121 if (iter->second != nullptr && peerDeviceId == iter->second->GetPeerDeviceId()) { in ConnectDevice()
126 DSchedContinueManager::GetInstance().NotifyAllConnectDecision(peerDeviceId, true); in ConnectDevice()
138 ret = DSchedAllConnectManager::GetInstance().ApplyAdvanceResource(peerDeviceId, reqInfoSets); in ConnectDevice()
142 DSchedContinueManager::GetInstance().NotifyAllConnectDecision(peerDeviceId, false); in ConnectDevice()
145 DSchedContinueManager::GetInstance().NotifyAllConnectDecision(peerDeviceId, true); in ConnectDevice()
147 ret = DSchedAllConnectManager::GetInstance().PublishServiceState(peerDeviceId, "", SCM_PREPAR in ConnectDevice()
161 AddNewPeerSession(const std::string &peerDeviceId, int32_t &sessionId) AddNewPeerSession() argument
206 CreateClientSocket(const std::string &peerDeviceId) CreateClientSocket() argument
221 CreateSessionRecord(int32_t sessionId, const std::string &peerDeviceId, bool isServer) CreateSessionRecord() argument
248 DisconnectDevice(const std::string &peerDeviceId) DisconnectDevice() argument
270 ShutdownSession(const std::string &peerDeviceId, int32_t sessionId) ShutdownSession() argument
282 GetSessionIdByDeviceId(const std::string &peerDeviceId, int32_t &sessionId) GetSessionIdByDeviceId() argument
294 OnBind(int32_t sessionId, const std::string &peerDeviceId) OnBind() argument
311 std::string peerDeviceId = sessions_[sessionId]->GetPeerDeviceId(); OnShutdown() local
342 std::string peerDeviceId = (iter->second != nullptr) ? iter->second->GetPeerDeviceId() : ""; ReleaseChannel() local
[all...]
/foundation/distributedhardware/device_manager/test/unittest/mock/
H A Ddevice_auth.cpp29 int32_t (*getRelatedGroups)(const char *appId, const char *peerDeviceId, char **returnGroupVec, uint32_t *groupNum) in getRelatedGroups() argument
32 (void)peerDeviceId; in getRelatedGroups()
48 int32_t (*getRelatedGroups)(const char *appId, const char *peerDeviceId, char **returnGroupVec, uint32_t *groupNum) in getRelatedGroups() argument
50 if (peerDeviceId == "123") { in getRelatedGroups()
54 if (peerDeviceId == "12345") { in getRelatedGroups()
58 if (peerDeviceId == "34567") { in getRelatedGroups()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dauth_delegate.cpp34 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()
58 !DmAdapter::GetInstance().IsSameAccount(peerDeviceId)) { in CheckAccess()
62 return CheckUsers(localUserId, peerUserId, peerDeviceId); in CheckAccess()
54 CheckAccess( int localUserId, int peerUserId, const std::string &peerDeviceId, int32_t authType, bool isSend) CheckAccess() argument
H A Dauth_delegate.h35 int localUserId, int peerUserId, const std::string &peerDeviceId, int32_t authType, bool isSend = true);
/foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/transport/
H A Ddsched_transport_softbus_adapter.h50 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);
/foundation/ability/dmsfwk/test/fuzztest/dschedtransportsoftbusadapter_fuzzer/
H A Ddschedtransportsoftbusadapter_fuzzer.cpp35 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()
81 dschedTransportSoftbusAdapter.CreateSessionRecord(sessionId, peerDeviceId, isServer); 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()
[all...]
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/softbus/
H A Dsession_manager.cpp99 const std::string &peerDeviceId) in CreateSession()
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()
182 if ((session->GetDataType() == type) && (session->GetPeerDeviceId() == peerDeviceId)) { in GetSendSession()
98 CreateSession(SoftbusSession::DataType type, const std::string &peerDeviceId) CreateSession() argument
177 GetSendSession(SoftbusSession::DataType type, const std::string &peerDeviceId) GetSendSession() argument
H A Dsoftbus_adapter.cpp144 string peerDeviceId = SoftbusAdapter::GetInstance().GetPeerNetworkId(socket); in OnBytes() local
145 if (peerDeviceId.empty()) { in OnBytes()
146 LOGE("get peerDeviceId name failed"); in OnBytes()
156 listener->OnDataReceived(peerDeviceId, socket, data, dataLen); in OnBytes()
182 LOGE("get peerDeviceId name failed"); in OnReceiveFileFinished()
208 char *peerDeviceId, in OpenSession()
215 .peerNetworkId = peerDeviceId, in OpenSession()
243 SoftbusAdapter::GetInstance().AcceptSesion(socket, sessionName, peerDeviceId); in OpenSession()
252 char *peerDeviceId, in OpenSessionByP2P()
262 return OpenSession(sessionName, peerDeviceId, groupI in OpenSessionByP2P()
207 OpenSession(char *sessionName, char *peerDeviceId, char *groupId, TransDataType dataType) OpenSession() argument
251 OpenSessionByP2P(char *sessionName, char *peerDeviceId, char *groupId, bool isFileType) OpenSessionByP2P() argument
[all...]
H A Dsoftbus_session.cpp37 SoftbusSession::SoftbusSession(const std::string &peerDeviceId, const std::string &sessionName, DataType type) in SoftbusSession() argument
38 : peerDeviceId_(peerDeviceId), sessionName_(sessionName), type_(type) in SoftbusSession()
/foundation/distributedhardware/device_manager/test/commonunittest/
H A DUTTest_dm_credential_manager.cpp269 "peerDeviceId" : "" in HWTEST_F()
358 "peerDeviceId" : "" in HWTEST_F()
391 "peerDeviceId" : "" in HWTEST_F()
438 "peerDeviceId" : "" in HWTEST_F()
447 "peerDeviceId" : "" in HWTEST_F()
496 "peerDeviceId" : "" in HWTEST_F()
527 "peerDeviceId" : "" in HWTEST_F()
579 "peerDeviceId" : "" in HWTEST_F()
588 "peerDeviceId" : "" in HWTEST_F()
620 "peerDeviceId" in HWTEST_F()
[all...]
/foundation/communication/ipc/ipc/native/c/rpc/trans_adapter/src/
H A Drpc_softbus_trans.c64 static int32_t Connect(const char *saSessionName, const char *peerDeviceId, void *args) in Connect() argument
70 if (peerDeviceId == NULL) { in Connect()
71 RPC_LOG_ERROR("Connect peerDeviceId is null"); in Connect()
75 int ret = OpenSession(saSessionName, saSessionName, peerDeviceId, "", &g_sessionAttr); in Connect()
76 printf("SOFTBUS Connect deviceid %s\n", peerDeviceId); in Connect()
/foundation/communication/dsoftbus/core/adapter/transmission/src/
H A Ddata_bus_native_virtual.c24 int NotifyNearByOnMigrateEvents(const char *peerDeviceId, int routeType, bool isUpgrade) in NotifyNearByOnMigrateEvents() argument
26 (void)peerDeviceId; in NotifyNearByOnMigrateEvents()
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/
H A Dsession_pool_test.cpp216 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; in HWTEST_F() local
217 auto session = make_shared<SoftbusSession>(TEST_SESSION_ID, peerDeviceId); in HWTEST_F()
309 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; in HWTEST_F() local
310 auto session = make_shared<SoftbusSession>(TEST_SESSION_ID, peerDeviceId); in HWTEST_F()
381 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; in HWTEST_F() local
382 auto session = make_shared<SoftbusSession>(TEST_SESSION_ID, peerDeviceId); in HWTEST_F()
388 pool->ReleaseSession(peerDeviceId, 1); in HWTEST_F()
390 pool->ReleaseSession(peerDeviceId, 1); in HWTEST_F()
399 pool->ReleaseSession(peerDeviceId, 1); in HWTEST_F()
428 std::string peerDeviceId in HWTEST_F() local
489 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; HWTEST_F() local
584 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; HWTEST_F() local
[all...]
/foundation/filemanagement/dfs_service/services/cloudsyncservice/include/transport/softbus/
H A Dsession_manager.h46 void ReleaseSession(SoftbusSession::DataType type, const std::string &peerDeviceId);
63 std::shared_ptr<SoftbusSession> CreateSession(SoftbusSession::DataType type, const std::string &peerDeviceId);
64 std::shared_ptr<SoftbusSession> GetSendSession(SoftbusSession::DataType type, const std::string &peerDeviceId);
69 bool IsDeviceIdVailid(const std::string &peerDeviceId);
H A Dsoftbus_adapter.h40 char *peerDeviceId,
44 int OpenSessionByP2P(char *sessionName, char *peerDeviceId, char *groupId, bool isFileType);
/foundation/ability/dmsfwk/services/dtbschedmgr/src/continue/
H A Ddsched_continue_manager.cpp104 void DSchedContinueManager::NotifyAllConnectDecision(std::string peerDeviceId, bool isSupport) in NotifyAllConnectDecision() argument
106 HILOGI("Notify all connect decision, peerDeviceId %{public}s, isSupport %{public}d.", in NotifyAllConnectDecision()
107 GetAnonymStr(peerDeviceId).c_str(), isSupport); in NotifyAllConnectDecision()
110 peerConnectDecision_[peerDeviceId] = isSupport; in NotifyAllConnectDecision()
317 std::string peerDeviceId = direction == CONTINUE_SOURCE ? info.sinkDeviceId_ : info.sourceDeviceId_; in HandleContinueMissionWithBundleName() local
318 if (peerConnectDecision_.find(peerDeviceId) != peerConnectDecision_.end()) { in HandleContinueMissionWithBundleName()
319 peerConnectDecision_.erase(peerDeviceId); in HandleContinueMissionWithBundleName()
333 std::string peerDeviceId = direction == CONTINUE_SOURCE ? info.sinkDeviceId_ : info.sourceDeviceId_; in WaitAllConnectDecision() local
337 [this, peerDeviceId]() { in WaitAllConnectDecision()
338 return peerConnectDecision_.find(peerDeviceId) ! in WaitAllConnectDecision()
[all...]
/foundation/communication/dsoftbus/sdk/transmission/session/src/
H A Dclient_trans_socket_manager.c47 (param->peerDeviceId == NULL) || in IsValidSessionParam()
68 strcpy_s(session->info.peerDeviceId, DEVICE_ID_SIZE_MAX, param->peerDeviceId) != EOK || in CreateNewSession()
347 if (strcmp(sessionNode->info.peerDeviceId, networkId) != 0) { in DestroyClientSessionByNetworkId()
504 if (param->peerDeviceId != NULL && in CreateNewSocketSession()
505 strcpy_s(session->info.peerDeviceId, DEVICE_ID_SIZE_MAX, param->peerDeviceId) != EOK) { in CreateNewSocketSession()
507 Anonymize(param->peerDeviceId, &anonyNetworkId); in CreateNewSocketSession()
508 TRANS_LOGI(TRANS_SDK, "strcpy peerDeviceId failed, peerDeviceId in CreateNewSocketSession()
[all...]
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/softbus/
H A Dsoftbus_session.cpp29 SoftbusSession::SoftbusSession(int32_t sessionId, std::string peerDeviceId) : sessionId_(sessionId), cid_(peerDeviceId) in SoftbusSession() argument
/foundation/communication/dsoftbus/core/transmission/trans_channel/manager/src/
H A Dtrans_channel_callback.c68 GetRemoteUdidWithNetworkId(channel->peerDeviceId, peerUdid, sizeof(peerUdid)); in TransServerOnChannelOpened()
71 GetOsTypeByNetworkId(channel->peerDeviceId, &osType); in TransServerOnChannelOpened()
75 TransGetRemoteDeviceVersion(channel->peerDeviceId, channel->isEncrypt ? CATEGORY_NETWORK_ID : CATEGORY_UDID, 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()
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/network/softbus/
H A Dsoftbus_session_test.cpp44 std::string peerDeviceId = "f6d4c0864707aefte7a78f09473aa122ff57fc8"; in SetUpTestCase() local
45 g_session = make_shared<SoftbusSession>(TEST_SESSION_ID, peerDeviceId); in SetUpTestCase()
/foundation/communication/dsoftbus/core/adapter/transmission/include/
H A Ddata_bus_native.h29 int NotifyNearByOnMigrateEvents(const char *peerDeviceId, int routeType, bool isUpgrade);
/foundation/distributedhardware/device_manager/services/implementation/src/credential/
H A Ddm_credential_manager.cpp52 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()
/foundation/communication/dsoftbus/tests/sdk/transmission/session/
H A Dclient_trans_session_service_test.cpp128 sessionParam->peerDeviceId = g_deviceId; in TestGenerateCommParam()
141 strcpy_s(session->info.peerDeviceId, DEVICE_ID_SIZE_MAX, param->peerDeviceId) != EOK || in TestGenerateSession()
220 ret = strcpy_s(session->info.peerDeviceId, DEVICE_ID_SIZE_MAX, param->peerDeviceId); in GenerateSession()
244 sessionParam->peerDeviceId = g_deviceId; in GenerateCommParam()
/foundation/distributedhardware/device_manager/services/implementation/src/dependency/softbus/
H A Dsoftbus_session.cpp121 char peerDeviceId[DEVICE_UUID_LENGTH] = {0}; in GetPeerDeviceId() local
122 int32_t ret = ::GetPeerDeviceId(sessionId, &peerDeviceId[0], DEVICE_UUID_LENGTH); in GetPeerDeviceId()
124 peerDevId = peerDeviceId; in GetPeerDeviceId()
125 LOGI("[SOFTBUS]GetPeerDeviceId success for session: %{public}d, peerDeviceId: %{public}s.", sessionId, in GetPeerDeviceId()
/foundation/communication/ipc/ipc/native/c/rpc/trans_adapter/include/
H A Drpc_trans.h34 int32_t (*Connect)(const char *SaSessionName, const char *peerDeviceId, void *args);

Completed in 13 milliseconds

12345