/foundation/communication/ipc/ipc/test/unittest/ipc/client/ |
H A D | IpcClientTest.cpp | 118 int ret = SendRequest(target, GET_SYSTEM_ABILITY_TRANSACTION, &data1, &reply1, g_option, &ptr); in HWTEST_F() local 134 int ret = SendRequest(sidServer, SERVER_OP_ADD, &data2, &reply2, g_option, &ptr2); in HWTEST_F() local 154 int ret = SendRequest(sidServer, SERVER_OP_MULTI, &data2, &reply, g_option, &ptr); in HWTEST_F() local 184 int ret = SendRequest(sidServer, SERVER_OP_ADD_SERVICE, &anonymous, &anonymousreply, g_option, &anonymousptr); in HWTEST_F() local 196 int ret = AddDeathRecipient(sidServer, (OnRemoteDead)ServerDead1, nullptr, &cbId1); in HWTEST_F() local 211 int ret = RemoveDeathRecipient(sidServer, cbId2); HWTEST_F() local 224 int ret = AddDeathRecipient(sidServer, (OnRemoteDead)ServerDead3, nullptr, &cbId5); // failed HWTEST_F() local 286 int ret = AddDeathRecipient(sidServer, (OnRemoteDead)ServerDead1, nullptr, &cbId1); HWTEST_F() local [all...] |
/foundation/communication/netmanager_base/frameworks/native/netpolicyclient/src/ |
H A D | net_policy_service_proxy.cpp | 40 int32_t ret = NETMANAGER_SUCCESS; in SendRequest() local 683 int ret = remote->SendRequest(static_cast<uint32_t>(PolicyInterfaceCode::CMD_NPS_CHECK_PERMISSION), in CheckPermission() local
|
/foundation/communication/netmanager_base/frameworks/native/netstatsclient/src/ |
H A D | net_stats_client.cpp | 44 int32_t ret = proxy->RegisterNetStatsCallback(callback); in RegisterNetStatsCallback() local 60 int32_t ret = proxy->UnregisterNetStatsCallback(callback); in UnregisterNetStatsCallback() local 119 int32_t ret = proxy->RegisterNetStatsCallback(callback_); in RecoverCallback() local
|
/foundation/communication/netmanager_base/test/fuzztest/netstatsclient_fuzzer/ |
H A D | net_stats_client_fuzzer.cpp | 47 errno_t ret = memcpy_s(&object, netStatsSize, g_baseFuzzData + g_baseFuzzPos, netStatsSize); in NetStatsGetData() local 100 int32_t ret = DelayedSingleton<NetStatsService>::GetInstance()->OnRemoteRequest(code, data, reply, option); in OnRemoteRequest() local
|
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/ |
H A D | ut_net_policy_client.cpp | 100 int32_t ret = g_netPolicyClient->SetPolicyByUid(TEST_UID, NetUidPolicy::NET_POLICY_ALLOW_METERED_BACKGROUND); in HWTEST_F() local 114 int32_t ret = g_netPolicyClient->GetPolicyByUid(TEST_UID, policy); in HWTEST_F() local 129 int32_t ret = g_netPolicyClient->GetUidsByPolicy(NetUidPolicy::NET_POLICY_ALLOW_METERED_BACKGROUND, uids); in HWTEST_F() local 143 int32_t ret = g_netPolicyClient->IsUidNetAllowed(TEST_UID, false, isAllowed); in HWTEST_F() local 159 int32_t ret = g_netPolicyClient->IsUidNetAllowed(TEST_UID, ifaceName, isAllowed); HWTEST_F() local 174 int32_t ret = g_netPolicyClient->IsUidNetAccess(TEST_UID, false, isAllowed); HWTEST_F() local 190 int32_t ret = g_netPolicyClient->IsUidNetAccess(TEST_UID, ifaceName, isAllowed); HWTEST_F() local 206 int32_t ret = g_netPolicyClient->SetNetQuotaPolicies(quotaPolicies); HWTEST_F() local 220 int32_t ret = g_netPolicyClient->SetNetQuotaPolicies(quotaPolicies); HWTEST_F() local 238 int32_t ret = g_netPolicyClient->SetNetQuotaPolicies(quotaPolicies); HWTEST_F() local 252 int32_t ret = g_netPolicyClient->GetNetQuotaPolicies(quotaPolicies); HWTEST_F() local 266 int32_t ret = g_netPolicyClient->SetFactoryPolicy(simId); HWTEST_F() local 279 int32_t ret = g_netPolicyClient->ResetPolicies(simId); HWTEST_F() local 291 int32_t ret = g_netPolicyClient->SetBackgroundPolicy(true); HWTEST_F() local 305 int32_t ret = g_netPolicyClient->GetBackgroundPolicy(backgroundPolicy); HWTEST_F() local 336 int32_t ret = g_netPolicyClient->SetSnoozePolicy(0, std::to_string(TRIGER_DELAY_US)); HWTEST_F() local 349 int32_t ret = HWTEST_F() local 363 int32_t ret = g_netPolicyClient->SetIdleTrustlist(TEST_UID, true); HWTEST_F() local 376 int32_t ret = g_netPolicyClient->SetDeviceIdleTrustlist({TEST_UID}, true); HWTEST_F() local 390 int32_t ret = g_netPolicyClient->GetIdleTrustlist(uids); HWTEST_F() local 404 int32_t ret = g_netPolicyClient->GetDeviceIdleTrustlist(uids); HWTEST_F() local 417 int32_t ret = g_netPolicyClient->SetDeviceIdlePolicy(true); HWTEST_F() local 468 int32_t ret = g_netPolicyClient->GetPowerSaveTrustlist(uids); HWTEST_F() local 483 int32_t ret = g_netPolicyClient->SetPowerSaveTrustlist(uids, isAllowed); HWTEST_F() local 497 int32_t ret = g_netPolicyClient->SetPowerSavePolicy(enable); HWTEST_F() local 510 int32_t ret = g_netPolicyClient->CheckPermission(); HWTEST_F() local [all...] |
/foundation/communication/dsoftbus/core/adapter/bus_center/src/ |
H A D | lnn_kv_adapter_wrapper.cpp | 309 int32_t ret = abilityManager->SubscribeSystemAbility(DISTRIBUTED_KV_DATA_SERVICE_ABILITY_ID, listener); in LnnSubcribeKvStoreService() local [all...] |
/foundation/communication/dsoftbus/core/bus_center/ipc/standard/src/ |
H A D | bus_center_client_proxy_standard.cpp | 251 int ret = remote->SendRequest(CLIENT_ON_NODE_ONLINE_STATE_CHANGED, data, reply, option); in OnNodeOnlineStateChanged() local 303 int ret = remote->SendRequest(CLIENT_ON_NODE_BASIC_INFO_CHANGED, data, reply, option); in OnNodeBasicInfoChanged() local 351 int32_t ret = remote->SendRequest(CLIENT_ON_NODE_STATUS_CHANGED, data, reply, option); in OnNodeStatusChanged() local 386 int32_t ret = remote->SendRequest(CLIENT_ON_LOCAL_NETWORK_ID_CHANGED, data, reply, option); OnLocalNetworkIdChanged() local 517 int ret = remote->SendRequest(CLIENT_ON_TIME_SYNC_RESULT, data, reply, option); OnTimeSyncResult() local 552 int ret = remote->SendRequest(CLIENT_ON_PUBLISH_LNN_RESULT, data, reply, option); OnPublishLNNResult() local 580 int ret = remote->SendRequest(CLIENT_ON_REFRESH_LNN_RESULT, data, reply, option); OnRefreshLNNResult() local 608 int ret = remote->SendRequest(CLIENT_ON_REFRESH_DEVICE_FOUND, data, reply, option); OnRefreshDeviceFound() local 637 int ret = remote->SendRequest(CLIENT_ON_DATA_LEVEL_CHANGED, data, reply, option); OnDataLevelChanged() local [all...] |
/foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/src/ |
H A D | lnn_devicename_info.c | 173 int32_t ret = EOK; in SetDisplayName() local 420 int32_t ret = LnnAsyncCallbackDelayHelper(GetLooper(LOOP_TYPE_DEFAULT), UpdataLocalFromSetting, NULL, 0); in AccountBootEventHandle() local 464 int ret = LnnAsyncCallbackDelayHelper(looper, UpdataLocalFromSetting, NULL, DELAY_LEN); in UpdataLocalFromSetting() local 519 int32_t ret = LnnRegSyncInfoHandler(LNN_INFO_TYPE_DEVICE_NAME, OnReceiveDeviceName); in LnnInitDevicename() local [all...] |
/foundation/communication/dsoftbus/core/common/dfx/event/src/ |
H A D | softbus_event.c | 52 int32_t ret = HiSysEvent_Write( in WriteHiSysEvent() local
|
/foundation/communication/dsoftbus/core/transmission/trans_channel/udp_negotiation/src/ |
H A D | trans_udp_channel_manager.c | 123 int32_t ret = RegisterTimeoutCallback(SOFTBUS_UDP_CHANNEL_TIMER_FUN, TransUdpTimerProc); in TransUdpChannelMgrInit() local 616 int32_t ret = SOFTBUS_OK; in ModifyUdpChannelTos() local 664 int32_t ret in UdpChannelFileTransLimit() local 673 int32_t ret = ModifyUdpChannelTos(tos); UdpChannelFileTransRecoveryLimit() local [all...] |
/foundation/communication/dsoftbus/sdk/transmission/session/cpp/src/ |
H A D | session_service_impl.cpp | 57 int32_t ret = CreateSessionServerInner(pkgName.c_str(), sessionName.c_str()); in CreateSessionServer() local 148 int32_t ret = IsServerSideInner(sessionId, &isServer); in CreateSession() local 185 int32_t ret = CreateSession(sessionId, session); OpenSessionCallback() local 271 int32_t ret = GetMySessionNameInner(sessionId, str, SESSION_NAME_SIZE_MAX); GetSessionListenerOnSessionOpened() local [all...] |
/foundation/communication/dsoftbus/sdk/transmission/trans_channel/proxy/src/ |
H A D | client_trans_proxy_file_helper.c | 44 int32_t ret = ClientTransProxyGetInfoByChannelId(channelId, &info); in ProxyChannelSendFileStream() local 66 int32_t ret = ProxyChannelSendFileStream(channelId, data, len, TRANS_SESSION_FILE_RESULT_FRAME); in SendFileTransResult() local 112 int32_t ret = ProxyChannelSendFileStream(channelId, data, len, type); in SendFileAckReqAndResData() local 207 int32_t ret = ProxyChannelSendFileStream(info->channelId, (char *)fileFrame->data, fileFrame->frameLength, PackReadFileRetransData() local 309 int32_t ret = RetransFileFrameBySeq(info, (int32_t)failSeq); AckResponseDataHandle() local 336 int32_t ret; GetFullRecvPath() local 438 int32_t ret; CreateDirAndGetAbsPath() local [all...] |
H A D | client_trans_proxy_file_common.c | 298 int32_t ret = fcntl(fd, isBlock ? F_SETLKW : F_SETLK, &fl); in FileLock() local
|
/foundation/communication/dsoftbus/tests/core/connection/tcp/ |
H A D | tcp_manager_test.cpp | 195 int32_t ret; in HWTEST_F() local 447 int32_t ret; in HWTEST_F() local 491 int32_t ret; HWTEST_F() local 534 int32_t ret; HWTEST_F() local 578 int32_t ret; HWTEST_F() local 844 int32_t ret = (port <= 0) ? SOFTBUS_INVALID_PARAM : SOFTBUS_OK; HWTEST_F() local 890 int32_t ret = SetIpTos(fd, tos); HWTEST_F() local 992 int32_t ret = (clientfd <= 0) ? SOFTBUS_INVALID_PARAM : SOFTBUS_OK; HWTEST_F() local 1032 int32_t ret = (clientfd <= 0) ? SOFTBUS_INVALID_PARAM : SOFTBUS_OK; HWTEST_F() local 1696 int32_t ret = (port <= 0) ? SOFTBUS_INVALID_PARAM : SOFTBUS_OK; HWTEST_F() local 1753 int32_t ret = TcpDisconnectDeviceNow(nullptr); HWTEST_F() local [all...] |
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/tcp_direct/unittest/ |
H A D | trans_core_tcp_direct_test.cpp | 148 int32_t ret = TransTcpDirectInit(cb); in HWTEST_F() local 169 int32_t ret = TransTcpDirectInit(cb); in HWTEST_F() local 223 int32_t ret = TransGetLaneInfo(¶m, &connInfo, &laneHandle); HWTEST_F() local 246 int32_t ret = TransSrvDataListInit(); HWTEST_F() local 262 int32_t ret = TransSrvDataListInit(); HWTEST_F() local 279 int32_t ret = TransSrvDataListInit(); HWTEST_F() local 300 int32_t ret = TransSrvDataListInit(); HWTEST_F() local 318 char *ret = VerifyP2pPack(g_ip, g_port, NULL); HWTEST_F() local 342 int32_t ret = VerifyP2pUnPack(json, peerIp, IP_LEN, &peerPort); HWTEST_F() local 364 char* ret = VerifyP2pPackError(code, errCode, "OnVerifyP2pRequest unpack fail"); HWTEST_F() local 384 int32_t ret = GetCipherFlagByAuthId(authHandle, &flag, &isAuthServer, isLegacyOs); HWTEST_F() local 412 int32_t ret = TransTdcStartSessionListener(DIRECT_CHANNEL_SERVER_P2P, &info); HWTEST_F() local 434 int32_t ret = TransTdcSetCallBack(cb); HWTEST_F() local 453 int32_t ret = TransSessionMgrInit(); HWTEST_F() local 482 int32_t ret = TransTdcAddSessionConn(conn); HWTEST_F() local 510 int32_t ret = TransSrvDataListInit(); HWTEST_F() local 530 int32_t ret = TransSessionMgrInit(); HWTEST_F() local 578 int32_t ret = TransSessionMgrInit(); HWTEST_F() local 622 int32_t ret = TransAddTcpChannelInfo(nullptr); HWTEST_F() local 635 int32_t ret = CreateTcpChannelInfoList(); HWTEST_F() local 655 int32_t ret = TransAddTcpChannelInfo(info); HWTEST_F() local [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/session/ |
H A D | client_trans_session_callback_test.cpp | 86 int32_t ret = TransClientInit(); in SetUpTestCase() local 238 int32_t ret = ClientAddSessionServer(SEC_TYPE_PLAINTEXT, g_pkgName, g_sessionName, &g_sessionlistener); in HWTEST_F() local 268 int32_t ret = GetSessionCallbackByChannelId(TRANS_TEST_INVALID_CHANNEL_ID, CHANNEL_TYPE_BUTT, HWTEST_F() local 309 int32_t ret = TestGenerateChannInfo(channel); HWTEST_F() local 344 int32_t ret = TestGenerateChannInfo(channel); HWTEST_F() local 377 int32_t ret = ClientAddSessionServer(SEC_TYPE_PLAINTEXT, g_pkgName, g_sessionName, &g_sessionlistener); HWTEST_F() local 405 int32_t ret = ProcessReceivedFileData(TRANS_TEST_SESSION_ID, TRANS_TEST_CHANNEL_ID, TRANS_TEST_AUTH_DATA, HWTEST_F() local 431 int32_t ret = TransOnDataReceived(TRANS_TEST_CHANNEL_ID, CHANNEL_TYPE_BUTT, TRANS_TEST_AUTH_DATA, HWTEST_F() local 482 int32_t ret = TransOnOnStreamRecevied(TRANS_TEST_CHANNEL_ID, CHANNEL_TYPE_BUTT, &data, &ext, ¶m); HWTEST_F() local 518 int32_t ret = ClientAddSessionServer(SEC_TYPE_PLAINTEXT, g_pkgName, g_sessionName, &sessionlistener); HWTEST_F() local 544 int32_t ret = TransOnQosEvent(TRANS_TEST_CHANNEL_ID, CHANNEL_TYPE_BUTT, TRANS_TEST_EVENT_ID, HWTEST_F() local 582 int32_t ret = ClientAddSessionServer(SEC_TYPE_PLAINTEXT, g_pkgName, g_sessionName, &sessionlistener); HWTEST_F() local 615 int32_t ret = ClientAddSessionServer(SEC_TYPE_PLAINTEXT, g_pkgName, g_sessionName, &sessionlistener); HWTEST_F() local 639 int32_t ret = TransOnDataReceived(TRANS_TEST_CHANNEL_ID, CHANNEL_TYPE_BUTT, TRANS_TEST_AUTH_DATA, HWTEST_F() local 692 int32_t ret = HandleAsyncBindSuccess(1, NULL, &lifecycle); HWTEST_F() local 707 int32_t ret = HandleSyncBindSuccess(1, &lifecycle); HWTEST_F() local [all...] |
H A D | client_trans_message_service_test.cpp | 89 int32_t ret = TransClientInit(); in SetUpTestCase() local 190 int32_t ret = ClientAddSessionServer(SEC_TYPE_PLAINTEXT, g_pkgName, sessionName, &g_sessionlistener); in AddSessionServerAndSession() local 221 int32_t ret = ClientDeleteSession(sessionId); DeleteSessionServerAndSession() local 235 int32_t ret = CheckSendLen(CHANNEL_TYPE_BUTT, BUSINESS_TYPE_MESSAGE, TRANS_TEST_SEND_LEN, BUSINESS_TYPE_MESSAGE); HWTEST_F() local 254 int32_t ret = SendBytes(sessionId, TRANS_TEST_AUTH_DATA, 0); HWTEST_F() local 298 int32_t ret = SendMessage(sessionId, TRANS_TEST_AUTH_DATA, 0); HWTEST_F() local 353 int32_t ret = SendStream(sessionId, &data, &ext, &streamFrameInfo); HWTEST_F() local 398 int32_t ret = SendFile(sessionId, sFileList, dFileList, TRANS_TEST_FILE_COUNT); HWTEST_F() local [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/ |
H A D | stream_encrypt_client_mt.cpp | 40 int32_t ret = TestInit(); in SetUpTestCase() local 49 int32_t ret = TestDeInit(); in TearDownTestCase() local 133 int32_t ret = Bind(socket, qosInfo, sizeof(qosInfo) / sizeof(qosInfo[0]), &g_listener); in HWTEST_F() local 186 int32_t ret = Bind(socket, qosInfo, sizeof(qosInfo) / sizeof(qosInfo[0]), &g_listener); HWTEST_F() local 300 int32_t ret = CreateSessionServer(PKG_NAME, TEST_SESSION_NAME, &sessionListener); HWTEST_F() local [all...] |
H A D | tmessenger.cpp | 180 int32_t ret = Listen(socket, qosInfo, sizeof(qosInfo) / sizeof(qosInfo[0]), &listener); in StartListen() local 225 int32_t ret = Bind(socket, qosInfo, sizeof(qosInfo) / sizeof(qosInfo[0]), &listener); in StartConnect() local 318 int32_t ret = Send(msg); QueryResult() local 335 int32_t ret = SendMessage(socket_, data.c_str(), data.size()); Send() local [all...] |
/foundation/communication/ipc/ipc/native/test/unittest/common/ |
H A D | ipc_process_skeleton_unittest.cpp | 110 bool ret = skeleton->SetMaxWorkThread(-1); in HWTEST_F() local 124 bool ret = skeleton->SetMaxWorkThread(1); in HWTEST_F() local 139 bool ret = skeleton->SetRegistryObject(object); in HWTEST_F() local 154 bool ret = skeleton->SetRegistryObject(object); in HWTEST_F() local 171 bool ret = skeleton->SpawnThread(policy, proto); in HWTEST_F() local 188 bool ret = skeleton->SpawnThread(policy, proto); HWTEST_F() local 204 bool ret = skeleton->OnThreadTerminated(threadName); HWTEST_F() local 250 bool ret = skeleton->IsContainsObject(object.GetRefPtr()); HWTEST_F() local 268 bool ret = skeleton->IsHandleMadeByUser(handler); HWTEST_F() local 284 bool ret = skeleton->IsHandleMadeByUser(handler); HWTEST_F() local 303 uint32_t ret = skeleton->GetDBinderIdleHandle(remoteSession); HWTEST_F() local 323 uint32_t ret = skeleton->GetDBinderIdleHandle(remoteSession); HWTEST_F() local 344 uint32_t ret = skeleton->GetDBinderIdleHandle(remoteSession); HWTEST_F() local 364 bool ret = skeleton->ProxyAttachDBinderSession(handler, object); HWTEST_F() local 386 auto ret = skeleton->ProxyQueryDBinderSession(handler); HWTEST_F() local 409 auto ret = skeleton->QueryProxyBySocketId(handler, proxyHandle); HWTEST_F() local 432 auto ret = skeleton->QueryHandleByDatabusSession(name, deviceId, index); HWTEST_F() local 455 auto ret = skeleton->QuerySessionByInfo(name, deviceId); HWTEST_F() local 475 auto ret = skeleton->QueryThreadLockInfo(threadId); HWTEST_F() local 492 bool ret = skeleton->DeleteDataThreadFromIdle(threadId); HWTEST_F() local 525 int ret = skeleton->GetSocketIdleThreadNum(); HWTEST_F() local 541 int ret = skeleton->GetSocketTotalThreadNum(); HWTEST_F() local 561 auto ret = skeleton->PopDataInfoFromThread(threadId); HWTEST_F() local 609 auto ret = skeleton->QueryThreadBySeqNumber(seqNumber); HWTEST_F() local 763 bool ret = skeleton->AddSendThreadInWait(seqNumber, messageInfo, userWaitTime); HWTEST_F() local 795 bool ret = skeleton->AddSendThreadInWait(seqNumber, messageInfo, userWaitTime); HWTEST_F() local 823 bool ret = skeleton->AddSendThreadInWait(seqNumber, messageInfo, userWaitTime); HWTEST_F() local 852 bool ret = skeleton->AddSendThreadInWait(seqNumber, messageInfo, userWaitTime); HWTEST_F() local 872 auto ret = skeleton->QueryStubByIndex(stubIndex); HWTEST_F() local 889 auto ret = skeleton->QueryStubByIndex(stubIndex); HWTEST_F() local 910 auto ret = skeleton->AddStubByIndex(stubObject.GetRefPtr()); HWTEST_F() local 934 uint64_t ret = 0; HWTEST_F() local 958 uint64_t ret = 10; HWTEST_F() local 978 uint64_t ret = skeleton->EraseStubIndex(stubObject.GetRefPtr()); HWTEST_F() local 996 uint64_t ret = skeleton->EraseStubIndex(stubObject.GetRefPtr()); HWTEST_F() local 1025 bool ret = skeleton->DetachAppInfoToStubIndex(pid, uid, tokenId, deviceId, stubIndex, listenFd); HWTEST_F() local 1054 bool ret = skeleton->DetachAppInfoToStubIndex(pid, uid, tokenId, deviceId, index, listenFd); HWTEST_F() local 1082 auto ret = skeleton->DetachAppInfoToStubIndex(pid, uid, tokenId, deviceId, listenFd); HWTEST_F() local 1105 bool ret = skeleton->DetachAppInfoToStubIndex(pid, uid, tokenId, deviceId, index, listenFd); HWTEST_F() local 1192 bool ret = skeleton->AttachAppInfoToStubIndex(pid, uid, tokenId, deviceId, stubIndex, listenFd); HWTEST_F() local 1220 bool ret = skeleton->AttachAppInfoToStubIndex(pid, uid, tokenId, deviceId, stubIndex, listenFd); HWTEST_F() local 1239 bool ret = skeleton->DetachCallbackStub(objectProxy.GetRefPtr()); HWTEST_F() local 1258 bool ret = skeleton->DetachCallbackStub(objectProxy.GetRefPtr()); HWTEST_F() local 1276 auto ret = skeleton->QueryCallbackProxy(objectStub.GetRefPtr()); HWTEST_F() local 1295 auto ret = skeleton->QueryCallbackProxy(objectStub.GetRefPtr()); HWTEST_F() local 1314 auto ret = skeleton->QueryCallbackProxy(objectStub.GetRefPtr()); HWTEST_F() local 1330 auto ret = skeleton->CreateSoftbusServer(name); HWTEST_F() local 1348 auto ret = skeleton->QueryRawData(fd); HWTEST_F() local 1364 auto ret = skeleton->QueryRawData(fd); HWTEST_F() local 1386 bool ret = skeleton->IsSameRemoteObject(stubObject.GetRefPtr(), pid, uid, tokenId, deviceId, auth); HWTEST_F() local 1408 bool ret = skeleton->IsSameRemoteObject(nullptr, pid, uid, tokenId, deviceId, auth); HWTEST_F() local 1430 bool ret = skeleton->IsSameRemoteObject(stubObject.GetRefPtr(), 0, uid, tokenId, deviceId, auth); HWTEST_F() local 1452 bool ret = skeleton->IsSameRemoteObject(stubObject.GetRefPtr(), pid, 0, tokenId, deviceId, auth); HWTEST_F() local 1474 bool ret = skeleton->IsSameRemoteObject(stubObject.GetRefPtr(), pid, uid, 0, deviceId, auth); HWTEST_F() local 1496 bool ret = skeleton->IsSameRemoteObject(stubObject.GetRefPtr(), pid, uid, tokenId, "testdeviceId", auth); HWTEST_F() local 1520 bool ret = skeleton->AttachCommAuthInfo(stubObject.GetRefPtr(), pid, uid, tokenId, deviceId); HWTEST_F() local 1542 bool ret = skeleton->AttachCommAuthInfo(stubObject.GetRefPtr(), pid, uid, tokenId, deviceId); HWTEST_F() local 1566 bool ret = skeleton->QueryCommAuthInfo(pid, uid, tokenId, deviceId); HWTEST_F() local 1592 bool ret = skeleton->QueryCommAuthInfo(0, uid, tokenId, deviceId); HWTEST_F() local 1614 auto ret = skeleton->QueryDBinderCallbackStub(objectProxy); HWTEST_F() local 1632 auto ret = skeleton->QueryDBinderCallbackStub(objectProxy); HWTEST_F() local 1652 auto ret = skeleton->QueryDBinderCallbackStub(object); HWTEST_F() local 1671 auto ret = skeleton->QueryDBinderCallbackProxy(object); HWTEST_F() local 1687 auto ret = skeleton->ProxyQueryDBinderSession(handler); HWTEST_F() local 1711 auto ret = skeleton->QueryHandleByDatabusSession(name, deviceId, index); HWTEST_F() local 1736 auto ret = skeleton->QuerySessionByInfo(name, deviceIdTest); HWTEST_F() local 1754 auto ret = skeleton->QuerySessionByInfo(name, deviceId); HWTEST_F() local 1772 auto ret = skeleton->QueryThreadLockInfo(threadId); HWTEST_F() local 1789 bool ret = skeleton->DeleteDataThreadFromIdle(threadId); HWTEST_F() local 1805 auto ret = skeleton->GetIdleDataThread(); HWTEST_F() local 1821 auto ret = skeleton->GetSocketIdleThreadNum(); HWTEST_F() local 1837 auto ret = skeleton->GetSocketTotalThreadNum(); HWTEST_F() local 1859 auto ret = skeleton->PopDataInfoFromThread(threadId); HWTEST_F() local 1875 auto ret = skeleton->QueryThreadBySeqNumber(seqNumber); HWTEST_F() local [all...] |
/foundation/communication/netmanager_base/services/netstatsmanager/src/ |
H A D | net_stats_cached.cpp | 42 auto ret = helper->CreateTable(VERSION_TABLE, VERSION_TABLE_CREATE_PARAM); in StartCached() local 374 int32_t ret in LoadIfaceNameIdentMaps() local 405 auto ret = NetsysController::GetInstance().DeleteStatsInfo(uid); ForceDeleteStats() local [all...] |
/foundation/communication/dsoftbus/core/transmission/ipc/standard/src/ |
H A D | trans_client_proxy_standard.cpp | 47 int32_t ret = remote->SendRequest(CLIENT_ON_PERMISSION_CHANGE, data, reply, option); in OnClientPermissonChange() local 129 int32_t ret = remote->SendRequest(CLIENT_ON_TRANS_LIMIT_CHANGE, data, reply, option); in OnClientTransLimitChange() local 148 int32_t ret in OnChannelOpened() local 185 int32_t ret = remote->SendRequest(CLIENT_ON_CHANNEL_BIND, data, reply, option); OnChannelBind() local 213 int32_t ret = remote->SendRequest(CLIENT_ON_CHANNEL_OPENFAILED, data, reply, option); OnChannelOpenFailed() local 240 int32_t ret = remote->SendRequest(CLIENT_ON_CHANNEL_LINKDOWN, data, reply, option); OnChannelLinkDown() local 266 int32_t ret = remote->SendRequest(CLIENT_ON_CHANNEL_CLOSED, data, reply, option); OnChannelClosed() local 298 int32_t ret = remote->SendRequest(CLIENT_ON_CHANNEL_MSGRECEIVED, data, reply, option); OnChannelMsgReceived() local 329 int32_t ret = remote->SendRequest(CLIENT_ON_CHANNEL_QOSEVENT, data, reply, option); OnChannelQosEvent() local 366 int32_t ret = remote->SendRequest(CLIENT_SET_CHANNEL_INFO, data, reply, option); SetChannelInfo() local [all...] |
/foundation/communication/dsoftbus/tests/core/connection/manager/ |
H A D | connection_manager_test.cpp | 42 unsigned int ret = type << SHIFT_BITS; in ObjectGetConnectionId() local 209 int ret; in HWTEST_F() local 236 int32_t ret; HWTEST_F() local 257 int ret; HWTEST_F() local 311 int ret; HWTEST_F() local 358 int ret; HWTEST_F() local 384 int32_t ret; HWTEST_F() local 433 int ret = ConnSetConnectCallback((ConnModule)moduleIdMin, &connCb); HWTEST_F() local 459 int ret = ConnConnectDevice(nullptr, reqId, &connRet); HWTEST_F() local 483 int ret = ConnStartLocalListening(&info); HWTEST_F() local 499 int ret = ConnStopLocalListening(&info); HWTEST_F() local 513 int ret = ConnTypeIsSupport(CONNECT_TYPE_MAX); HWTEST_F() local [all...] |
/foundation/communication/dsoftbus/tests/core/transmission/trans_channel/proxy_channel/ |
H A D | trans_proxy_message_test.cpp | 107 int32_t ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); in TestMessageAddProxyChannel() local 131 int32_t ret = TransProxySetCallBack(&cb); in TestCallbackSuccess() local 139 int32_t ret = TransProxySetCallBack(&cb); in TestCallbackFail() local 154 int32_t ret = TransProxyUnPackHandshakeErrMsg(msg, nullptr, sizeof(msg)); in HWTEST_F() local 171 int32_t ret = SOFTBUS_OK; HWTEST_F() local 212 int32_t ret = TransProxyUnpackHandshakeAckMsg(msg, &outChannel, sizeof(msg)); HWTEST_F() local 231 int32_t ret = SOFTBUS_MEM_ERR; HWTEST_F() local 242 int32_t ret = TransProxyUnpackHandshakeMsg(msg, &outChannel, sizeof(msg)); HWTEST_F() local 274 int32_t ret = TransProxyUnpackHandshakeMsg(msg, &outChannel, sizeof(msg)); HWTEST_F() local 305 int32_t ret = TransProxyUnpackHandshakeMsg(msg, &outChannel, sizeof(msg)); HWTEST_F() local 325 int32_t ret = TransProxyUnpackIdentity(msg, identity, TEST_CHANNEL_IDENTITY_LEN, sizeof(msg)); HWTEST_F() local 341 int32_t ret = TransProxyPackMessage(NULL, authHandle, &dataInfo); HWTEST_F() local 395 int32_t ret = TransProxyPackMessage(&msg, authId, &dataInfo); HWTEST_F() local 423 int32_t ret = TransProxyParseMessage(buf, PROXY_CHANNEL_HEAD_LEN, &msg); HWTEST_F() local 481 int32_t ret = TransProxyParseMessage(buf, len, &outMsg); HWTEST_F() local 530 int32_t ret = TransProxyParseMessage(buf, len, &outMsg); HWTEST_F() local 571 int32_t ret = TransProxySendMessage(NULL, payLoad, payLoadLen, priority); HWTEST_F() local 602 int32_t ret = SOFTBUS_OK; HWTEST_F() local 665 int32_t ret = TransProxyAckHandshake(connId, NULL, retCode); HWTEST_F() local 719 int32_t ret = TransProxyAckKeepalive(NULL); HWTEST_F() local 743 int32_t ret = TransProxyResetPeer(NULL); HWTEST_F() local [all...] |
H A D | trans_proxy_session_test.cpp | 149 int32_t ret = TransProxyCreateChanInfo(chan, chan->channelId, &appInfo); in TestAddProxyChannel() local 162 int32_t ret = SOFTBUS_MEM_ERR; in HWTEST_F() local 197 int32_t ret = TransProxyPostSessionData(channelId, (const unsigned char *)data, len, TRANS_SESSION_MESSAGE); in HWTEST_F() local 213 int32_t ret = SOFTBUS_OK; HWTEST_F() local 256 int32_t ret = TransOnNormalMsgReceived(pkgName, pid, channelId, NULL, len); HWTEST_F() local 286 int32_t ret = SOFTBUS_OK; HWTEST_F() local 349 int32_t ret = SOFTBUS_OK; HWTEST_F() local 407 int32_t ret = SOFTBUS_OK; HWTEST_F() local 455 int32_t ret = TransOnNormalMsgReceived(pkgName, pid, channelId, buf, len); HWTEST_F() local 481 int32_t ret = TransOnAuthMsgReceived(pkgName, pid, channelId, NULL, 0); HWTEST_F() local 501 int32_t ret = TransProxyDelSliceProcessorByChannelId(channelId); HWTEST_F() local [all...] |