Home
last modified time | relevance | path

Searched refs:commAggrHandle (Results 1 – 5 of 5) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_test.cpp138 g_envDeviceA.commAggrHandle->ReleaseCommunicator(commA);
140 g_envDeviceA.commAggrHandle->ReleaseCommunicator(commB);
155 g_envDeviceA.commAggrHandle->ReleaseCommunicator(commD);
256 g_envDeviceA.commAggrHandle->ReleaseCommunicator(commAA);
257 g_envDeviceB.commAggrHandle->ReleaseCommunicator(commBB);
258 g_envDeviceB.commAggrHandle->ReleaseCommunicator(commBA);
414 envDeviceE.commAggrHandle->ReleaseCommunicator(commEE); in TestRemoteRestart()
435 envDeviceD.commAggrHandle->ReleaseCommunicator(commDD); in TestRemoteRestart()
436 envDeviceE.commAggrHandle->ReleaseCommunicator(commEE); in TestRemoteRestart()
1141 envDeviceA.commAggrHandle = nullptr;
[all …]
H A Ddistributeddb_communicator_common.cpp28 if (inEnv.adapterHandle != nullptr || inEnv.commAggrHandle != nullptr) { in SetUpEnv()
39 inEnv.commAggrHandle = new (nothrow) CommunicatorAggregator(); in SetUpEnv()
40 if (inEnv.commAggrHandle == nullptr) { in SetUpEnv()
45 int errCode = inEnv.commAggrHandle->Initialize(inEnv.adapterHandle, adapter); in SetUpEnv()
61 if (inEnv.commAggrHandle != nullptr) { in TearDownEnv()
62 inEnv.commAggrHandle->Finalize(); in TearDownEnv()
63 inEnv.commAggrHandle->DecObjRef(inEnv.commAggrHandle); in TearDownEnv()
64 inEnv.commAggrHandle = nullptr; in TearDownEnv()
H A Ddistributeddb_communicator_deep_test.cpp86 g_commAA = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in AllocAllCommunicator()
88 g_commAB = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_B, errorNo); in AllocAllCommunicator()
90 g_commBB = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_B, errorNo); in AllocAllCommunicator()
92 g_commBC = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_C, errorNo); in AllocAllCommunicator()
94 g_commCC = g_envDeviceC.commAggrHandle->AllocCommunicator(LABEL_C, errorNo); in AllocAllCommunicator()
102 g_envDeviceA.commAggrHandle->ReleaseCommunicator(g_commAA); in ReleaseAllCommunicator()
104 g_envDeviceA.commAggrHandle->ReleaseCommunicator(g_commAB); in ReleaseAllCommunicator()
106 g_envDeviceB.commAggrHandle->ReleaseCommunicator(g_commBB); in ReleaseAllCommunicator()
108 g_envDeviceB.commAggrHandle->ReleaseCommunicator(g_commBC); in ReleaseAllCommunicator()
110 g_envDeviceC.commAggrHandle->ReleaseCommunicator(g_commCC); in ReleaseAllCommunicator()
[all …]
H A Ddistributeddb_communicator_send_receive_test.cpp82 g_commAA = g_envDeviceA.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in SetUp()
87 g_commBA = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_A, errorNo); in SetUp()
92 g_commBB = g_envDeviceB.commAggrHandle->AllocCommunicator(LABEL_B, errorNo); in SetUp()
102 g_envDeviceA.commAggrHandle->ReleaseCommunicator(g_commAA); in TearDown()
104 g_envDeviceB.commAggrHandle->ReleaseCommunicator(g_commBA); in TearDown()
106 g_envDeviceB.commAggrHandle->ReleaseCommunicator(g_commBB); in TearDown()
H A Ddistributeddb_communicator_common.h32 DistributedDB::CommunicatorAggregator *commAggrHandle = nullptr; member