@@ -107,15 +107,15 @@ class DataProcessingDevice : public fair::mq::Device
107107 std::unique_ptr<ConfigParamRegistry> mConfigRegistry ;
108108 ServiceRegistry& mServiceRegistry ;
109109
110- uint64_t mLastSlowMetricSentTimestamp = 0 ; // / The timestamp of the last time we sent slow metrics
111- uint64_t mLastMetricFlushedTimestamp = 0 ; // / The timestamp of the last time we actually flushed metrics
112- uint64_t mBeginIterationTimestamp = 0 ; // / The timestamp of when the current ConditionalRun was started
110+ uint64_t mLastSlowMetricSentTimestamp = 0 ; // / The timestamp of the last time we sent slow metrics
111+ uint64_t mLastMetricFlushedTimestamp = 0 ; // / The timestamp of the last time we actually flushed metrics
112+ uint64_t mBeginIterationTimestamp = 0 ; // / The timestamp of when the current ConditionalRun was started
113113 std::vector<fair::mq::RegionInfo> mPendingRegionInfos ; // / A list of the region infos not yet notified.
114114 std::mutex mRegionInfoMutex ;
115- ProcessingPolicies mProcessingPolicies ; // / User policies related to data processing
116- bool mWasActive = false ; // / Whether or not the device was active at last iteration.
117- std::vector<uv_work_t > mHandles ; // / Handles to use to schedule work.
118- std::vector<TaskStreamInfo> mStreams ; // / Information about the task running in the associated mHandle.
115+ ProcessingPolicies mProcessingPolicies ; // / User policies related to data processing
116+ bool mWasActive = false ; // / Whether or not the device was active at last iteration.
117+ std::vector<uv_work_t > mHandles ; // / Handles to use to schedule work.
118+ std::vector<TaskStreamInfo> mStreams ; // / Information about the task running in the associated mHandle.
119119 // / Handle to wake up the main loop from other threads
120120 // / e.g. when FairMQ notifies some callback in an asynchronous way
121121 uv_async_t * mAwakeHandle = nullptr ;
0 commit comments