/foundation/communication/dsoftbus/tests/sdk/transmission/session/ |
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...] |
H A D | softbus_trans_proxy_transceiver_test.cpp | 81 int32_t ret = TransProxyOpenConnChannel(nullptr, &connInfo, &channelId); in HWTEST_F() local 132 int32_t ret = TransProxyOpenConnChannel(&appInfo, &connInfo, &channelId); HWTEST_F() local 156 int32_t ret = TransProxyCloseConnChannel(1, isServer); HWTEST_F() local 177 int32_t ret = TransProxyCloseConnChannelReset(2, false, isServer, false); HWTEST_F() local 195 int32_t ret = TransProxyGetConnInfoByConnId(3, NULL); HWTEST_F() local 217 int32_t ret = TransProxyTransSendMsg(connectionId, buf, len, priority, pid); HWTEST_F() local 236 bool ret = false; HWTEST_F() local 300 int32_t ret = TransProxyConnExistProc(&conn, &chan, chanNewId); HWTEST_F() local 319 int32_t ret = TransProxyConnectDevice(&connInfo, reqId); HWTEST_F() local 339 int32_t ret = TransProxyOpenNewConnChannel(moduleId, &connInfo, channelId); HWTEST_F() local 351 int32_t ret = TransProxyTransInit(); HWTEST_F() local 366 int32_t ret = TransDelConnByReqId(reqId); HWTEST_F() local 384 int32_t ret = TransDelConnByReqId(reqId); HWTEST_F() local 451 int32_t ret = TransDecConnRefByConnId(connId1, true); HWTEST_F() local 477 int32_t ret = TransAddConnRefByConnId(connId, true); HWTEST_F() local 508 int32_t ret = TransAddConnItem(&chan); HWTEST_F() local 593 int32_t ret = TransGetConn(&connectOption2, connChan2, false); HWTEST_F() local 615 int32_t ret = TransGetConn(&connInfo, &proxyConn, isServer); HWTEST_F() local 645 int32_t ret = TransProxySendBadKeyMessage(&msg, &authHandle); HWTEST_F() local 699 SoftBusMessage *ret = TransProxyCreateLoopMsg(LOOP_RESETPEER_MSG, 0, HWTEST_F() local [all...] |
H A D | trans_proxy_channel_test.cpp | 167 int32_t ret = SetCipherOfHandshakeMsg(chan, NULL); in HWTEST_F() local 189 int32_t ret = SetCipherOfHandshakeMsg(chan, NULL); in HWTEST_F() local 203 int32_t ret = TransProxyHandshake(NULL); in HWTEST_F() local 241 int32_t ret = TransProxyAckHandshake(0, NULL, SOFTBUS_NO_INIT); HWTEST_F() local 271 int32_t ret = strcpy_s(info.identity, sizeof(info.identity), TEST_CHANNEL_INDENTITY); HWTEST_F() local 298 int32_t ret = strcpy_s(info.identity, sizeof(info.identity), TEST_CHANNEL_INDENTITY); HWTEST_F() local 325 int32_t ret = TransProxyAckKeepalive(NULL); HWTEST_F() local 356 int32_t ret = TransProxyAckKeepalive(&info); HWTEST_F() local 379 int32_t ret = TransProxyResetPeer(&info); HWTEST_F() local 401 int32_t ret = TransProxyResetPeer(&info); HWTEST_F() local 426 int32_t ret = TransProxyAddChanItem(NULL); HWTEST_F() local 448 int32_t ret = strcpy_s(info.identity, sizeof(info.identity), TEST_CHANNEL_INDENTITY); HWTEST_F() local 480 int32_t ret = strcpy_s(info.identity, sizeof(info.identity), TEST_CHANNEL_INDENTITY); HWTEST_F() local 515 int32_t ret = TransProxyCreateChanInfo(info, 1, &appInfo); HWTEST_F() local 537 int32_t ret = TransProxyManagerInitInner(&callBack); HWTEST_F() local 553 int32_t ret = TransProxyManagerInitInner(&callBack); HWTEST_F() local 573 int32_t ret = TransProxyManagerInitInner(&callBack); HWTEST_F() local 590 int32_t ret = TransProxyManagerInitInner(&callBack); HWTEST_F() local 609 int32_t ret = TransProxyParseMessage(data, len, &msg, &authHandle); HWTEST_F() local 633 int32_t ret = TransGetConnByChanId(channelId, 0, &connId); HWTEST_F() local 657 int32_t ret = TransProxySendInnerMessage(nullptr, TEST_PAY_LOAD, payLoadLen, priority); HWTEST_F() local 675 AuthLinkType ret = ConvertConnectType2AuthLinkType(type); HWTEST_F() local [all...] |
H A D | softbus_proxy_session_test.cpp | 144 int32_t ret = SOFTBUS_INVALID_PARAM; in HWTEST_F() local 171 int32_t ret = TransProxyPostSessionData(channelId, (const unsigned char *)data, len, TRANS_SESSION_MESSAGE); in HWTEST_F() local 187 int32_t ret = SOFTBUS_OK; HWTEST_F() local 237 int32_t ret = TransOnNormalMsgReceived(pkgName, pid, channelId, NULL, len); HWTEST_F() local 267 int32_t ret = SOFTBUS_OK; HWTEST_F() local 327 int32_t ret = SOFTBUS_OK; HWTEST_F() local 375 int32_t ret = SOFTBUS_OK; HWTEST_F() local 419 int32_t ret = TransOnNormalMsgReceived(pkgName, pid, channelId, buf, len); HWTEST_F() local 446 int32_t ret = NotifyClientMsgReceived(pkgName, pid, channelId, &receiveData); HWTEST_F() local [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/ipc/ |
H A D | trans_ipc_test.cpp | 85 int32_t ret = transServerProxy.SoftbusRegisterService(g_pkgName, nullptr); in HWTEST_F() local 110 int32_t ret = transServerProxy.JoinLNN(g_pkgName, (void *)g_addr, addrTypeLen); in HWTEST_F() local 144 int32_t ret = transServerProxy.CreateSessionServer(nullptr, g_sessionName); HWTEST_F() local 163 int32_t ret = transServerProxy.RemoveSessionServer(nullptr, g_sessionName); HWTEST_F() local 193 int32_t ret = transServerProxy.OpenSession(param, info); HWTEST_F() local 237 int32_t ret = transServerProxy.OpenAuthSession(nullptr, addrInfo); HWTEST_F() local 259 int32_t ret = transServerProxy.NotifyAuthSuccess(channelId, channelType); HWTEST_F() local 278 int32_t ret = transServerProxy.CloseChannel(nullptr, channelId, channelType); HWTEST_F() local 296 int32_t ret = transServerProxy.SendMessage(channelId, channelType, (const void *)dataInfo, len, msgType); HWTEST_F() local 316 int32_t ret = transServerProxy.QosReport(channelId, channelType, appType, quality); HWTEST_F() local 339 int32_t ret = transServerProxy.StreamStats(channelId, channelType, nullptr); HWTEST_F() local 363 int32_t ret = transServerProxy.RippleStats(channelId, channelType, nullptr); HWTEST_F() local 381 int32_t ret = transServerProxy.GrantPermission(UUID, PID, nullptr); HWTEST_F() local 397 int32_t ret = transServerProxy.RemovePermission(g_sessionName); HWTEST_F() local 412 int32_t ret = ServerIpcCreateSessionServer(g_pkgName, g_sessionName); HWTEST_F() local 438 int32_t ret = ServerIpcRemoveSessionServer(g_pkgName, g_sessionName); HWTEST_F() local 477 int32_t ret = ServerIpcOpenSession(param, info); HWTEST_F() local 529 int32_t ret = ServerIpcOpenAuthSession(g_sessionName, addrInfo); HWTEST_F() local 556 int32_t ret = TransServerProxyInit(); HWTEST_F() local 576 int32_t ret = ServerIpcCloseChannel(nullptr, channelId, chanType); HWTEST_F() local 605 int32_t ret = ServerIpcCloseChannelWithStatistics(channelId, channelType, laneId, (void *)dataInfo, length); HWTEST_F() local 619 int32_t ret = ServerIpcSendMessage(channelId, chanType, nullptr, 0, 0); HWTEST_F() local 643 int32_t ret = ServerIpcQosReport(channelId, chanType, appType, quality); HWTEST_F() local 665 int32_t ret = ServerIpcStreamStats(channelId, chanType, nullptr); HWTEST_F() local 687 int32_t ret = ServerIpcRippleStats(channelId, chanType, nullptr); HWTEST_F() local 709 int32_t ret = ServerIpcGrantPermission(uid, pid, nullptr); HWTEST_F() local 732 int32_t ret = ServerIpcRemovePermission(nullptr); HWTEST_F() local 760 int32_t ret = ServerIpcEvaluateQos(nullptr, type, qos, qosCount); HWTEST_F() local [all...] |
/foundation/communication/ipc/ipc/native/src/core/source/ |
H A D | dbinder_callback_stub.cpp | 252 auto ret = memcpy_s(dbinderData->target_name, SESSION_NAME_LENGTH, serviceName_.c_str(), in SaveDBinderData() local 294 int ret = AddDBinderCommAuth(pid, uid, sessionName); in GetAndSaveDBinderData() local [all...] |
H A D | databus_socket_listener.cpp | 158 int32_t ret = DBinderSoftbusClient::GetInstance().Listen(socketId, QOS_TV, QOS_COUNT, &serverListener_); in StartServerListener() local 217 int32_t ret = DBinderSoftbusClient::GetInstance().Bind(socketId, QOS_TV, QOS_COUNT, &clientListener_); in CreateClientSocket() local [all...] |
/foundation/communication/netmanager_base/frameworks/native/netstatsclient/src/proxy/ |
H A D | net_stats_service_proxy.cpp | 41 int32_t ret = NETMANAGER_SUCCESS; in SendRequest() local 492 int32_t ret = in GetTrafficStatsByUidNetwork() local 518 int32_t ret = SendRequest(static_cast<uint32_t>(StatsInterfaceCode::CMD_SET_APP_STATS), data, reply); SetAppStats() local [all...] |
/foundation/communication/netmanager_base/test/netconnmanager/unittest/net_conn_add_test/ |
H A D | router_advertisement_daemon_test.cpp | 63 auto ret = routerAdvertiseDaemon.StartRa(); in HWTEST_F() local 79 auto ret = routerAdvertiseDaemon.CreateRASocket(); in HWTEST_F() local 112 auto ret = routerAdvertiseDaemon.MaybeSendRa(dest); in HWTEST_F() local
|
/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_distributed_test/ |
H A D | netsys_controller_test.cpp | 108 int32_t ret = NetsysController::GetInstance().EnableDistributedClientNet(virnicAddr, iif); in HWTEST_F() local 124 int32_t ret = NetsysController::GetInstance().EnableDistributedServerNet(iif, devIface, dstAddr); in HWTEST_F() local [all...] |
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/ |
H A D | ut_net_policy_traffic.cpp | 259 int32_t ret = g_netPolicyTraffic->ResetPolicies(ICCID_1); in HWTEST_F() local 285 auto ret = g_netPolicyTraffic->ResetPolicies(); in HWTEST_F() local 312 auto ret = g_netPolicyTraffic->UpdateQuotaPoliciesInner(); in HWTEST_F() local 327 auto ret = g_netPolicyTraffic->GetQuotaRemain(quotaPolicy); in HWTEST_F() local 352 auto ret = g_netPolicyTraffic->IsValidQuotaPolicy(quotaPolicy); in HWTEST_F() local 386 auto ret = g_netPolicyTraffic->UpdateMeteredIfacesQuota(); HWTEST_F() local 400 auto ret = g_netPolicyTraffic->IsValidQuotaPolicy(quotaPolicy); HWTEST_F() local 414 auto ret = g_netPolicyTraffic->IsValidQuotaPolicy(quotaPolicy); HWTEST_F() local 439 auto ret = g_netPolicyTraffic->GetTotalQuota(quotaPolicy); HWTEST_F() local 456 auto ret = g_netPolicyTraffic->WriteQuotaPolicies(); HWTEST_F() local 470 auto ret = g_netPolicyTraffic->GetMatchIfaces(quotaPolicy); HWTEST_F() local 483 auto ret = g_netPolicyTraffic->GetMatchIfaces(quotaPolicy); HWTEST_F() local 496 auto ret = g_netPolicyTraffic->GetMatchIfaces(quotaPolicy); HWTEST_F() local 513 auto ret = g_netPolicyTraffic->IsValidNetType(BEARER_DEFAULT); HWTEST_F() local 525 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 537 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 549 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 561 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 573 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 585 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 597 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 609 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 621 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 633 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 645 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local 657 auto ret = g_netPolicyTraffic->IsValidPeriodDuration(periodDuration); HWTEST_F() local [all...] |
H A D | ut_net_policy_rule.cpp | 308 bool ret = g_netPolicyRule->IsValidNetPolicy(INVALID_VALUE); in HWTEST_F() local
|
/foundation/communication/dsoftbus/core/common/dfx/statistics/ |
H A D | trans_network_statistics.c | 156 bool ret = false; in IsChannelDfxInfoValid() local
|
/foundation/communication/dsoftbus/core/transmission/trans_channel/proxy/src/ |
H A D | softbus_proxychannel_listener.c | 41 int32_t ret = TransProxyOnChannelClosed(pkgName, pid, channelId); in NotifyNormalChannelClosed() local 48 int32_t ret = TransProxyOnChannelOpenFailed(pkgName, pid, channelId, errCode); in NotifyNormalChannelOpenFailed() local 89 int32_t ret = SOFTBUS_ERR; in NotifyNormalChannelOpened() local 136 int32_t ret = SOFTBUS_TRANS_PROXY_ERROR_APP_TYPE; OnProxyChannelOpened() local 219 int32_t ret = SOFTBUS_TRANS_PROXY_ERROR_APP_TYPE; OnProxyChannelBind() local 322 int32_t ret = SOFTBUS_TRANS_PROXY_ERROR_APP_TYPE; OnProxyChannelClosed() local 341 int32_t ret = SOFTBUS_OK; OnProxyChannelMsgReceived() local 363 int ret = SOFTBUS_TRANS_GET_APP_INFO_FAILED; TransProxyGetAppInfo() local 480 int32_t ret = TransProxyGetSendMsgChanInfo(channelId, info); TransSendNetworkingMessage() local [all...] |
/foundation/communication/dsoftbus/tests/core/bus_center/lnn/lane_listener/ |
H A D | lnn_lane_listener_test.cpp | 119 int32_t ret = InitLaneListener(); in HWTEST_F() local 132 int32_t ret = laneManager->registerLaneListener(LANE_TYPE_BUTT, &g_listener); in HWTEST_F() local 160 int32_t ret = laneManager->registerLaneListener(LANE_TYPE_TRANS, &g_listener); HWTEST_F() local 185 bool ret = LaneTypeCheck(type); HWTEST_F() local 201 LaneBusinessInfo *ret = GetLaneBusinessInfoWithoutLock(nullptr); HWTEST_F() local 227 int32_t ret = AddLaneBusinessInfoItem(LANE_TYPE_BUTT, INVALID_LANE_ID); HWTEST_F() local 257 int32_t ret = AddLaneBusinessInfoItem(LANE_TYPE_TRANS, LANE_ID_P2P); HWTEST_F() local 306 int32_t ret = FindLaneBusinessInfoByLinkInfo(nullptr, &resNum, laneBusinessInfo, LANE_TYPE_BUTT); HWTEST_F() local 347 LaneListenerInfo *ret = LaneListenerIsExist(LANE_TYPE_TRANS); HWTEST_F() local 379 int32_t ret = FindLaneListenerInfoByLaneType(LANE_TYPE_BUTT, nullptr); HWTEST_F() local 410 int32_t ret = GetStateNotifyInfo(nullptr, PEER_UUID, &laneLinkInfo); HWTEST_F() local 449 int32_t ret = LaneLinkupNotify(nullptr, &linkInfo); HWTEST_F() local 508 int32_t ret = LaneLinkdownNotify(nullptr, &linkInfo); HWTEST_F() local 555 int32_t ret = laneManager->registerLaneListener(LANE_TYPE_TRANS, &g_listener); HWTEST_F() local [all...] |
/foundation/communication/dsoftbus/tests/core/bus_center/lnn/net_buscenter/ |
H A D | lnn_network_manager_test.cpp | 128 int32_t ret = LnnInitNetworkManager(); in HWTEST_F() local 150 int32_t ret = LnnGetAddrTypeByIfName(nullptr, nullptr); HWTEST_F() local 183 int32_t ret = LnnRegistProtocol(nullptr); HWTEST_F() local 242 bool ret = LnnIsAutoNetWorkingEnabled(); HWTEST_F() local 353 LnnNetIfMgr *ret = CreateNetifMgr(netIfName); HWTEST_F() local 390 LnnNetIfMgr *ret = CreateNetifMgr(nullptr); HWTEST_F() local 457 VisitNextChoice ret = GetAllProtocols(nullptr, data); HWTEST_F() local 529 int32_t ret = RegistNetIfMgr(type, builder); HWTEST_F() local 587 int32_t ret = SOFTBUS_OK; HWTEST_F() local [all...] |
/foundation/communication/dsoftbus/tests/sdk/transmission/trans_channel/udp/stream/libsoftbus_stream/vtp_stream_socket_test/ |
H A D | vtp_stream_socket_test.cpp | 85 bool ret = vtpStreamSocket->CreateClient(*local, streamType, sessionKey); in HWTEST_F() local 124 bool ret = vtpStreamSocket->CreateClient(*local, *remote, streamType, sessionKey); in HWTEST_F() local 152 bool ret = vtpStreamSocket->CreateServer(*local, streamType, sessionKey); in HWTEST_F() local 197 bool ret = vtpStreamSocket->Connect(*remote); HWTEST_F() local 258 bool ret = vtpStreamSocket->SetOption(type, *value); HWTEST_F() local 307 int32_t ret = value->GetIntValue(); HWTEST_F() local 329 bool ret = vtpStreamSocket->SetStreamListener(nullptr); HWTEST_F() local 403 int32_t ret = ret = value->intVal_; HWTEST_F() local 459 bool ret = vtpStreamSocket->SetStreamScene(type, *value); HWTEST_F() local 488 bool ret = vtpStreamSocket->SetStreamHeaderSize(type, *value); HWTEST_F() local 524 bool ret = vtpStreamSocket->EnableBwEstimationAlgo(type, isServer); HWTEST_F() local 540 bool ret = vtpStreamSocket->EnableJitterDetectionAlgo(type); HWTEST_F() local 556 bool ret = vtpStreamSocket->EnableDirectlySend(type); HWTEST_F() local 574 bool ret = vtpStreamSocket->EnableSemiReliable(type); HWTEST_F() local 598 int32_t ret = vtpStreamSocket->FillpStatistics(fd, nullptr); HWTEST_F() local 652 int32_t ret = vtpStreamSocket->HandleFillpFrameStats(fd, nullptr); HWTEST_F() local 724 bool ret = vtpStreamSocket->Accept(); HWTEST_F() local 741 int32_t ret = vtpStreamSocket->EpollTimeout(fd, timeout); HWTEST_F() local 802 ssize_t ret = vtpStreamSocket->Encrypt(nullptr, inLen, data.get() + FRAME_HEADER_LEN, outLen); HWTEST_F() local 874 bool ret = vtpStreamSocket->SetStreamType(type, *value); HWTEST_F() local 940 int32_t ret = vtpStreamSocket->RecvStreamLen(); HWTEST_F() local 1008 int32_t ret = vtpStreamSocket->HandleRipplePolicy(fd, nullptr); HWTEST_F() local 1040 int32_t ret = vtpStreamSocket->HandleFillpFrameEvt(fd, nullptr); HWTEST_F() local 1070 int32_t ret = vtpStreamSocket->SetSocketEpollMode(fd); HWTEST_F() local 1099 int32_t ret = vtpStreamSocket->EpollTimeout(fd, timeout); HWTEST_F() local [all...] |