/foundation/multimedia/camera_framework/services/deferred_processing_service/src/base/timer/ |
D | time_broker.cpp | 68 auto timestamp = SteadyClock::GetTimestampMilli() + delayTimeMs; in RegisterCallback() local 69 auto timerInfo = std::make_shared<TimerInfo>(handle, timestamp, std::move(timerCallback)); in RegisterCallback() 70 expiringTimers_[timestamp].push_back(timerInfo); in RegisterCallback() 72 timeline_.push(timestamp); in RegisterCallback() 73 if (timestamp == timeline_.top()) { in RegisterCallback() 74 timer_->StartAt(timestamp); in RegisterCallback() 120 auto timestamp = timeline_.top(); in TimerExpired() local 122 timerInfos.reserve(expiringTimers_[timestamp].size()); in TimerExpired() 123 for (auto& weakTimerInfoPtr : expiringTimers_[timestamp]) { in TimerExpired() 129 expiringTimers_.erase(timestamp); in TimerExpired() [all …]
|
/foundation/communication/dhcp/services/dhcp_client/include/ |
D | dhcp_client_state_machine.h | 57 void SendReboot(uint32_t targetIp, time_t timestamp); 59 void DhcpResponseHandle(time_t timestamp); 60 void DhcpAckOrNakPacketHandle(uint8_t type, struct DhcpPacket *packet, time_t timestamp); 61 void ParseDhcpAckPacket(const struct DhcpPacket *packet, time_t timestamp); 62 void ParseDhcpNakPacket(const struct DhcpPacket *packet, time_t timestamp); 71 void DhcpOfferPacketHandle(uint8_t type, const struct DhcpPacket *packet, time_t timestamp); 72 void DhcpRequestHandle(time_t timestamp); 73 void Rebinding(time_t timestamp); 74 void Requesting(time_t timestamp); 75 void Renewing(time_t timestamp); [all …]
|
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/transaction/ |
D | rs_transaction_proxy_test.cpp | 116 uint64_t timestamp = 1; variable 117 RSTransactionProxy::GetInstance()->FlushImplicitTransaction(timestamp); 128 uint64_t timestamp = 1; variable 132 rsTransactionProxy->FlushImplicitTransaction(timestamp); 143 uint64_t timestamp = 1; variable 146 RSTransactionProxy::GetInstance()->FlushImplicitTransaction(timestamp); 157 uint64_t timestamp = 1; variable 161 RSTransactionProxy::GetInstance()->FlushImplicitTransaction(timestamp); 172 uint64_t timestamp = 1; variable 179 RSTransactionProxy::GetInstance()->FlushImplicitTransaction(timestamp); [all …]
|
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/pipeline/ |
D | rs_render_display_sync_test.cpp | 98 uint64_t timestamp = 107265354180; variable 101 bool isFrameSkip = displaySync->OnFrameSkip(timestamp, period, isDisplaySyncEnabled); 104 timestamp = 107273687513; 105 isFrameSkip = displaySync->OnFrameSkip(timestamp, period, isDisplaySyncEnabled); 108 timestamp = 107293131957; 110 isFrameSkip = displaySync->OnFrameSkip(timestamp, period, isDisplaySyncEnabled); 113 timestamp = 107304243068; 115 isFrameSkip = displaySync->OnFrameSkip(timestamp, period, isDisplaySyncEnabled); 118 timestamp = 107304243068; 120 isFrameSkip = displaySync->OnFrameSkip(timestamp, period, isDisplaySyncEnabled);
|
D | rs_surface_handler_test.cpp | 115 int64_t timestamp = 0; variable 121 rSSurfaceHandlerPtr_->SetBuffer(buffer, acquireFence, damage, timestamp); 128 rSSurfaceHandlerPtr_->SetBuffer(buffer, acquireFence, damage, timestamp); 222 buffer1.timestamp = 100; // timestamps of two buffers can be any different number 223 buffer2.timestamp = 200; 247 buffer1.timestamp = 100; // timestamps of two buffers can be any different number 248 buffer2.timestamp = 200; 272 buffer1.timestamp = 100; // timestamps of two buffers can be any different number 273 buffer2.timestamp = 200;
|
/foundation/distributedhardware/distributed_camera/services/cameraservice/cameraoperator/client/src/callback/ |
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) con… 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_surface/sync_fence/src/ |
D | sync_fence_timeline.cpp | 42 ns_sec_t timestamp = signaledTimestamps_.load(std::memory_order_relaxed); in GetSignalTimestamp() local 43 if (timestamp != SyncFence::FENCE_PENDING_TIMESTAMP) { in GetSignalTimestamp() 44 return timestamp; in GetSignalTimestamp() 55 timestamp = fence->SyncFileReadTimestamp(); in GetSignalTimestamp() 56 if (timestamp != SyncFence::FENCE_PENDING_TIMESTAMP) { in GetSignalTimestamp() 59 signaledTimestamps_.store(timestamp, std::memory_order_relaxed); in GetSignalTimestamp() 61 return timestamp; in GetSignalTimestamp()
|
/foundation/graphic/graphic_2d/utils/sync_fence/src/ |
D | sync_fence_timeline.cpp | 42 ns_sec_t timestamp = signaledTimestamps_.load(std::memory_order_relaxed); in GetSignalTimestamp() local 43 if (timestamp != SyncFence::FENCE_PENDING_TIMESTAMP) { in GetSignalTimestamp() 44 return timestamp; in GetSignalTimestamp() 55 timestamp = fence->SyncFileReadTimestamp(); in GetSignalTimestamp() 56 if (timestamp != SyncFence::FENCE_PENDING_TIMESTAMP) { in GetSignalTimestamp() 59 signaledTimestamps_.store(timestamp, std::memory_order_relaxed); in GetSignalTimestamp() 61 return timestamp; in GetSignalTimestamp()
|
/foundation/multimedia/image_framework/frameworks/innerkitsimpl/receiver/src/ |
D | image_receiver.cpp | 223 OHOS::sptr<OHOS::SurfaceBuffer> ImageReceiver::ReadNextImage(int64_t ×tamp) in ReadNextImage() argument 229 …Error surfaceError = listenerConsumerSurface->AcquireBuffer(buffer, flushFence, timestamp, damage); in ReadNextImage() 235 IMAGE_LOGD("[ImageReceiver] ReadNextImage %{public}lld", static_cast<long long>(timestamp)); in ReadNextImage() 242 int64_t timestamp = 0; in ReadNextImage() local 246 …Error surfaceError = listenerConsumerSurface->AcquireBuffer(buffer, flushFence, timestamp, damage); in ReadNextImage() 252 IMAGE_LOGD("[ImageReceiver] ReadNextImage %{public}lld", static_cast<long long>(timestamp)); in ReadNextImage() 256 OHOS::sptr<OHOS::SurfaceBuffer> ImageReceiver::ReadLastImage(int64_t ×tamp) in ReadLastImage() argument 263 …Error surfaceError = listenerConsumerSurface->AcquireBuffer(buffer, flushFence, timestamp, damage); in ReadLastImage() 266 … surfaceError = listenerConsumerSurface->AcquireBuffer(buffer, flushFence, timestamp, damage); in ReadLastImage() 270 IMAGE_LOGD("[ImageReceiver] ReadLastImage %{public}lld", static_cast<long long>(timestamp)); in ReadLastImage() [all …]
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
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() 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() 255 SyncInputArg inputArg(0, timestamp + 1, 100 * 1024); // for 100k in GetSyncData005() 281 Timestamp timestamp = 0; in GetSyncData006() local [all …]
|
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/flowctrl_manager/ |
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/graphic/graphic_2d/rosen/modules/hyper_graphic_manager/core/frame_rate_manager/ |
D | hgm_idle_detector.cpp | 25 void HgmIdleDetector::UpdateSurfaceTime(const std::string& name, uint64_t timestamp) in UpdateSurfaceTime() argument 36 frameTimeMap_[name] = timestamp; in UpdateSurfaceTime() 39 bool HgmIdleDetector::GetSurFaceIdleState(uint64_t timestamp) in GetSurFaceIdleState() argument 48 if ((timestamp - it->second) > BUFFER_IDLE_TIME_OUT) { in GetSurFaceIdleState()
|
D | hgm_frame_rate_manager.h | 64 uint64_t timestamp = 0; member 68 timestamp = curTimestamp; in SetTimestamp() 90 str << "TIMESTAMP:" << timestamp << "."; in ToString() 112 …void UniProcessDataForLtpo(uint64_t timestamp, std::shared_ptr<RSRenderFrameRateLinker> rsFrameRat… 132 void ProcessPendingRefreshRate(uint64_t timestamp); 135 void UpdateSurfaceTime(const std::string& name, uint64_t timestamp); 139 void UpdateGuaranteedPlanVote(uint64_t timestamp); 144 void HandleFrameRateChangeForLTPO(uint64_t timestamp, bool isDvsyncOn);
|
/foundation/multimedia/camera_framework/services/camera_service/binder/server/src/ |
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/communication/dsoftbus/tests/core/bus_center/mock_common/src/ |
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/interfaces/inner_api/native/camera/include/output/ |
D | metadata_output.h | 45 MetadataObject(MetadataObjectType type, double timestamp, Rect rect); 59 MetadataFaceObject(double timestamp, Rect rect); 125 …void ProcessFaceRectangles(int64_t timestamp, const std::shared_ptr<OHOS::Camera::CameraMetadata>&… 127 int32_t ProcessMetaObjects(int64_t timestamp, std::vector<sptr<MetadataObject>>& metaObjects, 151 int32_t ProcessMetadataBuffer(void* buffer, int64_t timestamp); 153 …int64_t timestamp, const camera_metadata_item_t& metadataItem, std::vector<sptr<MetadataObject>>& …
|
D | photo_output.h | 62 virtual void OnFrameShutter(const int32_t captureId, const uint64_t timestamp) const = 0; 70 virtual void OnFrameShutterEnd(const int32_t captureId, const uint64_t timestamp) const = 0; 78 virtual void OnCaptureReady(const int32_t captureId, const uint64_t timestamp) const = 0; 122 virtual void OnFrameShutter(const int32_t captureId, const uint64_t timestamp) const = 0; 414 int32_t OnFrameShutter(const int32_t captureId, const uint64_t timestamp) override; 422 int32_t OnFrameShutterEnd(const int32_t captureId, const uint64_t timestamp) override; 430 int32_t OnCaptureReady(const int32_t captureId, const uint64_t timestamp) override;
|
/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_client/unittest/pipeline/ |
D | rs_render_thread_test.cpp | 153 uint64_t timestamp = 123456; //for test variable 155 renderThread->OnVsync(timestamp, 0); 156 EXPECT_EQ(timestamp, 123456); 193 uint64_t timestamp = 1234; //for test variable 196 renderThread->Animate(timestamp); 197 EXPECT_EQ(timestamp, 1234); 204 renderThread->Animate(timestamp); 205 EXPECT_EQ(timestamp, 1234);
|
/foundation/multimedia/camera_framework/frameworks/native/camera/src/output/ |
D | metadata_output.cpp | 29 MetadataFaceObject::MetadataFaceObject(double timestamp, Rect rect) in MetadataFaceObject() argument 30 : MetadataObject(MetadataObjectType::FACE, timestamp, rect) in MetadataFaceObject() 33 MetadataObject::MetadataObject(MetadataObjectType type, double timestamp, Rect rect) in MetadataObject() argument 34 : type_(type), timestamp_(timestamp), box_(rect) in MetadataObject() 214 void MetadataOutput::ProcessFaceRectangles(int64_t timestamp, in ProcessFaceRectangles() argument 236 ret = ProcessMetaObjects(timestamp, metaObjects, metadataItem, metadata, isNeedMirror); in ProcessFaceRectangles() 246 int32_t MetadataOutput::ProcessMetaObjects(int64_t timestamp, std::vector<sptr<MetadataObject>>& me… in ProcessMetaObjects() argument 256 int64_t formatTimestamp = timestamp / timeUnit; in ProcessMetaObjects() 300 …int64_t timestamp, const camera_metadata_item_t& metadataItem, std::vector<sptr<MetadataObject>>& … in ProcessFaceRectangles() argument 305 int32_t MetadataObjectListener::ProcessMetadataBuffer(void* buffer, int64_t timestamp) in ProcessMetadataBuffer() argument [all …]
|
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/transaction/ |
D | rs_transaction_proxy.cpp | 120 void RSTransactionProxy::FlushImplicitTransaction(uint64_t timestamp, const std::string& abilityNam… in FlushImplicitTransaction() argument 126 timestamp_ = std::max(timestamp, timestamp_); in FlushImplicitTransaction() 145 void RSTransactionProxy::FlushImplicitTransactionFromRT(uint64_t timestamp) in FlushImplicitTransactionFromRT() argument 149 implicitTransactionDataFromRT_->timestamp_ = timestamp; in FlushImplicitTransactionFromRT() 176 void RSTransactionProxy::Commit(uint64_t timestamp) in Commit() argument 185 implicitRemoteTransactionDataStack_.top()->timestamp_ = timestamp; in Commit() 192 void RSTransactionProxy::CommitSyncTransaction(uint64_t timestamp, const std::string& abilityName) in CommitSyncTransaction() argument 195 timestamp_ = std::max(timestamp, timestamp_); in CommitSyncTransaction() 198 implicitCommonTransactionDataStack_.top()->timestamp_ = timestamp; in CommitSyncTransaction() 208 implicitRemoteTransactionDataStack_.top()->timestamp_ = timestamp; in CommitSyncTransaction()
|
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
D | cloud_merge_strategy.cpp | 34 if (localInfo.timestamp > cloudInfo.timestamp) { in TagSyncDataStatus() 45 …bool isTimeSame = (localInfo.timestamp == cloudInfo.timestamp) && (localInfo.wTimestamp == cloudIn… in TagSyncDataStatus()
|
/foundation/multimedia/camera_framework/services/deferred_processing_service/include/base/timer/ |
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/multimedia/camera_framework/services/camera_service/binder/base/include/ |
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/window/window_manager/previewer/src/ |
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/communication/dhcp/services/dhcp_client/src/ |
D | dhcp_client_state_machine.cpp | 572 void DhcpClientStateMachine::InitSelecting(time_t timestamp) in InitSelecting() argument 577 m_timeoutTimestamp = timestamp + TIMEOUT_MORE_WAIT_SEC; in InitSelecting() 598 m_timeoutTimestamp = timestamp + uTimeoutSec; in InitSelecting() 672 void DhcpClientStateMachine::SendReboot(uint32_t targetIp, time_t timestamp) in SendReboot() argument 679 m_timeoutTimestamp = timestamp + uTimeoutSec; in SendReboot() 683 void DhcpClientStateMachine::Reboot(time_t timestamp) in Reboot() argument 695 if (timestamp > ipInfoCached.absoluteLeasetime) { in Reboot() 707 SendReboot(lastAssignedIpv4Addr, timestamp); in Reboot() 711 void DhcpClientStateMachine::Requesting(time_t timestamp) in Requesting() argument 718 m_timeoutTimestamp = timestamp; in Requesting() [all …]
|