/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/timer/ |
H A D | time_broker.cpp | 66 auto timestamp = SteadyClock::GetTimestampMilli() + delayTimeMs; in RegisterCallback() local 67 auto timerInfo = std::make_shared<TimerInfo>(handle, timestamp, std::move(timerCallback)); in RegisterCallback() 68 expiringTimers_[timestamp].push_back(timerInfo); in RegisterCallback() 70 timeline_.push(timestamp); in RegisterCallback() 71 if (timestamp == timeline_.top()) { in RegisterCallback() 72 timer_->StartAt(timestamp); in RegisterCallback() 129 auto timestamp = timeline_.top(); in TimerExpired() local 131 timerInfos.reserve(expiringTimers_[timestamp].size()); in TimerExpired() 132 for (auto& weakTimerInfoPtr : expiringTimers_[timestamp]) { in TimerExpired() 138 expiringTimers_.erase(timestamp); in TimerExpired() 155 auto timestamp = timeline_.top(); RestartTimer() local [all...] |
/foundation/distributeddatamgr/pasteboard/services/dfx/src/ |
H A D | pasteboard_deduplicate_memory.h | 38 int64_t timestamp; member 64 int64_t timestamp = GetTimestamp(); in IsDuplicate() local 65 memory_.push_back(MemoryIdentity({.timestamp = timestamp, .data = data})); in IsDuplicate() 90 int64_t timestamp = GetTimestamp(); in ClearExpiration() local 91 if (timestamp < expirationMS_) { in ClearExpiration() 94 int64_t expirationTimestamp = timestamp - expirationMS_; in ClearExpiration() 96 return expirationTimestamp > identity.timestamp; in ClearExpiration()
|
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/pipeline/ |
H A D | rs_render_display_sync_test.cpp | 98 uint64_t timestamp = 107265354180; in HWTEST_F() local 101 bool isFrameSkip = displaySync->OnFrameSkip(timestamp, period, isDisplaySyncEnabled); in HWTEST_F() 104 timestamp = 107273687513; in HWTEST_F() 105 isFrameSkip = displaySync->OnFrameSkip(timestamp, period, isDisplaySyncEnabled); in HWTEST_F() 108 timestamp = 107293131957; in HWTEST_F() 110 isFrameSkip = displaySync->OnFrameSkip(timestamp, period, isDisplaySyncEnabled); in HWTEST_F() 113 timestamp = 107304243068; in HWTEST_F() 115 isFrameSkip = displaySync->OnFrameSkip(timestamp, period, isDisplaySyncEnabled); in HWTEST_F() 118 timestamp = 107304243068; in HWTEST_F() 120 isFrameSkip = displaySync->OnFrameSkip(timestamp, perio in HWTEST_F() [all...] |
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
H A D | object_asset_machine_test.cpp | 191 auto timestamp = std::to_string(time); in HWTEST_F() local 193 .name = "name_" + timestamp, in HWTEST_F() 194 .uri = "uri_" + timestamp, in HWTEST_F() 195 .modifyTime = "modifyTime_" + timestamp, in HWTEST_F() 196 .size = "size_" + timestamp, in HWTEST_F() 197 .hash = "modifyTime_size_" + timestamp, in HWTEST_F() 200 .storeName = "store_" + timestamp, in HWTEST_F() 201 .tableName = "table_" + timestamp, in HWTEST_F() 202 .primaryKey = {{ "key_" + timestamp, "value_" + timestamp }}, in HWTEST_F() [all...] |
/foundation/communication/dhcp/services/dhcp_client/include/ |
H A D | dhcp_client_state_machine.h | 59 void SendReboot(uint32_t targetIp, time_t timestamp); 61 void DhcpResponseHandle(time_t timestamp); 62 void DhcpAckOrNakPacketHandle(uint8_t type, struct DhcpPacket *packet, time_t timestamp); 63 void ParseDhcpAckPacket(const struct DhcpPacket *packet, time_t timestamp); 64 void ParseDhcpNakPacket(const struct DhcpPacket *packet, time_t timestamp); 74 void DhcpOfferPacketHandle(uint8_t type, const struct DhcpPacket *packet, time_t timestamp); 75 void DhcpRequestHandle(time_t timestamp); 76 void Rebinding(time_t timestamp); 77 void Requesting(time_t timestamp); 78 void Renewing(time_t timestamp); [all...] |
/foundation/distributedhardware/distributed_camera/services/cameraservice/cameraoperator/client/src/callback/ |
H A D | dcamera_photo_callback.cpp | 42 void DCameraPhotoCallback::OnFrameShutter(const int32_t captureId, const uint64_t timestamp) const in OnFrameShutter() 44 DHLOGI("enter, captureId: %{public}d, timestamp: %{public}" PRIu64, captureId, timestamp); in OnFrameShutter() 47 void DCameraPhotoCallback::OnFrameShutterEnd(const int32_t captureId, const uint64_t timestamp) const in OnFrameShutterEnd() 49 DHLOGI("enter, captureId: %{public}d, timestamp: %{public}" PRIu64, captureId, timestamp); in OnFrameShutterEnd() 52 void DCameraPhotoCallback::OnCaptureReady(const int32_t captureId, const uint64_t timestamp) const in OnCaptureReady() 54 DHLOGI("enter, captureId: %{public}d, timestamp: %{public}" PRIu64, captureId, timestamp); in OnCaptureReady()
|
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/transaction/ |
H A D | rs_transaction_proxy_test.cpp | 116 uint64_t timestamp = 1; in HWTEST_F() local 117 RSTransactionProxy::GetInstance()->FlushImplicitTransaction(timestamp); in HWTEST_F() 118 EXPECT_EQ(RSTransactionProxy::GetInstance()->timestamp_, timestamp); in HWTEST_F() 129 uint64_t timestamp = 1; in HWTEST_F() local 133 rsTransactionProxy->FlushImplicitTransaction(timestamp); in HWTEST_F() 144 uint64_t timestamp = 1; in HWTEST_F() local 147 RSTransactionProxy::GetInstance()->FlushImplicitTransaction(timestamp); in HWTEST_F() 148 EXPECT_EQ(RSTransactionProxy::GetInstance()->timestamp_, timestamp); in HWTEST_F() 159 uint64_t timestamp = 1; in HWTEST_F() local 163 RSTransactionProxy::GetInstance()->FlushImplicitTransaction(timestamp); in HWTEST_F() 192 uint64_t timestamp = 1; HWTEST_F() local 210 uint64_t timestamp = 1; HWTEST_F() local 232 uint64_t timestamp = 1; HWTEST_F() local 255 uint64_t timestamp = 1; HWTEST_F() local 268 uint64_t timestamp = 1; HWTEST_F() local 284 uint64_t timestamp = 1; HWTEST_F() local 302 uint64_t timestamp = 1; HWTEST_F() local 314 uint64_t timestamp = 1; HWTEST_F() local 330 uint64_t timestamp = 1; HWTEST_F() local 346 uint64_t timestamp = 1; HWTEST_F() local 363 uint64_t timestamp = 1; HWTEST_F() local 377 uint64_t timestamp = 1; HWTEST_F() local 396 uint64_t timestamp = 1; HWTEST_F() local 418 uint64_t timestamp = 1; HWTEST_F() local 440 uint64_t timestamp = 1; HWTEST_F() local 833 uint64_t timestamp = 1; HWTEST_F() local [all...] |
/foundation/arkui/napi/native_engine/impl/ark/ |
H A D | ark_idle_monitor.cpp | 28 void ArkIdleMonitor::NotifyLooperIdleStart(int64_t timestamp, int idleTime) in NotifyLooperIdleStart() argument 32 if (idleTime < MIN_TRIGGER_GC_IDLE_INTERVAL || !ShouldTryTriggerGC(timestamp)) { in NotifyLooperIdleStart() 35 JSNApi::NotifyLooperIdleStart(vm_, timestamp, idleTime); in NotifyLooperIdleStart() 38 bool ArkIdleMonitor::ShouldTryTriggerGC(int64_t timestamp) in ShouldTryTriggerGC() argument 40 int64_t notifyInterval = timestamp - GetNotifyTimestamp(); in ShouldTryTriggerGC() 42 SetNotifyTimestamp(timestamp); in ShouldTryTriggerGC() 55 void ArkIdleMonitor::NotifyLooperIdleEnd(int64_t timestamp) in NotifyLooperIdleEnd() argument 58 AddIdleDuration(timestamp - GetNotifyTimestamp()); in NotifyLooperIdleEnd() 59 JSNApi::NotifyLooperIdleEnd(vm_, timestamp); in NotifyLooperIdleEnd()
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/flowctrl_manager/ |
H A D | kvstore_flowctrl_manager.cpp | 40 void KvStoreFlowCtrlManager::RefreshTokenBucket(TokenBucket &tokenBucket, uint64_t timestamp)
in RefreshTokenBucket() argument 43 tokenBucket.tokenBucketRefreshTime = timestamp;
in RefreshTokenBucket() 60 bool KvStoreFlowCtrlManager::IsTokenEnoughSlice(TokenBucket &tokenBucket, uint64_t timestamp)
in IsTokenEnoughSlice() argument 66 timestamp - tokenBucket.tokenBucketRefreshTime > tokenBucket.refreshTimeGap) {
in IsTokenEnoughSlice() 67 RefreshTokenBucket(tokenBucket, timestamp);
in IsTokenEnoughSlice()
|
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/receiver/src/ |
H A D | image_receiver.cpp | 230 OHOS::sptr<OHOS::SurfaceBuffer> ImageReceiver::ReadNextImage(int64_t ×tamp) in ReadNextImage() argument 236 SurfaceError surfaceError = listenerConsumerSurface->AcquireBuffer(buffer, flushFence, timestamp, damage); in ReadNextImage() 242 IMAGE_LOGD("[ImageReceiver] ReadNextImage %{public}lld", static_cast<long long>(timestamp)); in ReadNextImage() 249 int64_t timestamp = 0; in ReadNextImage() local 253 SurfaceError surfaceError = listenerConsumerSurface->AcquireBuffer(buffer, flushFence, timestamp, damage); in ReadNextImage() 259 IMAGE_LOGD("[ImageReceiver] ReadNextImage %{public}lld", static_cast<long long>(timestamp)); in ReadNextImage() 263 OHOS::sptr<OHOS::SurfaceBuffer> ImageReceiver::ReadLastImage(int64_t ×tamp) in ReadLastImage() argument 270 SurfaceError surfaceError = listenerConsumerSurface->AcquireBuffer(buffer, flushFence, timestamp, damage); in ReadLastImage() 273 surfaceError = listenerConsumerSurface->AcquireBuffer(buffer, flushFence, timestamp, damage); in ReadLastImage() 277 IMAGE_LOGD("[ImageReceiver] ReadLastImage %{public}lld", static_cast<long long>(timestamp)); in ReadLastImage() 284 int64_t timestamp = 0; ReadLastImage() local 326 int64_t timestamp = 0; NextNativeImage() local 339 int64_t timestamp = 0; LastNativeImage() local [all...] |
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
H A D | distributeddb_storage_single_ver_natural_store_testcase.cpp | 105 Timestamp timestamp; in GetSyncData002() local 106 store->GetMaxTimestamp(timestamp); in GetSyncData002() 110 SyncInputArg inputArg(timestamp + 1, timestamp + 1000, 1024); // no more than 1024 in GetSyncData002() 119 * @tc.desc: To test the function of querying data when the timestamp range 182 Timestamp timestamp = 0; in GetSyncData004() local 183 store->GetMaxTimestamp(timestamp); in GetSyncData004() 192 SyncInputArg inputArg(0, timestamp + 1, 30 * 1024); // 30k per block in GetSyncData004() 245 Timestamp timestamp = 0; in GetSyncData005() local 246 store->GetMaxTimestamp(timestamp); in GetSyncData005() 281 Timestamp timestamp = 0; GetSyncData006() local 664 Timestamp timestamp = 10; // non-zero GetCurrentMaxTimestamp002() local 1151 Timestamp timestamp = 0; DeleteUserKeyValue003() local [all...] |
/foundation/ability/ability_runtime/utils/global/time/include/ |
H A D | time_util.h | 46 auto timestamp = millisecs.count(); in FormatTime() local 47 std::time_t tt = static_cast<std::time_t>(timestamp / SEC_TO_MILLISEC); in FormatTime() 58 auto timestamp = millis.count(); in DefaultCurrentTimeStr() local 59 std::time_t tt = static_cast<std::time_t>(timestamp / SEC_TO_MILLISEC); in DefaultCurrentTimeStr() 64 auto remainder = timestamp % SEC_TO_MILLISEC; in DefaultCurrentTimeStr()
|
/foundation/arkui/ace_engine/test/tools/event_tree_to_graph/src/beans/ |
H A D | touch_point.py | 25 # id: 0, point: Offset (278.00, 551.00), screenPoint: Offset (278.00, 551.00), type: TouchUp, timestamp: 2017-08-25 32 timestamp = '' variable in TouchPoint 47 self.timestamp = get_value_as_str(input_str, get_sample_key(touch_point_keyword, 'timestamp'), 48 get_sample_separator_count(touch_point_keyword, 'timestamp')) 54 if (self.id is None or self.point is None or self.screenPoint is None or self.type is None or self.timestamp 61 return ('id: {}, point: {}, screenPoint: {}, type: {}, timestamp: {}, isInjected: {}' 62 .format(self.id, self.point, self.screenPoint, self.type, self.timestamp, self.isInjected)) 66 .format(str(self.id), self.point, self.screenPoint, self.type, self.timestamp))
|
H A D | procedure_step.py | 25 # procedure: HandleTouchDown, state: READY, disposal: NONE, timestamp: 2017-08-25 15:00:20.177 30 timestamp = '' variable in ProcedureStep 43 self.timestamp = get_value_as_str(input_str, get_sample_key(event_procedure_keyword, 'timestamp'), 44 get_sample_separator_count(event_procedure_keyword, 'timestamp'), True) 48 if self.procedure is None or self.timestamp is None: 67 result_str += ', timestamp: ' + self.timestamp
|
/foundation/communication/dsoftbus/tests/core/bus_center/mock_common/src/ |
H A D | distribute_net_ledger_mock.cpp | 41 int32_t LnnGetDLHeartbeatTimestamp(const char *networkId, uint64_t *timestamp) in LnnGetDLHeartbeatTimestamp() argument 43 return GetDistriLedgerInterface()->LnnGetDLHeartbeatTimestamp(networkId, timestamp); in LnnGetDLHeartbeatTimestamp() 46 int32_t LnnSetDLHeartbeatTimestamp(const char *networkId, const uint64_t timestamp) in LnnSetDLHeartbeatTimestamp() argument 48 return GetDistriLedgerInterface()->LnnSetDLHeartbeatTimestamp(networkId, timestamp); in LnnSetDLHeartbeatTimestamp()
|
/foundation/multimedia/camera_framework/services/camera_service/binder/server/src/ |
H A D | hstream_capture_callback_stub.cpp | 93 uint64_t timestamp = data.ReadUint64(); in HandleOnFrameShutter() local 95 return OnFrameShutter(captureId, timestamp); in HandleOnFrameShutter() 101 uint64_t timestamp = data.ReadUint64(); in HandleOnFrameShutterEnd() local 103 return OnFrameShutterEnd(captureId, timestamp); in HandleOnFrameShutterEnd() 109 uint64_t timestamp = data.ReadUint64(); in HandleOnCaptureReady() local 111 return OnCaptureReady(captureId, timestamp); in HandleOnCaptureReady()
|
/foundation/multimedia/camera_framework/services/camera_service/binder/base/include/ |
H A D | istream_capture_callback.h | 33 virtual int32_t OnFrameShutter(int32_t captureId, uint64_t timestamp) = 0; 35 virtual int32_t OnFrameShutterEnd(int32_t captureId, uint64_t timestamp) = 0; 37 virtual int32_t OnCaptureReady(int32_t captureId, uint64_t timestamp) = 0;
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
H A D | distributeddb_cloud_strategy_test.cpp | 112 localInfo.timestamp = 1u; in HWTEST_F() 125 cloudInfo.timestamp = 2u; // mark 2 means cloud is new in HWTEST_F() 155 localInfo.timestamp = 3u; // mark 3 means local is new in HWTEST_F() 165 * @tc.steps: step11. cloud has same timestamp with local, and local has empty gid in HWTEST_F() 168 cloudInfo.timestamp = localInfo.timestamp; in HWTEST_F() 177 localInfo.timestamp = 4u; in HWTEST_F() 352 * @tc.steps: step2. build cloud and local info, both has same version and diff timestamp in HWTEST_F() 359 localInfo.timestamp = 1; in HWTEST_F() 362 cloudInfo.timestamp in HWTEST_F() [all...] |
/foundation/graphic/graphic_2d/rosen/modules/composer/vsync/test/fuzztest/vsyncsampler_fuzzer/ |
H A D | vsyncsampler_fuzzer.cpp | 61 int64_t timestamp = GetData<int64_t>(); in DoSomethingInterestingWithMyAPI() local 66 vsyncSampler->AddSample(timestamp); in DoSomethingInterestingWithMyAPI() 67 vsyncSampler->AddPresentFenceTime(timestamp); in DoSomethingInterestingWithMyAPI()
|
/foundation/multimedia/camera_framework/services/camera_service/binder/client/include/ |
H A D | hstream_capture_callback_proxy.h | 39 int32_t OnFrameShutter(int32_t captureId, uint64_t timestamp) override; 41 int32_t OnFrameShutterEnd(int32_t captureId, uint64_t timestamp) override; 43 int32_t OnCaptureReady(int32_t captureId, uint64_t timestamp) override;
|
/foundation/multimedia/camera_framework/test/fuzztest/photooutput_fuzzer/ |
H A D | photo_output_fuzzer.h | 30 void OnFrameShutter(const int32_t captureId, const uint64_t timestamp) const override {}
31 void OnFrameShutterEnd(const int32_t captureId, const uint64_t timestamp) const override {}
32 void OnCaptureReady(const int32_t captureId, const uint64_t timestamp) const override {}
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/cameraoperator/client/include/callback/ |
H A D | dcamera_photo_callback.h | 31 void OnFrameShutter(const int32_t captureId, const uint64_t timestamp) const override; 32 void OnFrameShutterEnd(const int32_t captureId, const uint64_t timestamp) const override; 33 void OnCaptureReady(const int32_t captureId, const uint64_t timestamp) const override;
|
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/timer/ |
H A D | time_broker.h | 43 TimerInfo(uint32_t handle, uint64_t timestamp, std::function<void(uint32_t handle)> callback) in TimerInfo() 44 : handle(handle), timestamp(timestamp), timerCallback(std::move(callback)) in TimerInfo() 48 uint64_t timestamp; member
|
/foundation/window/window_manager/previewer/src/ |
H A D | vsync_station.cpp | 76 void VsyncStation::VsyncCallbackInner(int64_t timestamp, int64_t frameCount) in VsyncCallbackInner() argument 86 callback->onCallback(timestamp, frameCount); in VsyncCallbackInner() 90 void VsyncStation::OnVsync(int64_t timestamp, int64_t frameCount, void* client) in OnVsync() argument 94 vsyncClient->VsyncCallbackInner(timestamp, frameCount); in OnVsync()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
H A D | cloud_merge_strategy.cpp | 38 localInfo.timestamp > cloudInfo.timestamp) { in TagSyncDataStatus() 49 bool isTimeSame = (localInfo.timestamp == cloudInfo.timestamp) && (localInfo.wTimestamp == cloudInfo.wTimestamp); in TagSyncDataStatus()
|