ndidiscovery.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/basicthread.h>
#include <promeki/list.h>
#include <promeki/map.h>
#include <promeki/mutex.h>
#include <promeki/string.h>
#include <promeki/timestamp.h>
#include <promeki/waitcondition.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class NdiDiscovery {
        public:
                struct Record {
                                String    canonicalName;   
                                String    urlAddress;      
                                TimeStamp firstSeen;       
                                TimeStamp lastSeen;        
                };
 
                using RecordList = ::promeki::List<Record>;
 
                static NdiDiscovery &instance();
 
                bool isRunning() const { return _running.value(); }
 
                RecordList sources() const;
 
                RecordList sources(int minUptimeMs) const;
 
                String waitForSource(const String &nameOrPattern, int timeoutMs);
 
                static String matchCanonical(const RecordList &records,
                                             const String     &nameOrPattern);
 
                void setPollIntervalMs(int ms);
 
                void setGroups(const String &commaSeparated);
 
                void setExtraIps(const String &commaSeparated);
 
                int pollIntervalMs() const;
 
                int64_t uptimeMs() const;
 
                NdiDiscovery(const NdiDiscovery &) = delete;
                NdiDiscovery &operator=(const NdiDiscovery &) = delete;
 
        private:
                NdiDiscovery();
                ~NdiDiscovery();
 
                void workerMain();
 
                mutable Mutex                 _mutex;
                mutable WaitCondition         _condRegistry; 
                WaitCondition                 _condConfig;   
                Map<String, Record>           _registry;     
                Atomic<bool>                  _running{false};
                Atomic<bool>                  _shutdown{false};
                Atomic<bool>                  _configDirty{false}; 
                Atomic<int>                   _pollIntervalMs{500};
                String                        _groups;       
                String                        _extraIps;     
                TimeStamp                     _startTime;    
                BasicThread                   _worker;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NDI