Home
last modified time | relevance | path

Searched refs:peerNetworkId (Results 1 - 25 of 149) sorted by relevance

123456

/foundation/ability/dmsfwk/services/dtbschedmgr/src/softbus_adapter/allconnectmgr/
H A Ddsched_all_connect_manager.cpp179 int32_t DSchedAllConnectManager::PublishServiceState(const std::string &peerNetworkId, const std::string &extraInfo, in PublishServiceState() argument
183 HILOGI("Publish service state enter, peerNetworkId %{public}s, extraInfo %{public}s, state %{public}d.", in PublishServiceState()
184 GetAnonymStr(peerNetworkId).c_str(), extraInfo.c_str(), state); in PublishServiceState()
190 int32_t ret = allConnectMgrApi_.ServiceCollaborationManager_PublishServiceState(peerNetworkId.c_str(), in PublishServiceState()
198 int32_t DSchedAllConnectManager::ApplyAdvanceResource(const std::string &peerNetworkId, in ApplyAdvanceResource() argument
204 HILOGI("Apply advance resource enter, peerNetworkId %{public}s.", GetAnonymStr(peerNetworkId).c_str()); in ApplyAdvanceResource()
210 peerConnectCbQueue_.push(peerNetworkId); in ApplyAdvanceResource()
215 ret = allConnectMgrApi_.ServiceCollaborationManager_ApplyAdvancedResource(peerNetworkId.c_str(), in ApplyAdvanceResource()
223 ret = WaitAllConnectApplyCb(peerNetworkId); in ApplyAdvanceResource()
230 WaitAllConnectApplyCb(const std::string &peerNetworkId) WaitAllConnectApplyCb() argument
249 NotifyAllConnectDecision(const std::string &peerNetworkId, bool isSupport) NotifyAllConnectDecision() argument
267 OnStop(const char *peerNetworkId) OnStop() argument
290 std::string peerNetworkId = peerConnectCbQueue_.front(); ApplyResult() local
[all...]
/foundation/multimedia/av_session/services/session/server/test/
H A Dcollaboration_manager_test.cpp156 const char* peerNetworkId = ""; in HWTEST_F() local
158 int32_t ret = CollaborationManager::GetInstance().PublishServiceState(peerNetworkId, state); in HWTEST_F()
171 const char* peerNetworkId = ""; in HWTEST_F() local
173 auto publishServiceState = [](const char* peerNetworkId, const char* serviceName, in HWTEST_F()
179 int32_t ret = CollaborationManager::GetInstance().PublishServiceState(peerNetworkId, state); in HWTEST_F()
192 const char* peerNetworkId = ""; in HWTEST_F() local
194 auto publishServiceState = [](const char* peerNetworkId, const char* serviceName, in HWTEST_F()
200 int32_t ret = CollaborationManager::GetInstance().PublishServiceState(peerNetworkId, state); in HWTEST_F()
213 const char* peerNetworkId = ""; in HWTEST_F() local
214 int32_t ret = CollaborationManager::GetInstance().ApplyAdvancedResource(peerNetworkId); in HWTEST_F()
227 const char* peerNetworkId = ""; HWTEST_F() local
248 const char* peerNetworkId = ""; HWTEST_F() local
[all...]
/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);
/foundation/communication/dsoftbus/tests/core/transmission/fuzztest/softbusproxychannellistener_fuzzer/
H A Dsoftbusproxychannellistener_fuzzer.cpp25 #define TEST_PEER_NETWORK_ID "com.test.trans.demo.peerNetworkId"
39 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()
/foundation/communication/dsoftbus/tests/sdk/transmission/session/
H A Dclient_trans_session_service_impl_test.cpp165 std::string peerNetworkId = "peerNetworkId"; in HWTEST_F() local
170 sessionServiceImpl.OpenSession(mySessionName, peerSessionName, peerNetworkId, groupId, flags); in HWTEST_F()
184 std::string peerNetworkId = "peerNetworkId"; in HWTEST_F() local
189 sessionServiceImpl.OpenSession(mySessionName, peerSessionName, peerNetworkId, groupId, flags); in HWTEST_F()
195 * @tc.desc: Test when peerNetworkId is empty then OpenSession returns nullptr.
203 std::string peerNetworkId = ""; in HWTEST_F() local
208 sessionServiceImpl.OpenSession(mySessionName, peerSessionName, peerNetworkId, groupId, flags); in HWTEST_F()
222 std::string peerNetworkId in HWTEST_F() local
[all...]
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/evaluateqos_fuzzer/
H A Devaluateqos_fuzzer.cpp32 std::unique_ptr<char[]> peerNetworkId = std::make_unique<char[]>(bufSize); in EvaluateQosTestWithNetworkId() local
33 if (memset_s(peerNetworkId.get(), bufSize, 0, bufSize) != EOK) { in EvaluateQosTestWithNetworkId()
37 if (memcpy_s(peerNetworkId.get(), bufSize, data, size) != EOK) { in EvaluateQosTestWithNetworkId()
47 (void)EvaluateQos(peerNetworkId.get(), DATA_TYPE_MESSAGE, qosInfo, sizeof(qosInfo) / sizeof(qosInfo[0])); in EvaluateQosTestWithNetworkId()
/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()
H A Dcollaboration_manager.h35 int32_t PublishServiceState(const char* peerNetworkId, ServiceCollaborationManagerBussinessStatus state);
36 int32_t ApplyAdvancedResource(const char* peerNetworkId);
/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 LOGI("ApplyAdvancedResource begin, peerNetworkId: %{public}s", Utils::GetAnonyString(peerNetworkId).c_str()); in ApplyAdvancedResource()
128 int32_t ret = allConnect_.ServiceCollaborationManager_ApplyAdvancedResource(peerNetworkId.c_str(), in ApplyAdvancedResource()
138 LOGE("applyResult is reject, peerNetworkId: %{public}s", Utils::GetAnonyString(peerNetworkId).c_str()); in ApplyAdvancedResource()
141 LOGI("ApplyAdvancedResource success, peerNetworkId in ApplyAdvancedResource()
241 OnStop(const char *peerNetworkId) OnStop() argument
[all...]
/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 *serviceName,
76 int32_t (*ServiceCollaborationManager_ApplyAdvancedResource)(const char *peerNetworkId, const char *serviceName,
/foundation/multimedia/av_session/services/session/server/test/fuzztest/collaborationmanager_fuzzer/
H A Dcollaborationmanager_fuzzer.cpp59 const char* peerNetworkId = reinterpret_cast<const char*>(data); in CollaborationManagerFuzzTest() local
63 collaborationManager.PublishServiceState(peerNetworkId, state); in CollaborationManagerFuzzTest()
64 collaborationManager.ApplyAdvancedResource(peerNetworkId); in CollaborationManagerFuzzTest()
/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* serviceName,
78 int32_t (*ServiceCollaborationManager_ApplyAdvancedResource)(const char* peerNetworkId, const char* serviceName,
/foundation/filemanagement/dfs_service/services/distributedfiledaemon/include/all_connect/
H A Dservice_collaboration_manager_capi.h70 int32_t (*OnStop)(const char *peerNetworkId);
75 int32_t (*ServiceCollaborationManager_PublishServiceState)(const char *peerNetworkId, const char *serviceName,
77 int32_t (*ServiceCollaborationManager_ApplyAdvancedResource)(const char *peerNetworkId, const char *serviceName,
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);
/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()
/foundation/communication/dsoftbus/tests/sdk/transmission/fuzztest/socket_fuzzer/
H A Dsocket_fuzzer.cpp48 .peerNetworkId = const_cast<char *>(DEFAULT_SOCKET_PEER_NETWORKID.c_str()), in SocketTestWithName()
75 .peerNetworkId = const_cast<char *>(DEFAULT_SOCKET_PEER_NETWORKID.c_str()), in SocketTestWithPeerName()
102 .peerNetworkId = socketNetworkId.get(), in SocketTestWithNetworkId()
129 .peerNetworkId = const_cast<char *>(DEFAULT_SOCKET_PKG_NAME.c_str()), in SocketTestWithPkgName()
151 .peerNetworkId = const_cast<char *>(DEFAULT_SOCKET_PKG_NAME.c_str()), in SocketTestWithDataType()
/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); in HWTEST_F()
222 int32_t ret = allConnectManager.PublishServiceState(peerNetworkId, state); in HWTEST_F()
245 const char *peerNetworkId, in HWTEST_F()
252 int32_t ret = allConnectManager.PublishServiceState(peerNetworkId, state); in HWTEST_F()
275 const char *peerNetworkId, in HWTEST_F()
282 int32_t ret = allConnectManager.PublishServiceState(peerNetworkId, state); in HWTEST_F()
304 int32_t ret = allConnectManager.ApplyAdvancedResource(peerNetworkId, nullptr); in HWTEST_F()
327 int32_t ret = allConnectManager.ApplyAdvancedResource(peerNetworkId, nullptr); in HWTEST_F()
350 const char *peerNetworkId, in HWTEST_F()
[all...]
/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()
54 TRANS_LOGI(TRANS_SDK, "strcpy peerNetworkId failed, peerNetworkId=%{public}s, peerNetworkIdLen=%{public}zu", in CheckSocketInfoIsValid()
55 AnonymizeWrapper(anonyNetworkId), strlen(info->peerNetworkId)); in CheckSocketInfoIsValid()
70 Anonymize(info->peerNetworkId, &tmpPeerNetworkId); in PrintSocketInfo()
73 "Socket: mySessionName=%{public}s, peerSessionName=%{public}s, peerNetworkId=%{public}s, " in PrintSocketInfo()
202 int32_t EvaluateQos(const char *peerNetworkId, TransDataType dataType, const QosTV *qos, uint32_t qosCount) in EvaluateQos() argument
204 if (!IsValidString(peerNetworkId, DEVICE_ID_SIZE_MA in EvaluateQos()
[all...]
/foundation/communication/dsoftbus/core/bus_center/lnn/lane_hub/lane_manager/src/
H A Dlnn_lane_link_p2p_virtual.c69 void RecycleP2pLinkedReqByLinkType(const char *peerNetworkId, LaneLinkType linkType) in RecycleP2pLinkedReqByLinkType() argument
71 (void)peerNetworkId; in RecycleP2pLinkedReqByLinkType()
/foundation/deviceprofile/device_info_manager/services/core/include/
H A Di_dp_sync_adapter.h31 virtual int32_t NotOHBaseDeviceOnline(const std::string& peerUdid, const std::string& peerNetworkId,
33 virtual int32_t SyncProfile(const std::string& peerUdid, const std::string& peerNetworkId,
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/
H A Dsoftbus_proxychannel_listener.c158 .peerNetworkId = NULL, in OnProxyChannelOpened()
273 .peerNetworkId = (appInfo->appType == APP_TYPE_AUTH) ? appInfo->peerData.deviceId : appInfo->peerNetWorkId, in TransProxyReportOpenChannelFailEvent()
361 static int32_t TransProxyGetAppInfo(const char *sessionName, const char *peerNetworkId, AppInfo *appInfo) in TransProxyGetAppInfo() argument
365 GetOsTypeByNetworkId(peerNetworkId, &osType); in TransProxyGetAppInfo()
384 if (strcpy_s(appInfo->peerNetWorkId, sizeof(appInfo->peerNetWorkId), peerNetworkId) != EOK) { in TransProxyGetAppInfo()
385 TRANS_LOGE(TRANS_CTRL, "strcpy_s peerNetworkId failed"); in TransProxyGetAppInfo()
389 ret = LnnGetRemoteStrInfo(peerNetworkId, STRING_KEY_UUID, in TransProxyGetAppInfo()
396 GetRemoteUdidWithNetworkId(peerNetworkId, appInfo->peerUdid, sizeof(appInfo->peerUdid)); in TransProxyGetAppInfo()
397 TransGetRemoteDeviceVersion(peerNetworkId, CATEGORY_NETWORK_ID, appInfo->peerVersion, sizeof(appInfo->peerVersion)); in TransProxyGetAppInfo()
403 const char *peerNetworkId, ConnectOptio in TransGetConnectOption()
402 TransGetConnectOption( const char *peerNetworkId, ConnectOption *connOpt, const LanePreferredLinkList *preferred) TransGetConnectOption() argument
443 TransOpenNetWorkingChannel( const char *sessionName, const char *peerNetworkId, const LanePreferredLinkList *preferred) TransOpenNetWorkingChannel() argument
[all...]
/foundation/communication/ipc/services/dbinder/dbinder_service/src/socket/
H A Ddbinder_remote_listener.cpp52 DBINDER_LOGI(LOG_LABEL, "socketId:%{public}d, peerNetworkId:%{public}s, peerName:%{public}s", in ServerOnBind()
131 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()
162 DBINDER_LOGE(LOG_LABEL, "Bind failed, ret:%{public}d, socketId:%{public}d, peerNetworkId:%{public}s", in CreateClientSocket()
163 ret, socketId, DBinderService::ConvertToSecureDeviceID(peerNetworkId).c_str()); in CreateClientSocket()
165 EraseDeviceLock(peerNetworkId); in CreateClientSocket()
169 DBINDER_LOGI(LOG_LABEL, "Bind succ socketId:%{public}d, peerNetworkId in CreateClientSocket()
180 GetPeerSocketId(const std::string &peerNetworkId) GetPeerSocketId() argument
[all...]
/foundation/communication/dsoftbus/tests/core/bus_center/mock_common/src/
H A Dlnn_trans_mock.cpp47 int32_t TransOpenNetWorkingChannel(const char *sessionName, const char *peerNetworkId, in TransOpenNetWorkingChannel() argument
51 return GetTransInterface()->TransOpenNetWorkingChannel(sessionName, peerNetworkId); in TransOpenNetWorkingChannel()
/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()
/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 dataLen) 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()

Completed in 10 milliseconds

123456