Home
last modified time | relevance | path

Searched defs:errCode (Results 1201 - 1225 of 1777) sorted by relevance

1...<<41424344454647484950>>...72

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_subscribe_query_test.cpp127 int errCode = E_OK; in CreateAndGetStore() local
239 int errCode = store->CheckAndInitQueryCondition(queryObject1); in HWTEST_F() local
305 int errCode = store->CheckAndInitQueryCondition(queryObject1); HWTEST_F() local
340 int errCode = store->CheckAndInitQueryCondition(queryObject1); HWTEST_F() local
663 int errCode = store->AddSubscribe(SUBSCRIBE_ID, queryObj, false); HWTEST_F() local
787 int errCode = store->AddSubscribe(SUBSCRIBE_ID, queryObj, false); HWTEST_F() local
843 int errCode = store->AddSubscribe(SUBSCRIBE_ID, queryObj, false); HWTEST_F() local
[all...]
H A Ddistributeddb_storage_register_conflict_test.cpp104 int errCode; in NotifierConnectCallback() local
H A Ddistributeddb_storage_encrypt_test.cpp74 int errCode = sqlite3_open_v2(uri.c_str(), &dbTemp, in Open() local
91 int errCode = sqlite3_exec(g_db, CREATE_SQL.c_str(), nullptr, nullptr, &zErrMsg); in CreateTable() local
104 int errCode = sqlite3_key(g_db, static_cast<const void *>(passwd), strlen(passwd)); in SetEncryptParam() local
130 int errCode = Open(g_db, STORE_ID); OpenWithKey() local
160 int errCode = SetEncryptParam(passwd, iterNumber, algName); InputPasswd() local
170 int errCode = Open(g_db, STORE_ID); Reconnect() local
191 int errCode = sqlite3_exec(g_db, ("INSERT OR REPLACE INTO data VALUES('" + keyStr + "','" + valueStr + PutValue() local
205 int errCode = sqlite3_exec(g_db, ("DELETE FROM data WHERE key='" + keyStr + "';").c_str(), nullptr, DeleteValue() local
220 int errCode = sqlite3_exec(g_db, ("INSERT OR REPLACE INTO data VALUES('" + keyStr + "','" + valueStr + UpdateValue() local
234 int errCode = sqlite3_exec(g_db, ("SELECT value from data WHERE key='" + keyStr + "';").c_str(), GetValue() local
247 int errCode = sqlite3_exec(g_db, ("SELECT " + EXPORT_STRING + "('" + dbName + "');").c_str(), nullptr, nullptr, Export() local
260 int errCode = sqlite3_exec(g_db, ("attach '" + dbName + ".db' as " + dbName + " key '';").c_str(), Attach() local
273 int errCode = sqlite3_exec(g_db, ("attach '" + dbName + ".db' as " + dbName + " key '" + passwd + "';").c_str(), AttachWithKey() local
285 int errCode = PutValue(KEY_1, VALUE_1); MultipleOperation() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dschema_utils.cpp257 int errCode = E_OK; in TransformDefaultValue() local
294 int errCode in ParseAndCheckSchemaAttribute() local
344 int errCode = TransformDefaultValue(attrContext[2], outAttr); // 2nd element is DEFAULT value ParseSchemaAttribute() local
388 int errCode = CheckDollarDotPrefix(tempInPathString, hasPrefix); ParseAndCheckFieldPath() local
[all...]
H A Djson_object.cpp47 uint32_t JsonObject::CalculateNestDepth(const std::string &inString, int &errCode) in CalculateNestDepth() argument
54 uint32_t JsonObject::CalculateNestDepth(const uint8_t *dataBegin, const uint8_t *dataEnd, int &errCode) in CalculateNestDepth() argument
118 int errCode = E_OK; in Parse() local
175 int errCode = E_OK; in Parse() local
256 int errCode = E_OK; IsFieldPathExist() local
267 int errCode = E_OK; GetFieldTypeByFieldPath() local
281 int errCode = E_OK; GetFieldValueByFieldPath() local
319 int errCode = E_OK; GetSubFieldPath() local
340 int errCode = GetSubFieldPath(eachPath, outSubPath); GetSubFieldPath() local
354 int errCode = E_OK; GetSubFieldPathAndType() local
381 int errCode = GetSubFieldPathAndType(eachPath, outSubPathType); GetSubFieldPathAndType() local
395 int errCode = E_OK; GetArraySize() local
414 int errCode = E_OK; GetArrayContentOfStringOrStringArray() local
503 int errCode = LocateJsonValueByFieldPath(inPath, exact, nearest, nearDepth); MoveToPath() local
534 int errCode = MoveToPath(inPath, exact, nearest); InsertField() local
559 int errCode = MoveToPath(inPath, exact, nearest); InsertField() local
584 int errCode = LocateJsonValueByFieldPath(inPath, exact, nearest, nearDepth); DeleteField() local
730 int errCode = E_OK; GetObjectArrayByFieldPath() local
753 int errCode = E_OK; GetObjectByFieldPath() local
774 int errCode = E_OK; GetStringArrayByFieldPath() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/kv/
H A Dsqlite_local_kvdb.cpp55 int errCode = operation->RekeyRecover(kvDBProp); in Open() local
72 int errCode = DBCommon::CreateStoreDirectory(dataDir, identifierDir, subDir, createIfNecessary); in Open() local
86 NewConnection(int &errCode) NewConnection() argument
112 int errCode = E_OK; Export() local
134 int errCode = storageEngine_->TryToDisable(true, OperatePerm::IMPORT_MONOPOLIZE_PERM); Import() local
164 int errCode = SQLiteUtils::OpenDatabase(option, db); RunExportLogic() local
182 int errCode = SQLiteUtils::OpenDatabase(option, db); RunRekeyLogic() local
204 GetHandle(bool isWrite, int &errCode, OperatePerm perm) const GetHandle() argument
220 int errCode = E_OK; GetVersion() local
275 int errCode = storageEngine_->InitSQLiteStorageEngine(poolSize, option); InitStorageEngine() local
315 int errCode = GetWorkDir(properties, baseDir); BackupCurrentDatabase() local
336 int errCode = GetWorkDir(properties, baseDir); ImportDatabase() local
376 int errCode = SQLiteUtils::GetVersion(openProp, dbVersion); CheckVersionAndUpgradeIfNeed() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_executor_cache.cpp31 int errCode = -E_NOT_SUPPORT; in PrepareForSavingCacheData() local
56 int errCode = E_OK; in ResetForSavingCacheData() local
72 int errCode = E_OK; ResetForMigrateCacheData() local
87 int errCode = DBCommon::CalcValueHash(REMOVE_DEVICE_DATA_KEY, hashKey); RemoveDeviceDataInCacheMode() local
139 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetMinVersionCacheData() local
171 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); MigrateRmDevData() local
209 int errCode = SQLiteUtils::AttachNewDatabase(dbHandle_, type, passwd, attachDbAbsPath, attachAsName); AttachMainDbAndCacheDb() local
239 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetMaxVersionInCacheDb() local
262 int errCode = PutIntoConflictAndCommitForMigrateCache(dataItem, {dataItem.dev.empty(), dataItem.dev}, notify, MigrateDataItem() local
304 int errCode = E_OK; CheckDataWithQuery() local
343 int errCode = CheckDataWithQuery(dataItems); MigrateDataItems() local
384 int errCode = StartTransaction(TransactType::IMMEDIATE); MigrateSyncDataByVersion() local
438 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); DelCacheDbDataByVersion() local
471 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, sql); VacuumLocalData() local
493 int errCode = SQLiteUtils::ExecuteRawSQL(dbHandle_, migrateLocaldataSql); MigrateLocalData() local
505 int errCode = BindPrimaryKeySyncDataInCacheMode(statement, hashKey, recordVersion); BindSyncDataInCacheMode() local
548 int errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_CACHE_SYNC_HASH_KEY_INDEX, hashKey, false); BindPrimaryKeySyncDataInCacheMode() local
563 int errCode = SQLiteUtils::BindInt64ToStatement(statement, BIND_CACHE_SYNC_STAMP_INDEX, dataItem.timestamp); BindTimestampSyncDataInCacheMode() local
581 int errCode = SQLiteUtils::BindBlobToStatement(statement, BIND_CACHE_SYNC_DEV_INDEX, devVect, true); BindDevSyncDataInCacheMode() local
597 int errCode = E_OK; GetExpandedCheckSql() local
633 int errCode = E_OK; SaveSyncDataItemInCacheMode() local
673 int errCode = BindSyncDataInCacheMode(statement, dataItem, hashKey, recordVersion); SaveSyncDataToCacheDatabase() local
688 int errCode = SQLiteUtils::GetStatement(dbHandle_, INSERT_CACHE_LOCAL_SQL, statement); PutLocalDataToCacheDB() local
711 int errCode = SQLiteUtils::BindBlobToStatement(statement, BindLocalDataInCacheMode() local
755 int errCode = PrepareForNotifyConflictAndObserver(dataItem, deviceInfo, notify, isPermitForceWrite); PutIntoConflictAndCommitForMigrateCache() local
789 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); GetMinTimestampInCacheDB() local
817 int errCode = GetMinTimestampInCacheDB(minTimeInCache); InitMigrateTimestampOffset() local
850 int errCode = InitMigrateTimestampOffset(); ProcessTimestampForSyncDataInCacheDB() local
907 int errCode = PrepareForSavingData(querySQL, insertSQL, updateSQL, migrateSyncStatements_); InitMigrateData() local
923 int errCode = migrateSyncStatements_.ResetStatement(); ClearMigrateData() local
944 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); DeleteMetaData() local
973 int errCode = SQLiteUtils::GetStatement(dbHandle_, sql, statement); DeleteMetaDataByPrefixKey() local
[all...]
H A Dsqlite_single_ver_database_upgrader.cpp107 int errCode = GetDbVersion(dbFilePath, option, currentVersion); in TransferDatabasePath() local
140 int errCode = SQLiteUtils::RollbackTransaction(db_); in EndUpgrade() local
204 int errCode = SQLiteUtils::ExecuteRawSQL(db_, item); in UpgradeFromDatabaseVersion() local
231 int errCode = SQLiteUtils::OpenDatabase(optionTmp, db); GetDbVersion() local
272 int errCode = RuntimeContext::GetInstance()->GetSecurityOption(dbFilePath, dbOpt); SetPathSecOptWithCheck() local
288 int errCode = RuntimeContext::GetInstance()->SetSecurityOption(dbItemFilePath, secOption); SetPathSecOptWithCheck() local
311 int errCode = E_OK; SetSecOption() local
356 int errCode = OS::RemoveFile(upgradeLockFile); MoveDatabaseToNewDir() local
434 int errCode = SQLiteUtils::ExecuteRawSQL(db_, updateSQL); UpgradeTime() local
443 int errCode = SQLiteUtils::CheckTableExists(db_, "meta_data", isCreate, true); MigrateMetaFromMetaDB() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dquery_sync_water_mark_helper.cpp79 int errCode = GetMetadataFromDb(deleteWaterMarkKey, value); in LoadDeleteSyncDataToCache() local
98 int errCode = querySyncCache_.Get(cacheKey, queryWaterMark); in GetQueryWaterMarkInCacheAndDb() local
143 int errCode = GetQueryWaterMarkInCacheAndDb(cacheKey, queryWaterMark); SetLastQueryTime() local
155 int errCode = GetQueryWaterMarkInCacheAndDb(cacheKey, queryWaterMark); SetRecvQueryWaterMarkWithoutLock() local
169 int errCode = GetQueryWaterMarkInCacheAndDb(cacheKey, queryWaterMark); SetSendQueryWaterMark() local
181 int errCode = OS::GetCurrentSysTimeInMicrosecond(queryWaterMark.lastUsedTime); UpdateCacheAndSave() local
196 int errCode = OS::GetCurrentSysTimeInMicrosecond(queryWaterMark.lastUsedTime); PutQueryWaterMarkToDB() local
208 int errCode = SerializeQueryWaterMark(queryWaterMark, dbValue); SaveQueryWaterMarkToDB() local
230 int errCode = GetMetadataFromDb(dbKey, dbValue); GetQueryWaterMarkFromDB() local
315 int errCode = GetDeleteWaterMarkFromCache(hashId, deleteWaterMark); SetSendDeleteSyncWaterMark() local
330 int errCode = GetDeleteWaterMarkFromCache(hashId, deleteWaterMark); SetRecvDeleteSyncWaterMark() local
342 int errCode = SaveDeleteWaterMarkToDB(dbKey, deleteWaterMark); UpdateDeleteSyncCacheAndSave() local
358 int errCode = GetDeleteWaterMarkFromDB(hashDeviceId, waterMark); GetDeleteWaterMarkFromCache() local
381 int errCode = GetMetadataFromDb(dbKey, dbValue); GetDeleteWaterMarkFromDB() local
394 int errCode = SerializeDeleteWaterMark(deleteWaterMark, dbValue); SaveDeleteWaterMarkToDB() local
483 int errCode = GetMetadataFromDb(id, value); RemoveLeastUsedQuerySyncItems() local
535 int errCode = storage_->DeleteMetaDataByPrefixKey(prefixKey); ResetRecvQueryWaterMark() local
[all...]
H A Dcommit_history_sync.cpp104 void CommitHistorySyncAckPacket::SetErrorCode(int32_t errCode) in SetErrorCode() argument
180 int errCode = E_OK; in CalculateLen() local
239 int errCode = GetDeviceLatestCommit(commitMap); SyncStart() local
261 int errCode = RunPermissionCheck(context->GetDeviceId()); RequestRecvCallback() local
301 int32_t errCode; AckRecvCallback() local
353 int errCode = parcel.WriteUInt64(commitMap.size()); RequestPacketSerialization() local
428 int errCode = inMsg->SetExternalObject<>(packet); RequestPacketDeSerialization() local
477 int errCode = parcel.WriteMultiVerCommits(commits); AckPacketSerialization() local
527 int errCode = inMsg->SetExternalObject<>(packet); AckPacketDeSerialization() local
549 int errCode = communicateHandle_->SendMessage(deviceId, inMsg, conf); Send() local
559 int errCode = storagePtr_->GetDeviceLatestCommit(readCommitMap); GetDeviceLatestCommit() local
588 int errCode = GetLocalDeviceInfo(localDevice); GetCommitTree() local
635 int errCode = message->SetExternalObject(packet); SendRequestPacket() local
685 int errCode = ackMessage->SetExternalObject(packet); SendAckPacket() local
717 int errCode = RuntimeContext::GetInstance()->RunPermissionCheck(param, flag); RunPermissionCheck() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dvalue_slice_sync.cpp51 void ValueSliceHashPacket::SetErrCode(int32_t errCode) in SetErrCode() argument
83 void ValueSlicePacket::SetErrorCode(int32_t errCode) in SetErrorCode() argument
139 int errCode = E_OK; in CalculateLen() local
196 int errCode = GetValidValueSliceHashNode(context, valueSliceHashNode); SyncStart() local
251 int errCode = GetValueSlice(valueSliceHashNode, valueSlice); RequestRecvCallback() local
277 int errCode = E_OK; AckRecvCallback() local
319 int errCode = message->SetExternalObject(packet); SendFinishedRequest() local
364 int32_t errCode = parcel.WriteInt(ackCode); RequestPacketSerialization() local
404 int errCode = inMsg->SetExternalObject<>(packet); RequestPacketDeSerialization() local
438 int32_t errCode = parcel.WriteInt(ackCode); AckPacketSerialization() local
481 int errCode = inMsg->SetExternalObject<>(packet); AckPacketDeSerialization() local
531 int errCode = communicateHandle_->SendMessage(deviceId, inMsg, conf); Send() local
555 int errCode = message->SetExternalObject<>(packet); SendRequestPacket() local
599 int errCode = ackMessage->SetExternalObject<>(packet); SendAckPacket() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_interfaces_relational_tracker_table_test.cpp158 int errCode; in CheckExtendAndCursor() local
229 int errCode; in CheckDropTableAndReopenDb() local
571 int errCode; in HWTEST_F() local
892 int errCode; in HWTEST_F() local
1208 int errCode; in HWTEST_F() local
[all...]
H A Ddistributeddb_interfaces_data_operation_syncdb_test.cpp1354 int errCode = E_OK; in HWTEST_F() local
H A Ddistributeddb_interfaces_auto_launch_test.cpp292 int errCode = E_OK; in GetKvDB() local
300 int errCode; in PutSyncData() local
322 int errCode; in GetSyncData() local
534 int errCode; in SetAutoLaunchLifeCycleTime() local
H A Ddistributeddb_interfaces_database_test.cpp1265 int errCode = E_OK; in HWTEST_F() local
[all...]
H A Ddistributeddb_interfaces_import_and_export_test.cpp104 int errCode = g_passwd1.SetValue(passwdBuffer1.data(), passwdBuffer1.size()); in SetUpTestCase() local
365 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); in HWTEST_F() local
433 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); HWTEST_F() local
511 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); HWTEST_F() local
569 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); HWTEST_F() local
[all...]
H A Ddistributeddb_interfaces_import_and_export_rd_test.cpp106 int errCode = g_passwd1.SetValue(passwdBuffer1.data(), passwdBuffer1.size()); in SetUpTestCase() local
497 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); in HWTEST_F() local
546 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); HWTEST_F() local
643 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); HWTEST_F() local
700 int errCode = passwd.SetValue(passwdBuffer.data(), passwdBuffer.size()); HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/
H A Dkv_store_delegate_manager.cpp52 IKvDBConnection *GetOneConnectionWithRetry(const KvDBProperties &properties, int &errCode) in GetOneConnectionWithRetry() argument
216 int errCode; in GetKvStore() local
337 int errCode; in GetKvStore() local
421 int errCode in DeleteKvStore() local
443 int errCode = KvDBManager::SetProcessLabel(appId, userId); SetProcessLabel() local
491 int errCode = KvDBManager::CalculateKvStoreSize(properties, size); GetKvStoreDiskSize() local
556 int errCode = RuntimeContext::GetInstance()->SetPermissionCheckCallback(callback); SetPermissionCheckCallback() local
562 int errCode = RuntimeContext::GetInstance()->SetPermissionCheckCallback(callback); SetPermissionCheckCallback() local
574 int errCode = AutoLaunch::GetAutoLaunchProperties(param, DBTypeInner::DB_KV, true, ptr); EnableKvStoreAutoLaunch() local
600 int errCode = RuntimeContext::GetInstance()->DisableKvStoreAutoLaunch(hashIdentifier, dualIdentifier, userId); DisableKvStoreAutoLaunch() local
633 int errCode = RuntimeContext::GetInstance()->SetSyncActivationCheckCallback(callback); SetSyncActivationCheckCallback() local
640 int errCode = RuntimeContext::GetInstance()->NotifyUserChanged(); NotifyUserChanged() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dsync_operation.cpp185 int errCode = RuntimeContext::GetInstance()->ScheduleQueuedTask(identifier_, [this, tmpStatus] { in Finished() local
268 int errCode = RuntimeContext::GetInstance()->ScheduleQueuedTask(identifier_, [this, syncProcessMap] { in ExeSyncProcessCallFun() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/
H A Dstorage_fuzzer.cpp118 int errCode = sqlite3_open(STORE_PATH.c_str(), &db); in CreateDB() local
149 int errCode = E_OK; in GetRelationalStore() local
307 int errCode; in GetHashKey() local
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_general_store_test.cpp178 auto errCode = CryptoManager::GetInstance().GenerateRootKey(); in HWTEST_F() local
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/
H A Dgeneric_single_ver_kv_entry.cpp117 int errCode = parcel.WriteUInt32(targetVersion); in SerializeData() local
128 int errCode = parcel.WriteUInt32(size); in SerializeDatas() local
154 int errCode = AdaptToVersion(OperType::CAL_LEN, targetVersion, len); CalculateLen() local
187 int errCode = AdaptToVersion(OperType::DESERIALIZE, version, parcel, len); DeSerializeData() local
235 int errCode = E_OK; AdaptToVersion() local
280 int errCode = parcel.WriteUInt64(writeTimestamp); SerializeDataByLaterVersion() local
292 int errCode = SerializeDataByFirstVersion(parcel); SerializeDataByVersion() local
383 int errCode = SerializeDatas(kvEntries, parcel, compressInfo.targetVersion); Compress() local
405 int errCode = inst->Uncompress(srcData, destData, destLen); Uncompress() local
434 int errCode = DataCompression::TransferCompressionAlgo(algoType, compressAlgo); DeSerializeCompressedDatas() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
H A Dsqlite_relational_store_connection.cpp50 int errCode = RollBack(); in Close() local
98 int errCode = E_OK; in StartTransaction() local
123 int errCode = writeHandle_->Commit(); Commit() local
138 int errCode = writeHandle_->Rollback(); RollBack() local
152 int errCode = store->CreateDistributedTable(tableName, syncType); CreateDistributedTable() local
167 int errCode = store->RemoveDeviceData(); RemoveDeviceData() local
196 int errCode = store->CleanCloudData(mode); DoClean() local
216 int errCode = store->RemoveDeviceData(device, tableName); RemoveDeviceData() local
262 int errCode = store->Sync(syncParam, GetConnectionId()); SyncToDevice() local
365 int errCode = store->SetTrackerTable(schema); SetTrackerTable() local
450 int errCode = store->Sync(option, onProcess, taskId); Sync() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/communicator/
H A Ddistributeddb_communicator_test.cpp66 bool errCode = SetUpEnv(g_envDeviceA, DEVICE_NAME_A); in SetUpTestCase() local
483 int errCode = g_envDeviceA.commAggrHandle->RegOnConnectCallback( in HWTEST_F() local
548 int errCode = g_envDeviceB.commAggrHandle->RegCommunicatorLackCallback( in HWTEST_F() local
643 int errCode = g_envDeviceB.commAggrHandle->RegCommunicatorLackCallback( HWTEST_F() local
731 int errCode = g_envDeviceB.commAggrHandle->RegCommunicatorLackCallback([](const LabelType &commLabel, HWTEST_F() local
805 int errCode = g_envDeviceB.commAggrHandle->RegCommunicatorLackCallback([](const LabelType &commLabel, HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_single_ver_p2p_subscribe_sync_test.cpp348 int errCode = SingleVerSerializeManager::Serialization(buffer, len, &msg); in HWTEST_F() local
397 int errCode = subManager.ReserveLocalSubscribeQuery(device, querySyncObj1); in HWTEST_F() local

Completed in 30 milliseconds

1...<<41424344454647484950>>...72