| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | frame_retainer.cpp | 47 int errCode = context->SetTimer(RETAIN_SURVAIL_PERIOD_IN_MILLISECOND, action, nullptr, timerId_); in Initialize() local
95 int errCode = work.buffer->ConvertForCrossThread(); in RetainFrame() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | intercepted_data_impl.cpp | 46 int errCode = checkSchema(value); in CheckValue() local
133 int errCode = DBCommon::CalcValueHash(newKey, hashKey); in ModifyKey() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/ |
| H A D | generic_multi_ver_kv_entry.cpp | 35 int errCode = valueObject_.GetSerialData(valueObjectSerial); in GetSerialData() local
[all...] |
| H A D | multi_ver_vacuum_executor_impl.cpp | 57 int errCode = E_OK; in GetVacuumAbleCommits() local
101 int errCode = handle->GetEntriesByVersion(version, recordsInCommit); GetVacuumNeedRecordsByVersion() local
130 int errCode = handle->GetOverwrittenClearTypeEntries(version, clearShadowRecords); GetShadowRecordsOfClearTypeRecord() local
158 int errCode = handle->GetOverwrittenNonClearTypeEntries(version, hashKey, nonClearShadowRecords); GetShadowRecordsOfNonClearTypeRecord() local
184 int errCode = E_OK; StartTransactionForVacuum() local
212 int errCode = writeHandle_->CommitTransaction(MultiTransactionType::ALL_DATA); CommitTransactionForVacuum() local
233 int errCode = writeHandle_->RollBackTransaction(MultiTransactionType::ALL_DATA); RollBackTransactionForVacuum() local
253 int errCode = writeHandle_->DeleteEntriesByHashKey(version, hashKey); DeleteRecordTotally() local
271 int errCode = writeHandle_->UpdateTrimedFlag(version, hashKey); MarkRecordAsVacuumDone() local
289 int errCode = writeHandle_->UpdateTrimedFlag(commitId); MarkCommitAsVacuumDone() local
301 int errCode = E_OK; GetCorrectHandleForUse() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | process_notifier.cpp | 110 int errCode = RuntimeContext::GetInstance()->ScheduleQueuedTask(id, [callback, currentProcess, syncer]() { in NotifyProcess() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_kv_syncer.cpp | 62 int errCode = Sync(devices, SyncModeType::AUTO_PUSH, nullptr, nullptr, false); in EnableAutoSync() local
100 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, devices, engine, storage] { in LocalDataChanged() local
176 int errCode = static_cast<SingleVerKvDBSyncInterface *>(storage)->CheckAndInitQueryCondition(query); SyncConditionCheck() local
235 int errCode = Sync(devices, SyncModeType::AUTO_PUSH, nullptr, nullptr, false); TryFullSync() local
260 int errCode; TriggerSubQuerySync() local
300 int errCode = GenericSyncer::InitSyncEngine(syncInterface); InitSyncEngine() local
328 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, engine, storage, subscribeQuery]() { TriggerAddSubscribeAsync() local
[all...] |
| H A D | single_ver_relational_syncer.cpp | 24 int errCode = SingleVerSyncer::Initialize(syncInterface, isNeedActive); in Initialize() local
51 int errCode = GenerateEachSyncTask(param, syncId, tablesQuery, connectionId, subSyncIdSet); in PrepareSync() local
74 int errCode = E_OK; in GenerateEachSyncTask() local
169 int errCode = UpgradeSchemaVerInMeta(); SchemaChangeCallback() local
182 int errCode = static_cast<RelationalDBSyncInterface *>(storage)->CheckAndInitQueryCondition(query); SyncConditionCheck() local
[all...] |
| H A D | single_ver_data_sync_extend.cpp | 39 int errCode = SingleVerDataSyncUtils::AckMsgErrnoCheck(context, message); in ControlCmdAckRecv() local
103 int errCode = message->SetExternalObject(packet); in SendControlPacket() local
136 int errCode = ackMessage->SetCopiedObject(ack); SendControlAck() local
181 int errCode; SubscribeRequestRecvPre() local
211 int errCode = SubscribeRequestRecvPre(context, packet, message); SubscribeRequestRecv() local
265 int errCode; UnsubscribeRequestRecv() local
322 int errCode = SingleVerDataSyncUtils::QuerySyncCheck(context, isCheckStatus); QuerySyncCheck() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | time_helper.cpp | 32 int errCode = OS::GetCurrentSysTimeInMicrosecond(curTime); in GetSysCurrentTime() local
52 int errCode = OS::GetCurrentSysTimeInMicrosecond(curTime); in GetSysCurrentRawTime() local
92 int errCode = SaveLocalTimeOffset(localTimeOffset); in Initialize() local
150 int errCode in GetMonotonicTime() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_relational_remote_query_test.cpp | 53 int errCode = sqlite3_open(g_storePath.c_str(), &db); in CreateDBAndTable() local
88 int errCode = E_OK; in GetRelationalStore() local
106 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); in InsertData() local
[all...] |
| H A D | distributeddb_storage_data_connection_test.cpp | 55 int errCode; in CreateConnInNewDb() local
105 int errCode = E_OK; in SetUp() local
339 int errCode; in HWTEST_F() local
412 int errCode; in HWTEST_F() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | notification_chain.cpp | 26 RegisterListener( EventType type, const Listener::OnEvent &onEvent, const Listener::OnFinalize &onFinalize, int &errCode) RegisterListener() argument
|
| H A D | performance_analysis.cpp | 127 int errCode = OS::GetCurrentSysTimeInMicrosecond(curTime); in StepTimeRecordStart() local
146 bool errCode = GetTimeRecord(step, timePair); in StepTimeRecordEnd() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/ |
| H A D | sqlite_single_ver_relational_continue_token.cpp | 42 int errCode = GetQuerySyncStatement(db, queryStmt); in GetStatement() local
92 int errCode = E_OK; in GetQuerySyncStatement() local
106 int errCode = E_OK; GetMissQueryStatement() local
118 int errCode = SQLiteUtils::GetStatement(db, sql, stmt); GetDeletedDataStmt() local
184 int errCode; GetCloudStatement() local
209 int errCode = E_OK; ReleaseCloudStatement() local
[all...] |
| H A D | sqlite_relational_database_upgrader.cpp | 38 int errCode = SQLiteUtils::GetLogTableVersion(db_, logTableVersion); in Upgrade() local
75 int errCode = SQLiteUtils::GetLogTableVersion(db_, logTableVersion); ExecuteUpgrade() local
123 int errCode = SQLiteUtils::CheckTableExists(db_, table.first, isExists); UpgradeTrigger() local
167 int errCode = UpgradeLogBaseOnVersion(logTableVersion, table.first); UpgradeLogTable() local
176 int errCode = UpgradeLogBaseOnVersion(logTableVersion, table.first); UpgradeLogTable() local
193 int errCode = SQLiteUtils::AnalysisSchemaFieldDefine(db_, logName, tableInfo); UpgradeLogBaseOnVersion() local
234 int errCode = SQLiteUtils::GetRelationalSchema(db_, schemaDefine); GetParseSchema() local
[all...] |
| /foundation/distributeddatamgr/data_object/frameworks/innerkitsimpl/src/communicator/ |
| H A D | process_communicator_impl.cpp | 39 Status errCode = CommunicationProvider::GetInstance().Start(pi);
in Start() local
50 Status errCode = CommunicationProvider::GetInstance().Stop(pi);
in Stop() local
67 Status errCode = CommunicationProvider::GetInstance().StartWatchDeviceChange(this, pi);
in RegOnDeviceChange() local
73 Status errCode = CommunicationProvider::GetInstance().StopWatchDeviceChange(this, pi);
in RegOnDeviceChange() local
92 Status errCode = CommunicationProvider::GetInstance().StartWatchDataChange(this, pi);
in RegOnDataReceive() local
98 Status errCode = CommunicationProvider::GetInstance().StopWatchDataChange(this, pi); RegOnDataReceive() local
120 Status errCode = CommunicationProvider::GetInstance().SendData(pi, destination, dataInfo, totalLength); SendData() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | communicator_proxy.cpp | 186 int errCode = targetCommunicator->GetRemoteCommunicatorVersion(target, outVersion); in GetRemoteCommunicatorVersion() local
216 int errCode = targetCommunicator->SendMessage(dstTarget, inMsg, config, onEnd); in SendMessage() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_encrypt_database_test.cpp | 102 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); in CheckRekeyWithMultiKvStore() local
145 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); in CheckRekeyWithExistedSnapshot() local
185 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); in CheckRekeyWithExistedObserver() local
411 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); in HWTEST_F() local
461 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); in HWTEST_F() local
508 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); HWTEST_F() local
563 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | kv_virtual_device.cpp | 54 void KvVirtualDevice::SetGetDataErrCode(int whichTime, int errCode, bool isGetDataControl) in SetGetDataErrCode() argument
|
| /foundation/distributeddatamgr/data_share/frameworks/native/common/src/ |
| H A D | ishared_result_set_stub.cpp | 78 int errCode = resultSet_->GetRowCount(count); in HandleGetRowCountRequest() local
90 int errCode = resultSet_->GetAllColumnNames(names); in HandleGetAllColumnNamesRequest() local
116 int errCode = resultSet_->Close(); HandleCloseRequest() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| H A D | process_communication_impl.cpp | 35 Status errCode = endpoint_->Start(); in Start() local
46 Status errCode = endpoint_->Stop(); in Stop() local
69 Status errCode = endpoint_->RegOnDataReceive(dataReciveCallback); in RegOnDataReceive() local
82 Status errCode = endpoint_->SendData(dtsIdentifier, data, length); in SendData() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_executor_subscribe.cpp | 28 int errCode = E_OK; in CheckQueryObjectLegal() local
48 int errCode = SQLiteUtils::StepWithRetry(stmt, isMemDb_); in CheckMissQueryDataItem() local
77 int errCode = E_OK; CheckMissQueryDataItems() local
99 int errCode = E_OK; CheckDataWithQuery() local
155 int errCode = E_OK; AddSubscribeTrigger() local
191 int errCode = E_OK; RemoveSubscribeTrigger() local
211 int errCode = E_OK; RemoveTrigger() local
226 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); RemoveSubscribeTriggerWaterMark() local
253 int errCode = SQLiteUtils::GetStatement(dbHandle_, GET_SYNC_DATA_TIRGGER_SQL, stmt); GetTriggers() local
[all...] |
| /foundation/distributeddatamgr/pasteboard/interfaces/kits/napi/include/ |
| H A D | async_call.h | 48 void SetErrInfo(int32_t errCode, std::string errMsg) in SetErrInfo() argument
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/src/ |
| H A D | rdb_store_manager.cpp | 87 GetRdbStore( const RdbStoreConfig &config, int &errCode, int version, RdbOpenCallback &openCallback) GetRdbStore() argument
230 int errCode = E_OK; ProcessOpenCallback() local
[all...] |
| /foundation/distributeddatamgr/relational_store/test/native/rdb/unittest/ |
| H A D | rdb_bigint_test.cpp | 55 int errCode = E_OK; in SetUpTestCase() local
|