| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | process_communicator_impl.cpp | 47 Status errCode = CommunicationProvider::GetInstance().Start(pi); in Start() local
58 Status errCode = CommunicationProvider::GetInstance().Stop(pi); in Stop() local
75 Status errCode = DmAdapter::GetInstance().StartWatchDeviceChange(this, pi); in RegOnDeviceChange() local
81 Status errCode = DmAdapter::GetInstance().StopWatchDeviceChange(this, pi); in RegOnDeviceChange() local
100 Status errCode = CommunicationProvider::GetInstance().StartWatchDataChange(this, pi); in RegOnDataReceive() local
106 Status errCode = CommunicationProvider::GetInstance().StopWatchDataChange(this, pi); RegOnDataReceive() local
142 Status errCode = CommunicationProvider::GetInstance().SendData(pi, destination, dataInfo, totalLength); SendData() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/common/src/ |
| H A D | db_config.cpp | 59 int errCode = E_OK; in CheckAndGetDBConfig() local
162 DBConfig DBConfig::GetDBConfigFromJsonStr(const std::string &confStr, int &errCode) in GetDBConfigFromJsonStr() argument
223 ReadConfig(const std::string &confStr, int &errCode) ReadConfig() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/executor/document/ |
| H A D | check_common.cpp | 54 bool CheckCommon::CheckCollectionName(const std::string &collectionName, std::string &formattedName, int &errCode) in CheckCollectionName() argument
197 int errCode = SplitFieldName(jsonTemp.GetItemField(), allFieldsName); in CheckUpdata() local
244 int errCode = E_OK; CheckProjection() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_manager.cpp | 57 static RelationalStoreConnection *GetOneConnectionWithRetry(const RelationalDBProperties &properties, int &errCode) in GetOneConnectionWithRetry() argument
111 int errCode = E_OK; in OpenStore() local
190 int errCode = E_OK; in CalcPrimaryKeyHash() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_data_inserter.cpp | 24 int errCode = E_OK; in ResetStatements() local
131 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in GetInsertStatement() local
146 int errCode = DataTransformer::DeSerializeDataItem(dataItem, data, remoteFields_); BindInsertStatement() local
185 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); GetDeleteLogStmt() local
201 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); GetDeleteSyncDataStmt() local
215 int errCode = SQLiteUtils::GetStatement(db, sql, logStmt); GetSaveLogStatement() local
236 int errCode = GetSaveLogStatement(db, stmt.saveLogStmt, stmt.queryStmt); PrepareStatement() local
250 int errCode = E_OK; Iterate() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_engine.cpp | 65 int errCode = E_OK; in InitReadWriteExecutors() local
110 int errCode = InitReadWriteExecutors(); Init() local
134 FindExecutor(bool writable, OperatePerm perm, int &errCode, int waitTime) FindExecutor() argument
161 FindWriteExecutor(OperatePerm perm, int &errCode, int waitTime) FindWriteExecutor() argument
197 FindReadExecutor(OperatePerm perm, int &errCode, int waitTime) FindReadExecutor() argument
440 FetchStorageExecutor(bool isWrite, std::list<StorageExecutor *> &idleList, std::list<StorageExecutor *> &usingList, int &errCode) FetchStorageExecutor() argument
[all...] |
| H A D | sync_able_engine.cpp | 49 int errCode = StartSyncer(); in Sync() local
79 int errCode = StartSyncer(); in EraseDeviceWaterMark() local
90 int errCode = E_OK; in StartSyncer() local
111 int errCode in StartSyncerWithNoLock() local
265 int errCode = StartSyncer(); RemoteQuery() local
287 int errCode = StartSyncer(); GetHashDeviceId() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_tag_assets.cpp | 21 void TagSingleAssetForDownload(AssetOpType flag, Asset &asset, Assets &res, int &errCode) in TagSingleAssetForDownload() argument
86 TagAssetWithNormalStatus(const bool isNormalStatus, AssetOpType flag, Asset &asset, Assets &res, int &errCode) TagAssetWithNormalStatus() argument
96 TagAssetsWithNormalStatus(const bool isNormalStatus, AssetOpType flag, Assets &assets, Assets &res, int &errCode) TagAssetsWithNormalStatus() argument
127 TagAssetWithSameHash(const bool isNormalStatus, Asset &beCoveredAsset, Asset &coveredAsset, Assets &res, int &errCode) TagAssetWithSameHash() argument
137 TagForNotContainsAsset(const std::string &assetFieldName, VBucket &coveredData, VBucket &beCoveredData, bool setNormalStatus, int &errCode) TagForNotContainsAsset() argument
163 TagAssets(const std::string &assetFieldName, VBucket &coveredData, VBucket &beCoveredData, bool setNormalStatus, int &errCode) TagAssets() argument
212 TagCoveredAssetInner(Asset &covered, const Asset &beCovered, const bool setNormalStatus, Assets &res, int &errCode) TagCoveredAssetInner() argument
226 TagAsset(const std::string &assetFieldName, VBucket &coveredData, VBucket &beCoveredData, bool setNormalStatus, int &errCode) TagAsset() argument
298 int errCode = OS::GetCurrentSysTimeInMicrosecond(timestamp); MarkAssetForUpload() local
327 TagAssetsInSingleCol( VBucket &coveredData, VBucket &beCoveredData, const Field &assetField, bool setNormalStatus, int &errCode) TagAssetsInSingleCol() argument
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_multi_ver_sync_db_interface.cpp | 159 int errCode = E_OK; in Initialize() local
181 int errCode in GetData() local
217 int errCode = connection_->Close(); DeleteDatabase() local
[all...] |
| H A D | virtual_communicator.cpp | 70 int errCode = TranslateMsg(inMsg, message); in SendMessage() local
218 int errCode = E_OK; in TranslateMsg() local
[all...] |
| /foundation/distributeddatamgr/data_share/test/native/unittest/datashareproxy_test/ |
| H A D | proxydatas_with_permission_test.cpp | 212 int errCode = 0; in HWTEST_F() local
240 int errCode = 0; in HWTEST_F() local
260 int errCode = 0; in HWTEST_F() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/evloop/src/ |
| H A D | event_loop_impl.cpp | 123 int errCode = QueueRequest(EventRequest::ADD_EVENT, eventImpl, timeout); in Add() local
148 int errCode = QueueRequest(EventRequest::REMOVE_EVENT, eventImpl, timeout); in Remove() local
170 int errCode = E_OK; in Run() local
225 int errCode = QueueRequest(type, event, events); Modify() local
238 int errCode = QueueRequest(EventRequest::SET_TIMEOUT, event, time); Modify() local
282 int errCode = event->CheckStatus(); QueueRequest() local
345 int errCode = E_OK; AddEventObject() local
371 int errCode = E_OK; RemoveEventObject() local
396 int errCode = E_OK; ModifyEventObject() local
477 int errCode = E_OK; ProcessRequest() local
539 int errCode = event->Dispatch(); DispatchAll() local
563 int errCode = Exit(polling); CleanLoop() local
[all...] |
| H A D | event_impl.cpp | 124 int errCode = loop->Modify(this, true, events); in AddEvents() local
155 int errCode = loop->Modify(this, false, events); in RemoveEvents() local
180 int errCode = loop->Modify(this, timeout); in SetTimeout() local
200 int errCode = loop->Remove(this); Detach() local
356 int errCode = E_OK; Dispatch() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | communicator_linker.cpp | 54 int errCode = OS::GetCurrentSysTimeInMicrosecond(curTime); in Initialize() local
170 int errCode = TriggerLabelExchangeAckEvent(inTarget, inSequenceId); in ReceiveLabelExchange() local
231 int errCode = context->SetTimer(static_cast<int>(inCountDown), [inAction](TimerId inTimerId)->int{ in SuspendByOnceTimer() local
268 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, inTarget]() { DetectDistinctValueChange() local
332 int errCode = E_OK; TriggerLabelExchangeAckEvent() local
398 int errCode = aggregator_->ScheduleSendTask(toTarget, inBuff, FrameType::COMMUNICATION_LABEL_EXCHANGE, config); SendLabelExchange() local
456 int errCode = aggregator_->ScheduleSendTask(toTarget, inBuff, FrameType::COMMUNICATION_LABEL_EXCHANGE_ACK, config); SendLabelExchangeAck() local
[all...] |
| H A D | db_status_adapter.cpp | 110 int errCode = RuntimeContext::GetInstance()->ScheduleTask([triggerLocal, remoteDBInfos, remote, local]() { in SetDBStatusChangeCallback() local
125 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, devInfos, dbInfos]() { in NotifyDBInfos() local
200 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, dev]() { in SetRemoteOptimizeCommunication() local
327 int errCode = RuntimeContext::GetInstance()->GetCommunicatorAggregator(communicatorAggregator); GetLocalDeviceId() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_utils.cpp | 206 int errCode = TransferGrdErrno(GRD_KVGetSize(resultSet, &keyLen, &valueLen)); in RdKvFetch() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_thread_pool_test.cpp | 103 int errCode = RuntimeContext::GetInstance()->ScheduleTask([]() { in CallScheduleTaskOnce() local
138 int errCode = RuntimeContext::GetInstance()->SetTimer(timeOut, [&timerCount](TimerId timerId) { in SetTimer() local
154 int errCode = RuntimeContext::GetInstance()->SetTimer(ONE_HUNDRED_MILLISECONDS, [&timerCount](TimerId timerId) { in SetTimer() local
415 int errCode = RuntimeContext::GetInstance()->SetTimer(1, [&dataMutex, &removeSet, &checkSet](TimerId timerId) { in HWTEST_F() local
450 int errCode = RuntimeContext::GetInstance()->ScheduleTask([&finishedTaskCount, &dataMutex, &cv]() { in HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/gaussdb_rd/src/oh_adapter/src/ |
| H A D | sqlite_store_executor_impl.cpp | 33 int errCode = RDSQLiteUtils::CreateDataBase(path, 0, db); in CreateDatabase() local
79 int errCode = GetDataByKey("grd_meta", dbConfigKey, dbConfigVal); GetDBConfig() local
116 int errCode = RDSQLiteUtils::ExecSql( PutData() local
145 int errCode = RDSQLiteUtils::ExecSql( InsertData() local
172 int errCode = RDSQLiteUtils::ExecSql( GetDataByKey() local
199 int errCode = RDSQLiteUtils::ExecSql( GetDataById() local
253 int errCode = RDSQLiteUtils::ExecSql( GetDataByFilter() local
297 int errCode = 0; DelData() local
326 int errCode = E_OK; CreateCollection() local
359 int errCode = E_OK; DropCollection() local
371 int errCode = RDSQLiteUtils::ExecSql(dbHandle_, sql); DropCollection() local
378 IsCollectionExists(const std::string &name, int &errCode) IsCollectionExists() argument
[all...] |
| H A D | rd_sqlite_utils.cpp | 31 int MapSqliteError(int errCode) in MapSqliteError() argument
69 int errCode = sqlite3_open_v2(path.c_str(), &db, SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE, nullptr); in CreateDataBase() local
97 int errCode = sqlite3_prepare_v2(db, sql.c_str(), -1, &statement, nullptr); GetStatement() local
117 int errCode = sqlite3_step(statement); StepWithRetry() local
131 int errCode = E_OK; ResetStatement() local
158 int errCode; BindBlobToStatement() local
198 int errCode = sqlite3_bind_text(statement, index, value.c_str(), value.length(), SQLITE_TRANSIENT); BindTextToStatement() local
233 int errCode = sqlite3_exec(db, sql.c_str(), nullptr, nullptr, &errMsg); ExecSql() local
251 int errCode = RDSQLiteUtils::GetStatement(db, sql, stmt); ExecSql() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/ |
| H A D | sqlite_local_kvdb_connection.cpp | 52 int errCode = E_OK; in Get() local
65 int errCode = CheckDataStatus(key, value, false); in Put() local
98 int errCode = CheckDataStatus(key, {}, true); Delete() local
133 int errCode = StartTransactionInner(isAuto); Clear() local
174 int errCode = E_OK; GetEntries() local
197 int errCode = StartTransactionInner(isAuto); PutBatch() local
240 int errCode = StartTransactionInner(isAuto); DeleteBatch() local
273 int errCode = E_OK; GetSnapshot() local
374 int errCode = E_OK; StartTransactionInner() local
399 int errCode = writeHandle_->Commit(); CommitInner() local
414 int errCode = writeHandle_->RollBack(); RollBackInner() local
434 int errCode = kvDB_->TryToDisableConnection(OperatePerm::REKEY_MONOPOLIZE_PERM); Rekey() local
476 int errCode = kvDB_->TryToDisableConnection(OperatePerm::IMPORT_MONOPOLIZE_PERM); Import() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_executor_extend.cpp | 42 int errCode = E_OK; in CloudExcuteRemoveOrUpdate() local
87 int errCode = E_OK; CloudCheckDataExist() local
140 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_ALL_HWM_DATA_SQL, "", "", true); RemoveDeviceDataInner() local
164 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_ALL_HWM_DATA_SQL, "", "", true); RemoveDeviceDataInner() local
185 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_HWM_DATA_BY_USERID_SQL, "", RemoveDeviceDataWithUserInner() local
213 int errCode = CloudExcuteRemoveOrUpdate(REMOVE_CLOUD_HWM_DATA_BY_USERID_SQL, "", RemoveDeviceDataWithUserInner() local
242 int errCode = CloudCheckDataExist(SELECT_CLOUD_LOG_DATA_BY_DEVID_SQL, deviceName, "", isDataExist); RemoveDeviceData() local
257 int errCode = E_OK; RemoveDeviceData() local
277 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, stmt); GetEntries() local
314 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); PrepareForUnSyncTotalByTime() local
333 int errCode = SQLiteUtils::StepWithRetry(countStatement, isMemDb_); GetCountValue() local
355 int errCode = PrepareForUnSyncTotalByTime(begin, end, countStatement); GetUnSyncTotalByTimestamp() local
366 int errCode = PrepareForUnSyncTotalByTime(begin, end, countStatement, true); GetDeletedSyncTotalByTimestamp() local
376 int errCode = E_OK; GetSyncTotalWithQuery() local
394 int errCode = SQLiteUtils::CheckTableExists(dbHandle_, tableName, isCreate); RemoveCloudUploadFlag() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | remote_executor_packet.cpp | 288 int errCode = rowDataSet_.DeSerialize(parcel); in DeSerialization() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/common/ |
| H A D | distributeddb_tools_test.cpp | 210 int errCode = sqlite3_exec(db, sql.c_str(), nullptr, nullptr, &errMsg); in ExecSql() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/ |
| H A D | distributeddb_communicator_deep_test.cpp | 59 bool errCode = SetUpEnv(g_envDeviceA, DEVICE_NAME_A); in SetUpTestCase() local
173 int errCode = g_commAB->SendMessage(DEVICE_NAME_B, msgForAB, conf); in HWTEST_F() local
206 int errCode = eachBuff->AllocBufferByTotalLength(100, 0); // 100 totallen without header CreateBufferThenAddIntoScheduler() local
238 int errCode = CreateBufferThenAddIntoScheduler(scheduler, DEVICE_NAME_A, Priority::LOW); HWTEST_F() local
349 int errCode = g_commAB->SendMessage(DEVICE_NAME_B, sendMsgForAB, conf); HWTEST_F() local
410 int errCode = g_commBC->SendMessage(DEVICE_NAME_C, sendMsgForBC, conf); HWTEST_F() local
481 int errCode = g_commAB->SendMessage(DEVICE_NAME_B, sendMsgForAB, conf); HWTEST_F() local
539 int errCode = g_commAB->SendMessage(DEVICE_NAME_B, sendMsg, conf); HWTEST_F() local
[all...] |
| H A D | distributeddb_communicator_send_receive_test.cpp | 55 bool errCode = SetUpEnv(g_envDeviceA, DEVICE_NAME_A); in SetUpTestCase() local
162 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf); in HWTEST_F() local
213 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf); in HWTEST_F() local
243 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf); HWTEST_F() local
290 int errCode = g_commBA->SendMessage(DEVICE_NAME_A, msgForBA, conf); HWTEST_F() local
475 int errCode = g_commBA->SendMessage(DEVICE_NAME_A, msgForBA, conf); HWTEST_F() local
536 int errCode = g_commBA->SendMessage(DEVICE_NAME_A, msgForBA, conf); HWTEST_F() local
597 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf, sendResultNotifier); HWTEST_F() local
657 int errCode = g_commBB->SendMessage(DEVICE_NAME_A, msgForBB, conf); HWTEST_F() local
738 int errCode = g_commAA->SendMessage(DEVICE_NAME_B, msgForAA, conf); HWTEST_F() local
[all...] |