Home
last modified time | relevance | path

Searched refs:peerNetworkId (Results 1 – 25 of 151) sorted by relevance

1234567

/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/allconnectmgr/
H A Ddsched_all_connect_manager.cpp180 GetAnonymStr(peerNetworkId).c_str(), extraInfo.c_str(), state); in PublishServiceState()
206 peerConnectCbQueue_.push(peerNetworkId); in ApplyAdvanceResource()
219 ret = WaitAllConnectApplyCb(peerNetworkId); in ApplyAdvanceResource()
230 [this, peerNetworkId]() { in WaitAllConnectApplyCb()
240 GetAnonymStr(peerNetworkId).c_str(), peerConnectDecision_.at(peerNetworkId).load()); in WaitAllConnectApplyCb()
241 peerConnectDecision_.erase(peerNetworkId); in WaitAllConnectApplyCb()
248 GetAnonymStr(peerNetworkId).c_str(), isSupport); in NotifyAllConnectDecision()
250 peerConnectDecision_[peerNetworkId] = isSupport; in NotifyAllConnectDecision()
263 int32_t DSchedAllConnectManager::OnStop(const char *peerNetworkId) in OnStop() argument
266 GetAnonymStr(peerNetworkId).c_str()); in OnStop()
[all …]
/ohos5.0/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/all_connect/
H A Dall_connect_manager.cpp85 int32_t AllConnectManager::PublishServiceState(const std::string &peerNetworkId, in PublishServiceState() argument
89 Utils::GetAnonyString(peerNetworkId).c_str(), state); in PublishServiceState()
100 int32_t ret = allConnect_.ServiceCollaborationManager_PublishServiceState(peerNetworkId.c_str(), in PublishServiceState()
110 int32_t AllConnectManager::ApplyAdvancedResource(const std::string &peerNetworkId, in ApplyAdvancedResource() argument
113 …yAdvancedResource begin, peerNetworkId: %{public}s", Utils::GetAnonyString(peerNetworkId).c_str()); in ApplyAdvancedResource()
128 … int32_t ret = allConnect_.ServiceCollaborationManager_ApplyAdvancedResource(peerNetworkId.c_str(), in ApplyAdvancedResource()
138 …("applyResult is reject, peerNetworkId: %{public}s", Utils::GetAnonyString(peerNetworkId).c_str()); in ApplyAdvancedResource()
141 …dvancedResource success, peerNetworkId: %{public}s", Utils::GetAnonyString(peerNetworkId).c_str()); in ApplyAdvancedResource()
241 int32_t AllConnectManager::OnStop(const char *peerNetworkId) in OnStop() argument
243 std::string pNetworkId(peerNetworkId); in OnStop()
/ohos5.0/foundation/ability/dmsfwk/services/dtbschedmgr/include/softbus_adapter/allconnectmgr/
H A Ddsched_all_connect_manager.h34 int32_t PublishServiceState(const std::string &peerNetworkId, const std::string &extraInfo,
36 int32_t ApplyAdvanceResource(const std::string &peerNetworkId,
46 int32_t WaitAllConnectApplyCb(const std::string &peerNetworkId);
47 void NotifyAllConnectDecision(const std::string &peerNetworkId, bool isSupport);
49 static int32_t OnStop(const char *peerNetworkId);
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/fuzztest/softbusproxychannellistener_fuzzer/
H A Dsoftbusproxychannellistener_fuzzer.cpp39 char peerNetworkId[DEVICE_ID_SIZE_MAX] = TEST_PEER_NETWORK_ID; in TransOpenNetWorkingChannelSessionNameTest() local
41 TransOpenNetWorkingChannel(mySessionName, peerNetworkId, nullptr); in TransOpenNetWorkingChannelSessionNameTest()
50 char peerNetworkId[DEVICE_ID_SIZE_MAX] = {0}; in TransOpenNetWorkingChannelPeerNetworkIdTest() local
51 if (memcpy_s(peerNetworkId, DEVICE_ID_SIZE_MAX, data, size)) { in TransOpenNetWorkingChannelPeerNetworkIdTest()
56 TransOpenNetWorkingChannel(mySessionName, peerNetworkId, nullptr); in TransOpenNetWorkingChannelPeerNetworkIdTest()
/ohos5.0/foundation/communication/ipc/services/dbinder/dbinder_service/src/socket/
H A Ddbinder_remote_listener.cpp131 int32_t DBinderRemoteListener::CreateClientSocket(const std::string &peerNetworkId) in CreateClientSocket() argument
133 std::shared_ptr<DeviceLock> lockInfo = QueryOrNewDeviceLock(peerNetworkId); in CreateClientSocket()
141 auto it = clientSocketInfos_.find(peerNetworkId); in CreateClientSocket()
150 .peerNetworkId = const_cast<char*>(peerNetworkId.c_str()), in CreateClientSocket()
163 ret, socketId, DBinderService::ConvertToSecureDeviceID(peerNetworkId).c_str()); in CreateClientSocket()
165 EraseDeviceLock(peerNetworkId); in CreateClientSocket()
170 socketId, DBinderService::ConvertToSecureDeviceID(peerNetworkId).c_str()); in CreateClientSocket()
174 clientSocketInfos_[peerNetworkId] = socketId; in CreateClientSocket()
180 int32_t DBinderRemoteListener::GetPeerSocketId(const std::string &peerNetworkId) in GetPeerSocketId() argument
183 auto it = serverSocketInfos_.find(peerNetworkId); in GetPeerSocketId()
/ohos5.0/foundation/filemanagement/dfs_service/services/distributedfiledaemon/test/unittest/all_connect/
H A Dall_connect_manager_test.cpp52 static inline std::string peerNetworkId = "testNetworkId"; member in OHOS::Storage::DistributedFile::Test::AllConnectManagerTest
198 int32_t ret = allConnectManager.PublishServiceState(peerNetworkId, state);
222 int32_t ret = allConnectManager.PublishServiceState(peerNetworkId, state);
245 const char *peerNetworkId,
252 int32_t ret = allConnectManager.PublishServiceState(peerNetworkId, state);
275 const char *peerNetworkId,
282 int32_t ret = allConnectManager.PublishServiceState(peerNetworkId, state);
304 int32_t ret = allConnectManager.ApplyAdvancedResource(peerNetworkId, nullptr);
350 const char *peerNetworkId,
380 const char *peerNetworkId,
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/session/
H A Dclient_trans_session_service_impl_test.cpp165 std::string peerNetworkId = "peerNetworkId"; variable
170 … sessionServiceImpl.OpenSession(mySessionName, peerSessionName, peerNetworkId, groupId, flags);
184 std::string peerNetworkId = "peerNetworkId"; variable
189 … sessionServiceImpl.OpenSession(mySessionName, peerSessionName, peerNetworkId, groupId, flags);
203 std::string peerNetworkId = ""; variable
208 … sessionServiceImpl.OpenSession(mySessionName, peerSessionName, peerNetworkId, groupId, flags);
222 std::string peerNetworkId = "peerNetworkId"; variable
227 … sessionServiceImpl.OpenSession(mySessionName, peerSessionName, peerNetworkId, groupId, flags);
H A Dclient_trans_socket_service_test.cpp59 info.peerNetworkId = const_cast<char *>(g_networkId.c_str());
94 info.peerNetworkId = const_cast<char *>(g_networkId.c_str());
131 info.peerNetworkId = networkId;
137 info.peerNetworkId = networkId;
153 info.peerNetworkId = const_cast<char *>(g_networkId.c_str());
188 info.peerNetworkId = nullptr;
/ohos5.0/foundation/multimedia/av_session/services/session/adapter/
H A Dcollaboration_manager.cpp61 __attribute__((no_sanitize("cfi")))static int32_t OnStop(const char* peerNetworkId) in OnStop() argument
125 int32_t CollaborationManager::PublishServiceState(const char* peerNetworkId, in PublishServiceState() argument
133 if (exportapi_.ServiceCollaborationManager_PublishServiceState(peerNetworkId, in PublishServiceState()
140 int32_t CollaborationManager::ApplyAdvancedResource(const char* peerNetworkId) in ApplyAdvancedResource() argument
156 if (exportapi_.ServiceCollaborationManager_ApplyAdvancedResource(peerNetworkId, in ApplyAdvancedResource()
/ohos5.0/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
H A Dsoftbus_proxychannel_listener.c159 .peerNetworkId = NULL, in OnProxyChannelOpened()
366 GetOsTypeByNetworkId(peerNetworkId, &osType); in TransProxyGetAppInfo()
385 if (strcpy_s(appInfo->peerNetWorkId, sizeof(appInfo->peerNetWorkId), peerNetworkId) != EOK) { in TransProxyGetAppInfo()
390 ret = LnnGetRemoteStrInfo(peerNetworkId, STRING_KEY_UUID, in TransProxyGetAppInfo()
397 GetRemoteUdidWithNetworkId(peerNetworkId, appInfo->peerUdid, sizeof(appInfo->peerUdid)); in TransProxyGetAppInfo()
404 const char *peerNetworkId, ConnectOption *connOpt, const LanePreferredLinkList *preferred) in TransGetConnectOption() argument
417 peerNetworkId, NETWORK_ID_BUF_LEN) != EOK) { in TransGetConnectOption()
445 const char *sessionName, const char *peerNetworkId, const LanePreferredLinkList *preferred) in TransOpenNetWorkingChannel() argument
452 !IsValidString(peerNetworkId, DEVICE_ID_SIZE_MAX)) { in TransOpenNetWorkingChannel()
455 if (TransGetConnectOption(peerNetworkId, &connOpt, preferred) != SOFTBUS_OK) { in TransOpenNetWorkingChannel()
[all …]
/ohos5.0/foundation/communication/dsoftbus/sdk/transmission/session/src/
H A Dclient_trans_socket_service.c51 … if (info->peerNetworkId != NULL && !IsValidString(info->peerNetworkId, DEVICE_ID_SIZE_MAX - 1)) { in CheckSocketInfoIsValid()
53 Anonymize(info->peerNetworkId, &anonyNetworkId); in CheckSocketInfoIsValid()
55 anonyNetworkId, strlen(info->peerNetworkId)); in CheckSocketInfoIsValid()
70 Anonymize(info->peerNetworkId, &tmpPeerNetworkId); in PrintSocketInfo()
202 int32_t EvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t q… in EvaluateQos() argument
204 if (!IsValidString(peerNetworkId, DEVICE_ID_SIZE_MAX) || dataType >= DATA_TYPE_BUTT || in EvaluateQos()
210 return ServerIpcEvaluateQos(peerNetworkId, dataType, qos, qosCount); in EvaluateQos()
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/evaluateqos_fuzzer/
H A Devaluateqos_fuzzer.cpp34 std::unique_ptr<char[]> peerNetworkId = std::make_unique<char[]>(bufSize); in EvaluateQosTestWithNetworkId() local
35 if (memset_s(peerNetworkId.get(), bufSize, 0, bufSize) != EOK) { in EvaluateQosTestWithNetworkId()
39 if (memcpy_s(peerNetworkId.get(), bufSize, data, size) != EOK) { in EvaluateQosTestWithNetworkId()
49 …(void)EvaluateQos(peerNetworkId.get(), DATA_TYPE_MESSAGE, qosInfo, sizeof(qosInfo) / sizeof(qosInf… in EvaluateQosTestWithNetworkId()
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/socket_fuzzer/
H A Dsocket_fuzzer.cpp54 .peerNetworkId = const_cast<char *>(g_defaultSocketPeerNetworkid.c_str()), in SocketTestWithName()
85 .peerNetworkId = const_cast<char *>(g_defaultSocketPeerNetworkid.c_str()), in SocketTestWithPeerName()
116 .peerNetworkId = socketNetworkId.get(), in SocketTestWithNetworkId()
147 .peerNetworkId = const_cast<char *>(g_defaultSocketPkgName.c_str()), in SocketTestWithPkgName()
169 .peerNetworkId = const_cast<char *>(g_defaultSocketPkgName.c_str()), in SocketTestWithDataType()
/ohos5.0/foundation/ability/dmsfwk/interfaces/innerkits/common/include/
H A Dservice_collaboration_manager_capi.h69 int32_t (*OnStop)(const char *peerNetworkId);
74 …int32_t (*ServiceCollaborationManager_PublishServiceState)(const char *peerNetworkId, const char *…
76 …int32_t (*ServiceCollaborationManager_ApplyAdvancedResource)(const char *peerNetworkId, const char…
/ohos5.0/foundation/filemanagement/dfs_service/services/distributedfiledaemon/include/all_connect/
H A Dall_connect_manager.h34 int32_t PublishServiceState(const std::string &peerNetworkId,
36 int32_t ApplyAdvancedResource(const std::string &peerNetworkId,
47 static int32_t OnStop(const char *peerNetworkId);
H A Dservice_collaboration_manager_capi.h70 int32_t (*OnStop)(const char *peerNetworkId);
75 …int32_t (*ServiceCollaborationManager_PublishServiceState)(const char *peerNetworkId, const char *…
77 …int32_t (*ServiceCollaborationManager_ApplyAdvancedResource)(const char *peerNetworkId, const char…
/ohos5.0/foundation/multimedia/av_session/interfaces/inner_api/native/session/include/
H A Dcollaboration_manager_utils.h71 int32_t (*OnStop)(const char* peerNetworkId);
76 …int32_t (*ServiceCollaborationManager_PublishServiceState)(const char* peerNetworkId, const char* …
78 …int32_t (*ServiceCollaborationManager_ApplyAdvancedResource)(const char* peerNetworkId, const char…
/ohos5.0/foundation/filemanagement/dfs_service/services/distributedfiledaemon/src/network/softbus/
H A Dsoftbus_handler.cpp228 .peerNetworkId = const_cast<char*>(peerDevId.c_str()), in CreatSocketId()
366 std::string peerNetworkId = it->second; in RemoveNetworkId() local
369 if (item.second == peerNetworkId) { in RemoveNetworkId()
373 AllConnectManager::GetInstance().PublishServiceState(peerNetworkId, in RemoveNetworkId()
377 std::vector<int32_t> SoftBusHandler::GetsocketIdFromPeerNetworkId(const std::string &peerNetworkId) in GetsocketIdFromPeerNetworkId() argument
379 if (peerNetworkId.empty()) { in GetsocketIdFromPeerNetworkId()
386 if (item.second == peerNetworkId) { in GetsocketIdFromPeerNetworkId()
404 void SoftBusHandler::CopyOnStop(const std::string &peerNetworkId) in CopyOnStop() argument
406 auto socketIdList = GetsocketIdFromPeerNetworkId(peerNetworkId); in CopyOnStop()
/ohos5.0/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/
H A Dsoftbus_proxychannel_listener_test.cpp296 char peerNetworkId[SESSIONKEYSIZE] = {0}; variable
297 strcpy_s(peerNetworkId, SESSIONKEYSIZE, TEST_CHANNEL_INDENTITY);
299 int32_t ret = TransProxyGetAppInfo(sessionName, peerNetworkId, appInfo);
314 char peerNetworkId[SESSIONKEYSIZE] = {0}; variable
315 strcpy_s(peerNetworkId, SESSIONKEYSIZE, TEST_CHANNEL_INDENTITY);
317 int32_t ret = TransOpenNetWorkingChannel(sessionName, peerNetworkId, NULL);
/ohos5.0/foundation/ability/dmsfwk/test/fuzztest/dschedallconnectmanager_fuzzer/
H A Ddschedallconnectmanager_fuzzer.cpp74 const std::string peerNetworkId(reinterpret_cast<const char*>(data + offset), size - MIN_SIZE); in FuzzApplyAdvanceResource()
75 DSchedAllConnectManager::GetInstance().ApplyAdvanceResource(peerNetworkId, reqInfoSets); in FuzzApplyAdvanceResource()
126 const std::string peerNetworkId(reinterpret_cast<const char*>(data), size); in FuzzPublishServiceState()
131 DSchedAllConnectManager::GetInstance().PublishServiceState(peerNetworkId, extraInfo, state); in FuzzPublishServiceState()
/ohos5.0/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/softbus/
H A Dsession_manager.cpp78 int32_t SessionManager::SendData(const std::string &peerNetworkId, const void *data, uint32_t dataL… in SendData() argument
80 auto sendSession = CreateSession(SoftbusSession::DataType::TYPE_BYTES, peerNetworkId); in SendData()
87 int32_t SessionManager::SendFile(const std::string &peerNetworkId, in SendFile() argument
91 auto sendSession = CreateSession(SoftbusSession::DataType::TYPE_FILE, peerNetworkId); in SendFile()
/ohos5.0/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/src/
H A Dlnn_lane_link.c868 if (peerNetworkId == NULL) { in FetchLaneResourceByDevId()
875 Anonymize(peerNetworkId, &anonyPeerNetworkId); in FetchLaneResourceByDevId()
979 if (LnnGetRemoteStrInfo(reqInfo->peerNetworkId, STRING_KEY_DEV_UDID, in LaneLinkOfBr()
1202 if (LnnGetRemoteStrInfo(reqInfo->peerNetworkId, STRING_KEY_DEV_UDID, in LaneLinkOfBleReuseCommon()
1252 if (LnnGetRemoteStrInfo(reqInfo->peerNetworkId, STRING_KEY_DEV_UDID, in LaneLinkOfBle()
1289 if (LnnGetRemoteStrInfo(reqInfo->peerNetworkId, STRING_KEY_DEV_UDID, in LaneLinkOfGattDirect()
1340 if (LnnGetRemoteStrInfo(reqInfo->peerNetworkId, STRING_KEY_DEV_UDID, in LaneLinkOfP2pReuse()
1476 if (LnnGetRemoteStrInfo(reqInfo->peerNetworkId, STRING_KEY_DEV_UDID, in CreateWlanLinkInfo()
1536 if (LnnGetRemoteStrInfo(reqInfo->peerNetworkId, STRING_KEY_DEV_UDID, in LaneLinkOfCoc()
1571 if (LnnGetRemoteStrInfo(reqInfo->peerNetworkId, STRING_KEY_DEV_UDID, in LaneLinkOfCocDirect()
[all …]
/ohos5.0/foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/src/
H A Dlnn_net_builder_process.c134 if (strcmp(networkId, item->connInfo.peerNetworkId) == 0) { in FindConnectionFsmByNetworkId()
226 if (strcmp(msgPara->oldNetworkId, connFsm->connInfo.peerNetworkId) != 0) { in IsInvalidConnectionFsm()
453 if (strcmp(networkId, item->connInfo.peerNetworkId) != 0 || item->isDead) { in ProcessLeaveLNNRequest()
482 if (strcmp(networkId, item->connInfo.peerNetworkId) != 0 || item->isDead) { in ProcessSyncOfflineFinish()
558 isOnline = IsNodeOnline(connFsm->connInfo.peerNetworkId); in ProcessNodeStateChanged()
559 TryElectAsMasterState(connFsm->connInfo.peerNetworkId, isOnline); in ProcessNodeStateChanged()
593 if (!IsNodeOnline(connFsm->connInfo.peerNetworkId)) { in ProcessMasterElect()
608 SendElectMessageToAll(connFsm->connInfo.peerNetworkId); in ProcessMasterElect()
610 rc = SyncElectMessage(connFsm->connInfo.peerNetworkId); in ProcessMasterElect()
672 if (strcmp(item->connInfo.peerNetworkId, msgPara->networkId) != 0 || in ProcessLeaveSpecific()
/ohos5.0/foundation/communication/dsoftbus/core/common/security/permission/standard/
H A Daccess_control_virtual.c21 int32_t TransCheckClientAccessControl(const char *peerNetworkId) in TransCheckClientAccessControl() argument
23 (void)peerNetworkId; in TransCheckClientAccessControl()
/ohos5.0/foundation/deviceprofile/device_info_manager/services/core/test/unittest/
H A Dprofile_cache_test.cpp574 std::string peerNetworkId = ""; variable
575 ProfileCache::GetInstance().OnNodeOnline(peerNetworkId);
577 peerNetworkId = ProfileUtils::GetLocalUdidFromDM();
578 ProfileCache::GetInstance().OnNodeOnline(peerNetworkId);
579 EXPECT_NE("NetworkId", peerNetworkId);
590 std::string peerNetworkId = ""; variable
591 ProfileCache::GetInstance().OnNodeOffline(peerNetworkId);
593 peerNetworkId = ProfileUtils::GetLocalUdidFromDM();
594 ProfileCache::GetInstance().OnNodeOffline(peerNetworkId);
595 EXPECT_NE("NetworkId", peerNetworkId);

1234567