mdnstypebrowser.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_MDNS
#include <cstdint>
#include <promeki/namespace.h>
#include <promeki/atomic.h>
#include <promeki/buffer.h>
#include <promeki/duration.h>
#include <promeki/error.h>
#include <promeki/list.h>
#include <promeki/map.h>
#include <promeki/mdnsservicetype.h>
#include <promeki/mutex.h>
#include <promeki/networkinterface.h>
#include <promeki/objectbase.h>
#include <promeki/socketaddress.h>
#include <promeki/timestamp.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class MdnsManager;
 
class MdnsTypeBrowser : public ObjectBase {
                PROMEKI_OBJECT(MdnsTypeBrowser, ObjectBase)
        public:
                static constexpr int64_t InitialQueryIntervalMs = 1000;
 
                static constexpr int64_t MaxQueryIntervalMs = 3600 * 1000;
 
                explicit MdnsTypeBrowser(ObjectBase *parent = nullptr);
 
                ~MdnsTypeBrowser() override;
 
                void setManager(MdnsManager *manager);
 
                MdnsManager *manager() const { return _manager; }
 
                MdnsManager *effectiveManager() const;
 
                bool isActive() const { return _active.value(); }
 
                Error start();
 
                void stop();
 
                Error sendQuery();
 
                void handlePacket(const Buffer &data, const SocketAddress &sender,
                                  const NetworkInterface &iface);
 
                void onManagerTick(const TimeStamp &now);
 
                List<MdnsServiceType> types() const;
 
                void clearCache();
 
                PROMEKI_SIGNAL(typeFound, MdnsServiceType);
                PROMEKI_SIGNAL(typeLost,  MdnsServiceType);
 
        private:
                struct Entry {
                        MdnsServiceType type;
                        TimeStamp       lastSeen;
                        Duration        ttl;
                };
 
                MdnsManager        *_manager = nullptr;
                mutable Mutex       _entriesMtx;
                Map<String, Entry>  _entries;   // keyed by case-folded type fqdn
                Atomic<bool>        _active;
 
                TimeStamp           _nextQueryAt;
                Duration            _currentInterval;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_MDNS