Home
last modified time | relevance | path

Searched refs:user_ (Results 1 - 25 of 25) sorted by relevance

/foundation/window/window_manager/dmserver/src/
H A Dsensor_connector.cpp45 SensorUser GravitySensorSubscriber::user_; member in OHOS::Rosen::GravitySensorSubscriber
90 if (strcpy_s(user_.name, sizeof(user_.name), "ScreenRotationController") != EOK) { in SubscribeGravitySensor()
94 user_.userData = nullptr; in SubscribeGravitySensor()
95 user_.callback = &HandleGravitySensorEventCallback; in SubscribeGravitySensor()
96 if (SubscribeSensor(SENSOR_TYPE_ID_GRAVITY, &user_) != 0) { in SubscribeGravitySensor()
100 SetBatch(SENSOR_TYPE_ID_GRAVITY, &user_, ORIENTATION_SENSOR_SAMPLING_RATE, ORIENTATION_SENSOR_REPORTING_RATE); in SubscribeGravitySensor()
101 SetMode(SENSOR_TYPE_ID_GRAVITY, &user_, SENSOR_ON_CHANGE); in SubscribeGravitySensor()
102 if (ActivateSensor(SENSOR_TYPE_ID_GRAVITY, &user_) != 0) { in SubscribeGravitySensor()
116 if (DeactivateSensor(SENSOR_TYPE_ID_GRAVITY, &user_) ! in UnsubscribeGravitySensor()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/
H A Dprocess_notifier.cpp62 auto &syncProcess = user_.empty() ? syncProcess_ : multiSyncProcess_[user_]; in UpdateProcess()
87 multiSyncProcess_[user_].errCode = TransferDBErrno(taskInfo.errCode, true); in NotifyProcess()
88 multiSyncProcess_[user_].process = taskInfo.status; in NotifyProcess()
89 if (user_.empty()) { in NotifyProcess()
134 auto &syncProcess = IsMultiUser() ? multiSyncProcess_.at(user_) : syncProcess_; in GetUploadBatchIndex()
147 auto &syncProcess = IsMultiUser() ? multiSyncProcess_.at(user_) : syncProcess_; in ResetUploadBatchIndex()
161 auto &syncProcess = IsMultiUser() ? multiSyncProcess_.at(user_) : syncProcess_; in GetLastUploadInfo()
175 if (user_.empty()) { in GetDownloadInfoByTableName()
178 syncProcess = multiSyncProcess_[user_]; in GetDownloadInfoByTableName()
[all...]
H A Dprocess_notifier.h54 std::string user_; member in DistributedDB::ProcessNotifier
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/cloud/
H A Dsync_event.cpp27 prepareTraceId_(syncParam.prepareTraceId), user_(syncParam.user) in EventInfo()
49 user_ = info.user_;
105 return info_.user_; in GetUser()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/sync_strategies/
H A Dnetwork_sync_strategy.cpp34 if (info.user != user_) { in NetworkSyncStrategy()
58 if (storeInfo.user != user_) { in CheckSyncAction()
60 user_ = storeInfo.user; in CheckSyncAction()
H A Dnetwork_sync_strategy.h54 int32_t user_ = -1; member in OHOS::CloudData::NetworkSyncStrategy
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_cloud_kv_store.cpp66 cloudSchema = std::make_shared<DataBaseSchema>(schema_[user_]); in GetCloudDbSchema()
74 if (schema_.find(user_) == schema_.end()) { in GetCloudTableSchema()
78 auto it = std::find_if(schema_[user_].tables.begin(), schema_[user_].tables.end(), [&](const auto &table) { in GetCloudTableSchema()
81 if (it != schema_[user_].tables.end()) { in GetCloudTableSchema()
159 std::tie(errCode, count) = SqliteCloudKvExecutorUtils::CountCloudData(db, isMemory, timestamp, user_, in GetUploadCount()
175 std::tie(errCode, count) = SqliteCloudKvExecutorUtils::CountAllCloudData({ db, isMemory }, timestampVec, user_, in GetAllUploadCount()
190 token->SetUser(user_); in GetCloudData()
191 recorder_.SetUser(user_); in GetCloudData()
248 std::tie(errCode, dataInfoWithLog) = SqliteCloudKvExecutorUtils::GetLogInfo(db, isMemory, vBucket, user_); in GetInfoByPrimaryKeyOrGid()
[all...]
H A Dsqlite_single_ver_continue_token.cpp157 std::tie(errCode, stmt) = helper.GetKvCloudQueryStmt(db, forcePush, mode, timeRanges_[""].first, user_); in GetCloudQueryStmt()
181 user_ = user; in SetUser()
H A Dsqlite_single_ver_continue_token.h84 std::string user_; member in DistributedDB::SQLiteSingleVerContinueToken
H A Dsqlite_cloud_kv_store.h128 std::string user_; member in DistributedDB::SqliteCloudKvStore
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dsync_manager.cpp49 : user_(user), bundleName_(bundleName), triggerMode_(triggerMode) in SyncInfo()
58 : user_(user), bundleName_(bundleName) in SyncInfo()
67 : user_(user), bundleName_(bundleName), tables_(tables) in SyncInfo()
74 : user_(param.user), bundleName_(param.bundleName), triggerMode_(param.triggerMode) in SyncInfo()
237 auto syncId = GenerateId(syncInfo.user_); in DoCloudSync()
279 if (!Account::GetInstance()->IsVerified(info.user_)) { in IsValid()
308 info.user_, "", info.syncId_ }; in GetPostEventTask()
340 bool createdByDefaultUser = InitDefaultUser(info.user_);
342 cloud.user = info.user_;
351 BatchReport(info.user_, traceId
[all...]
H A Dsync_manager.h81 int32_t user_ = 0; member in OHOS::CloudData::SyncManager::final
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/src/
H A Ddistributed_test_sysinfo.cpp102 &cpuStatFirst_.user_, &cpuStatFirst_.nice_, in GetSysCpuInfo()
109 allFirst = cpuStatFirst_.user_ + cpuStatFirst_.nice_ + cpuStatFirst_.system_ + cpuStatFirst_.idle_ + in GetSysCpuInfo()
122 &cpuStatSecond_.user_, &cpuStatSecond_.nice_, in GetSysCpuInfo()
130 allSecond = cpuStatSecond_.user_ + cpuStatSecond_.nice_ + cpuStatSecond_.system_ + cpuStatSecond_.idle_ + in GetSysCpuInfo()
/foundation/window/window_manager/dmserver/include/
H A Dsensor_connector.h61 static SensorUser user_; member in OHOS::Rosen::GravitySensorSubscriber
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dsync_event.h43 int32_t user_ = 0; member in OHOS::DistributedData::SyncEvent::EventInfo
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/include/
H A Ddistributed_test_sysinfo.h54 uint64_t user_; member
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/
H A Dauto_cache.h87 int32_t user_; member
/foundation/communication/netmanager_base/interfaces/innerkits/netmanagernative/include/
H A Dnetsys_net_diag_data.h112 std::string user_; member
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_proxy.cpp319 downloadData.user = user_; in PutCloudSyncData()
488 user_ = user; in SetUser()
624 if (user_.empty()) { in AppendWithUserIfNeed()
627 return source + "_" + user_; in AppendWithUserIfNeed()
/foundation/communication/netmanager_base/frameworks/native/netmanagernative/
H A Dnetsys_net_diag_data.cpp340 if (!parcel.WriteString(user_)) { in Marshalling()
372 if (!parcel.ReadString(socketInfo.user_)) { in Unmarshalling()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/store/
H A Dauto_cache.cpp250 : store_(delegate), watchers_(watchers), user_(user), meta_(meta) in Delegate()
311 return user_; in GetUser()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dstorage_proxy.h171 std::string user_; member in DistributedDB::StorageProxy
/foundation/communication/netmanager_base/test/netmanagernative/unittest/netsys_manager_test/
H A Dnet_diag_wrapper_test.cpp350 "state_:%{public}s user_:%{public}s programName_:%{public}s recvQueue_:%{public}d " in ShowSocketInfo()
352 lt.protocol_.c_str(), lt.state_.c_str(), lt.user_.c_str(), in ShowSocketInfo()
531 protoSocketInfo.user_ = TEST_STRING_VALUE; in HWTEST_F()
H A Dnetsys_controller_test.cpp765 "foreignAddr_:%{public}s state_:%{public}s user_:%{public}s programName_:%{public}s recvQueue_:%{public}d" in ShowSocketInfo()
767 lt.protocol_.c_str(), lt.localAddr_.c_str(), lt.foreignAddr_.c_str(), lt.state_.c_str(), lt.user_.c_str(), in ShowSocketInfo()
/foundation/communication/netmanager_base/services/netmanagernative/src/netsys/
H A Dnet_diag_wrapper.cpp512 socketInfo.user_ = match[userPos].str(); in ExtractNetProtoSocketsInfo()

Completed in 14 milliseconds