| /foundation/deviceprofile/device_info_manager/services/core/test/unittest/ |
| D | subscribe_profile_manager_test.cpp | 51 int32_t errCode = SubscribeProfileManager::GetInstance().Init(); in SetUpTestCase() local
57 int32_t errCode = SubscribeProfileManager::GetInstance().UnInit(); in TearDownTestCase() local
156 int32_t errCode = SubscribeProfileManager::GetInstance().SubscribeDeviceProfile(subscribeInfo); variable
170 int32_t errCode = SubscribeProfileManager::GetInstance(). variable
185 int32_t errCode = SubscribeProfileManager::GetInstance(). variable
199 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileAdd(profile); variable
212 … int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileDelete(profile); variable
226 …int32_t errCode = SubscribeProfileManager::GetInstance().NotifyTrustDeviceProfileUpdate(oldProfile… variable
240 int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileAdd(dbKey, dbValue); variable
254 …int32_t errCode = SubscribeProfileManager::GetInstance().NotifyDeviceProfileUpdate(dbKey, dbValue); variable
[all …]
|
| D | switch_profile_manager_test.cpp | 67 int32_t errCode = SwitchProfileManager::GetInstance().Init(); variable
80 int32_t errCode = SwitchProfileManager::GetInstance().UnInit(); variable
93 int32_t errCode = SwitchProfileManager::GetInstance().ReInit(); variable
107 int32_t errCode = SwitchProfileManager::GetInstance().PutCharacteristicProfile(charProfile); variable
120 … int32_t errCode = SwitchProfileManager::GetInstance().PutCharacteristicProfileBatch(charProfiles); variable
136 …int32_t errCode = SwitchProfileManager::GetInstance().GetCharacteristicProfile(deviceId, serviceNa… variable
149 int32_t errCode = SwitchProfileManager::GetInstance().RefreshLocalSwitchProfile(); variable
|
| D | static_profile_manager_test.cpp | 65 int32_t errCode = StaticProfileManager::GetInstance().Init(); variable
78 int32_t errCode = StaticProfileManager::GetInstance().UnInit(); variable
91 int32_t errCode = StaticProfileManager::GetInstance().ReInit(); variable
104 int32_t errCode = StaticProfileManager::GetInstance().PutCharacteristicProfile(charProfile); variable
120 …int32_t errCode = StaticProfileManager::GetInstance().GetCharacteristicProfile(deviceId, serviceNa… variable
135 …int32_t errCode = StaticProfileManager::GetInstance().GetAllCharacteristicProfile(staticCapability… variable
150 …int32_t errCode = StaticProfileManager::GetInstance().GenerateStaticInfoProfile(staticCapabilityPr… variable
|
| /foundation/communication/netstack/test/unittest/tlssocket/client/ |
| D | TlsSocketCertChainTest.cpp | 57 server.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetCertChainHwTestShortParam()
58 server.Connect(options, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetCertChainHwTestShortParam()
76 server.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetCertChainHwTestLongParam()
77 server.Connect(options, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetCertChainHwTestLongParam()
89 testServer.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anonfcc191750502()
103 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anonfcc191750602()
106 (void)certChainServer.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anonfcc191750702()
122 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anonfcc191750802()
125 (void)certChainServer.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anonfcc191750902()
140 …certChainServer.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCES… in __anonfcc191750a02()
[all …]
|
| D | TlsSocketTest.cpp | 56 server.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetSocketHwTestShortParam()
57 server.Connect(options, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetSocketHwTestShortParam()
73 server.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetSocketHwTestLongParam()
74 server.Connect(options, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetSocketHwTestLongParam()
86 … bindTestServer.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anonbdc824640502()
100 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anonbdc824640602()
103 (void)testService.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anonbdc824640702()
118 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anonbdc824640802()
121 (void)testService.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anonbdc824640902()
135 …testService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); … in __anonbdc824640a02()
[all …]
|
| D | TlsSocketOneWayTest.cpp | 56 server.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetOneWayHwTestShortParam()
57 server.Connect(options, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetOneWayHwTestShortParam()
73 server.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetOneWayHwTestLongParam()
74 server.Connect(options, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetOneWayHwTestLongParam()
87 oneWayService.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anoncec174170502()
102 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anoncec174170602()
105 (void)oneWayService.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anoncec174170702()
122 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anoncec174170802()
125 (void)oneWayService.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anoncec174170902()
141 …oneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anoncec174170a02()
[all …]
|
| D | TlsSocketCertChainOneWayTest.cpp | 58 server.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetCertChainOneWayHwTestShortParam()
59 server.Connect(options, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetCertChainOneWayHwTestShortParam()
77 server.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetCertChainOneWayHwTestLongParam()
78 server.Connect(options, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetCertChainOneWayHwTestLongParam()
90 srv.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anon4cf6a9e80502()
104 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anon4cf6a9e80602()
107 …(void)certChainOneWayService.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon4cf6a9e80702()
123 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anon4cf6a9e80802()
126 …(void)certChainOneWayService.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS)… in __anon4cf6a9e80902()
141 …certChainOneWayService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET… in __anon4cf6a9e80a02()
[all …]
|
| D | TlsSocketUnilateralConnection.cpp | 64 server.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetUnilateralHwTestShortParam()
65 server.Connect(options, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in SetUnilateralHwTestShortParam()
141 tlsService.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anon8da754850402()
156 …tlsService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }… in __anon8da754850502()
158 (void)tlsService.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anon8da754850602()
175 …tlsService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }… in __anon8da754850702()
177 (void)tlsService.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anon8da754850802()
193 …tlsService.Send(tcpSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }… in __anon8da754850902()
195 (void)tlsService.Close([](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anon8da754850a02()
212 tlsService.Bind(address, [](int32_t errCode) { EXPECT_TRUE(errCode == TLSSOCKET_SUCCESS); }); in __anon8da754850b02()
[all …]
|
| /foundation/distributeddatamgr/relational_store/test/ndk/unittest/ |
| D | rdb_asset_test.cpp | 57 int errCode = 0; in SetUpTestCase() local
66 int errCode = OH_Rdb_Execute(assetTestRdbStore_, dropTableSql); in TearDownTestCase() local
86 int errCode = OH_Rdb_Execute(assetTestRdbStore_, createTableSql); in CreateAssetTable() local
103 int errCode = OH_Data_Asset_SetName(nullptr, nullptr); variable
125 int errCode = OH_Data_Asset_SetUri(nullptr, nullptr); variable
147 int errCode = OH_Data_Asset_SetPath(nullptr, nullptr); variable
167 int errCode = OH_Data_Asset_SetCreateTime(nullptr, 1); variable
189 int errCode = OH_Data_Asset_SetName(asset, "name"); variable
215 int errCode = OH_Data_Asset_SetUri(asset, "uri"); variable
241 int errCode = OH_Data_Asset_SetPath(asset, "path"); variable
[all …]
|
| /foundation/window/window_manager/wmserver/src/zidl/ |
| D | window_manager_stub.cpp | 54 … WMError errCode = CreateWindow(windowProxy, windowProperty, surfaceNode, windowId, token); in OnRemoteRequest() local
65 WMError errCode = AddWindow(windowProperty); in OnRemoteRequest() local
72 WMError errCode = RemoveWindow(windowId, isFromInnerkits); in OnRemoteRequest() local
78 WMError errCode = DestroyWindow(windowId); in OnRemoteRequest() local
84 WMError errCode = RequestFocus(windowId); in OnRemoteRequest() local
101 WMError errCode = RegisterWindowManagerAgent(type, windowManagerAgentProxy); in OnRemoteRequest() local
110 WMError errCode = UnregisterWindowManagerAgent(type, windowManagerAgentProxy); in OnRemoteRequest() local
135 WMError errCode = GetTopWindowId(mainWinId, topWinId); in OnRemoteRequest() local
141 WMError errCode = MinimizeAllAppWindows(data.ReadUint64()); in OnRemoteRequest() local
146 WMError errCode = ToggleShownStateForAllAppWindows(); in OnRemoteRequest() local
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| D | default_factory.cpp | 33 IKvDB *DefaultFactory::CreateKvDb(KvDBType kvDbType, int &errCode) in CreateKvDb()
55 IKvDB *DefaultFactory::CreateLocalKvDB(int &errCode) in CreateLocalKvDB()
63 IKvDB *DefaultFactory::CreateMultiVerNaturalStore(int &errCode) in CreateMultiVerNaturalStore()
72 IKvDB *DefaultFactory::CreateSingleVerNaturalStore(int &errCode) in CreateSingleVerNaturalStore()
80 IKvDB *DefaultFactory::CreateRdSingleVerNaturalStore(int &errCode) in CreateRdSingleVerNaturalStore()
89 IKvDB *DefaultFactory::CreateCommitStorageDB(int &errCode) in CreateCommitStorageDB()
96 IKvDBMultiVerDataStorage *DefaultFactory::CreateMultiVerStorage(int &errCode) in CreateMultiVerStorage()
104 IKvDBCommitStorage *DefaultFactory::CreateMultiVerCommitStorage(int &errCode) in CreateMultiVerCommitStorage()
|
| /foundation/communication/netstack/test/unittest/tlssocket/server/ |
| D | TlsSocketServerTest.cpp | 92 …server.Listen(tlsListenOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_… in __anon15b3c0730202()
107 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKE… in __anon15b3c0730302()
123 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKE… in __anon15b3c0730402()
126 …(void)server.Close(socketFd, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_SUC… in __anon15b3c0730502()
143 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKE… in __anon15b3c0730602()
147 …(void)server.Close(socketFd, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_SUC… in __anon15b3c0730702()
151 server.Stop([](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_SUCCESS); }); in __anon15b3c0730802()
181 …server.Send(tlsServerSendOptions, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKE… in __anon15b3c0730a02()
184 …(void)server.Close(socketFd, [](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_SUC… in __anon15b3c0730b02()
187 server.Stop([](int32_t errCode) { EXPECT_TRUE(errCode == TlsSocket::TLSSOCKET_SUCCESS); }); in __anon15b3c0730c02()
[all …]
|
| /foundation/filemanagement/app_file_service/tests/mock/module_ipc/ |
| D | service_reverse_proxy_mock.cpp | 23 …viceReverseProxy::BackupOnFileReady(string bundleName, string fileName, int fd, int32_t errCode) {} in BackupOnFileReady()
25 void ServiceReverseProxy::BackupOnBundleStarted(int32_t errCode, string bundleName) {} in BackupOnBundleStarted()
29 void ServiceReverseProxy::BackupOnBundleFinished(int32_t errCode, string bundleName) {} in BackupOnBundleFinished()
31 void ServiceReverseProxy::BackupOnAllBundlesFinished(int32_t errCode) {} in BackupOnAllBundlesFinished()
35 void ServiceReverseProxy::RestoreOnBundleStarted(int32_t errCode, string bundleName) {} in RestoreOnBundleStarted()
37 void ServiceReverseProxy::RestoreOnBundleFinished(int32_t errCode, string bundleName) {} in RestoreOnBundleFinished()
39 void ServiceReverseProxy::RestoreOnAllBundlesFinished(int32_t errCode) {} in RestoreOnAllBundlesFinished()
41 …iceReverseProxy::RestoreOnFileReady(string bundleName, string fileName, int fd, int32_t errCode) {} in RestoreOnFileReady()
43 void ServiceReverseProxy::RestoreOnResultReport(string result, string bundleName, ErrCode errCode) … in RestoreOnResultReport()
48 int32_t errCode) {} in IncrementalBackupOnFileReady()
[all …]
|
| /foundation/deviceprofile/device_info_manager/radar/test/unittest/ |
| D | dp_radar_helper_test.cpp | 40 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
52 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
65 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
78 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
89 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
101 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
112 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
124 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
136 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
148 int32_t errCode = static_cast<int32_t>(StageRes::STAGE_SUCC); variable
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| D | sqlite_single_ver_storage_executor_cache.cpp | 31 int errCode = -E_NOT_SUPPORT; in PrepareForSavingCacheData() local
56 int errCode = E_OK; in ResetForSavingCacheData() local
72 int errCode = E_OK; in ResetForMigrateCacheData() local
87 int errCode = DBCommon::CalcValueHash(REMOVE_DEVICE_DATA_KEY, hashKey); in RemoveDeviceDataInCacheMode() local
139 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetMinVersionCacheData() local
171 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in MigrateRmDevData() local
209 …int errCode = SQLiteUtils::AttachNewDatabase(dbHandle_, type, passwd, attachDbAbsPath, attachAsNam… in AttachMainDbAndCacheDb() local
239 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); in GetMaxVersionInCacheDb() local
262 …int errCode = PutIntoConflictAndCommitForMigrateCache(dataItem, {dataItem.dev.empty(), dataItem.de… in MigrateDataItem() local
304 int errCode = E_OK; in CheckDataWithQuery() local
[all …]
|
| D | sqlite_local_storage_executor.cpp | 50 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_SQL, statement); in Get() local
77 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, CLEAR_SQL); in Clear() local
85 int errCode = SQLiteUtils::GetStatement(dbHandle_, SELECT_BATCH_SQL, statement); in GetEntries() local
138 int errCode = Put(entry.key, entry.value); in PutBatch() local
157 int errCode = Delete(key); in DeleteBatch() local
175 int errCode = SQLiteUtils::BeginTransaction(dbHandle_); in StartTransaction() local
181 int errCode = SQLiteUtils::CommitTransaction(dbHandle_); in Commit() local
187 int errCode = SQLiteUtils::RollbackTransaction(dbHandle_); in RollBack() local
194 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_SQL, statement); in Put() local
226 int errCode = SQLiteUtils::GetStatement(dbHandle_, DELETE_SQL, statement); in Delete() local
|
| /foundation/filemanagement/app_file_service/tests/unittests/backup_api/backup_impl/include/ |
| D | service_reverse_mock.h | 39 …void BackupOnFileReady(std::string bundleName, std::string fileName, int fd, int32_t errCode) over… in BackupOnFileReady()
40 void BackupOnBundleStarted(int32_t errCode, std::string bundleName) override {} in BackupOnBundleStarted()
42 void BackupOnBundleFinished(int32_t errCode, std::string bundleName) override {} in BackupOnBundleFinished()
43 void BackupOnAllBundlesFinished(int32_t errCode) override {} in BackupOnAllBundlesFinished()
46 void RestoreOnBundleStarted(int32_t errCode, std::string bundleName) override {} in RestoreOnBundleStarted()
47 void RestoreOnBundleFinished(int32_t errCode, std::string bundleName) override {} in RestoreOnBundleFinished()
48 void RestoreOnAllBundlesFinished(int32_t errCode) override {} in RestoreOnAllBundlesFinished()
49 …void RestoreOnFileReady(std::string bundleName, std::string fileName, int fd, int32_t errCode) ove… in RestoreOnFileReady()
50 …void RestoreOnResultReport(std::string result, std::string bundleName, ErrCode errCode) override {} in RestoreOnResultReport()
54 int32_t errCode) override {} in IncrementalBackupOnFileReady()
[all …]
|
| /foundation/ability/form_fwk/interfaces/kits/native/src/ |
| D | form_mgr.cpp | 73 int errCode = Connect(); in AddForm() local
136 int errCode = Connect(); in DeleteForm() local
169 int errCode = Connect(); in StopRenderingForm() local
202 int errCode = Connect(); in ReleaseForm() local
241 int errCode = Connect(); in UpdateForm() local
287 int errCode = Connect(); in ReleaseRenderer() local
320 int errCode = Connect(); in RequestForm() local
366 int errCode = Connect(); in NotifyWhetherVisibleForms() local
391 int errCode = Connect(); in HasFormVisible() local
418 int errCode = Connect(); in CastTempForm() local
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/test/unittest/oh_adapter/ |
| D | documentdb_json_common_test.cpp | 51 int errCode = E_OK; variable
76 int errCode = E_OK; variable
100 int errCode = E_OK; variable
122 int errCode = E_OK; variable
136 int errCode = E_OK; variable
155 int errCode = E_OK; variable
174 int errCode = E_OK; variable
193 int errCode = E_OK; variable
212 int errCode = E_OK; variable
231 int errCode = E_OK; variable
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| D | kv_store_delegate_impl.cpp | 59 int errCode = conn_->Put(option, key, value); in Put() local
76 int errCode = conn_->PutBatch(option, entries); in PutBatch() local
93 int errCode = conn_->Delete(option, key); in Delete() local
110 int errCode = conn_->DeleteBatch(option, keys); in DeleteBatch() local
127 int errCode = conn_->Clear(option); in Clear() local
161 int errCode = conn_->GetSnapshot(snapshot); in GetKvStoreSnapshot() local
223 int errCode = E_OK; in RegisterObserver() local
262 int errCode = conn_->UnRegisterObserver(observerHandle); in UnRegisterObserver() local
278 int errCode = conn_->StartTransaction(); in StartTransaction() local
293 int errCode = conn_->Commit(); in Commit() local
[all …]
|
| D | kv_store_nb_delegate_impl.cpp | 108 int errCode = conn_->GetResultSet(option, keyPrefix, kvDbResultSet); in GetEntries() local
130 int errCode = conn_->GetEntries(option, query, entries); in GetEntries() local
156 int errCode = conn_->GetResultSet(option, query, kvDbResultSet); in GetEntries() local
182 int errCode = conn_->GetCount(option, query, count); in GetCount() local
227 int errCode = conn_->PutBatch(option, entries); in PutBatch() local
249 int errCode = conn_->DeleteBatch(option, keys); in DeleteBatch() local
303 int errCode = conn_->Pragma(PRAGMA_PUBLISH_LOCAL, static_cast<PragmaData>(&publishInfo)); in PublishLocal() local
323 int errCode = conn_->Pragma(PRAGMA_UNPUBLISH_SYNC, static_cast<PragmaData>(&unpublishInfo)); in UnpublishToLocal() local
343 int errCode = conn_->PutBatch(option, entries); in PutLocalBatch() local
359 int errCode = conn_->DeleteBatch(option, keys); in DeleteLocalBatch() local
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| D | multi_ver_storage_executor.cpp | 61 int errCode = kvDataStorage_->PutMetaData(key, value); in PutMetaData() local
71 int errCode = kvDataStorage_->GetMetaData(key, value); in GetMetaData() local
82 int errCode = commitStorage_->GetLatestCommits(latestCommits); in GetDeviceLatestCommit() local
120 int errCode = commitStorage_->GetCommitTree(latestCommits, commitTree); in GetCommitTree() local
158 int errCode = E_OK; in GetCommitData() local
272 int errCode; in GetValueSliceInner() local
294 int errCode; in PutValueSliceInner() local
317 int errCode; in DeleteValueSliceInner() local
345 int errCode; in StartSliceTransaction() local
362 int errCode = sliceTransaction_->CommitTransaction(); in CommitSliceTransaction() local
[all …]
|
| D | multi_ver_vacuum_executor_impl.cpp | 57 int errCode = E_OK; in GetVacuumAbleCommits() local
101 int errCode = handle->GetEntriesByVersion(version, recordsInCommit); in GetVacuumNeedRecordsByVersion() local
130 int errCode = handle->GetOverwrittenClearTypeEntries(version, clearShadowRecords); in GetShadowRecordsOfClearTypeRecord() local
158 … int errCode = handle->GetOverwrittenNonClearTypeEntries(version, hashKey, nonClearShadowRecords); in GetShadowRecordsOfNonClearTypeRecord() local
184 int errCode = E_OK; in StartTransactionForVacuum() local
212 int errCode = writeHandle_->CommitTransaction(MultiTransactionType::ALL_DATA); in CommitTransactionForVacuum() local
233 int errCode = writeHandle_->RollBackTransaction(MultiTransactionType::ALL_DATA); in RollBackTransactionForVacuum() local
253 int errCode = writeHandle_->DeleteEntriesByHashKey(version, hashKey); in DeleteRecordTotally() local
271 int errCode = writeHandle_->UpdateTrimedFlag(version, hashKey); in MarkRecordAsVacuumDone() local
289 int errCode = writeHandle_->UpdateTrimedFlag(commitId); in MarkCommitAsVacuumDone() local
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| D | rd_single_ver_result_set.cpp | 57 int errCode = E_OK; in Open() local
87 int errCode = PreCheckResultSet(); in Close() local
124 int errCode = PreCheckResultSet(); in GetCount() local
156 int errCode = E_OK; in Move() local
194 int errCode = PreCheckResultSet(); in MoveToNext() local
233 int errCode = PreCheckResultSet(); in MoveToPrev() local
264 int errCode = PreCheckResultSet(); in MoveTo() local
286 int errCode = E_OK; in MoveToFirst() local
304 int errCode = E_OK; in MoveToLast() local
374 int errCode = PreCheckResultSet(); in GetEntry() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| D | distributeddb_time_sync_test.cpp | 149 int errCode; variable
194 int errCode; variable
240 int errCode; variable
283 int errCode; variable
321 int errCode; variable
389 int errCode; variable
454 int errCode; variable
484 …int errCode = g_timeSyncA->Initialize(g_virtualCommunicator, g_metadataA, g_syncInterfaceA, DEVICE… variable
516 …int errCode = g_timeSyncA->Initialize(g_virtualCommunicator, g_metadataA, g_syncInterfaceA, DEVICE… variable
|