ndiclock.h

Go to the documentation of this file.

 
#pragma once
 
#include <promeki/namespace.h>
#include <promeki/config.h>
 
#if PROMEKI_ENABLE_NDI
 
#include <promeki/atomic.h>
#include <promeki/clock.h>
#include <promeki/clockdomain.h>
#include <promeki/framerate.h>
#include <promeki/mutex.h>
#include <promeki/waitcondition.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class NdiClock : public Clock {
        public:
                static const ClockDomain &domain();
 
                explicit NdiClock(const FrameRate &frameRate = FrameRate());
 
                ~NdiClock() override;
 
                void setLatestTimestamp(int64_t ndiTimestampTicks);
 
                void setFrameRate(const FrameRate &frameRate);
 
                int64_t     resolutionNs() const override;
                ClockJitter jitter() const override;
 
        protected:
                Result<int64_t> raw() const override;
                Error           sleepUntilNs(int64_t targetNs) const override;
 
        private:
                // Atomic backing the fast-path raw() / setLatestTimestamp pair.
                // Stored in nanoseconds so raw() does not multiply on every
                // call — a hot path for downstream timing math.
                mutable Atomic<int64_t> _lastTimestampNs{0};
                Atomic<bool>            _hasTimestamp{false};
                Atomic<bool>            _shutdown{false};
 
                // Wait condition for sleepUntilNs.  Signalled on every
                // setLatestTimestamp so the longest-waiter can wake
                // and recheck.  The mutex guards _frameRate too.
                mutable Mutex         _waitMutex;
                mutable WaitCondition _waitCond;
                FrameRate             _frameRate;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NDI