multicastmanager.h

Go to the documentation of this file.

 
#pragma once
 
 
#include <promeki/config.h>
#if PROMEKI_ENABLE_NETWORK
#include <promeki/objectbase.h>
#include <promeki/error.h>
#include <promeki/list.h>
#include <promeki/string.h>
#include <promeki/socketaddress.h>
 
PROMEKI_NAMESPACE_BEGIN
 
class UdpSocket;
 
class MulticastManager : public ObjectBase {
                PROMEKI_OBJECT(MulticastManager, ObjectBase)
        public:
                MulticastManager(ObjectBase *parent = nullptr);
 
                ~MulticastManager() override;
 
                Error joinGroup(const SocketAddress &group, UdpSocket *socket);
 
                Error joinGroup(const SocketAddress &group, UdpSocket *socket, const String &iface);
 
                Error leaveGroup(const SocketAddress &group, UdpSocket *socket);
 
                void leaveAllGroups();
 
                List<SocketAddress> activeGroups() const;
 
                bool isMemberOf(const SocketAddress &group) const;
 
                Error joinSourceGroup(const SocketAddress &group, const SocketAddress &source, UdpSocket *socket);
 
                Error leaveSourceGroup(const SocketAddress &group, const SocketAddress &source, UdpSocket *socket);
 
                void setDefaultInterface(const String &iface) { _defaultInterface = iface; }
 
                const String &defaultInterface() const { return _defaultInterface; }
 
                PROMEKI_SIGNAL(groupJoined, SocketAddress);
 
                PROMEKI_SIGNAL(groupLeft, SocketAddress);
 
        private:
                struct Membership {
                                SocketAddress group;
                                UdpSocket    *socket;
                                SocketAddress source; // For SSM, null otherwise
                                bool          isSSM = false;
                };
 
                List<Membership> _memberships;
                String           _defaultInterface;
};
 
PROMEKI_NAMESPACE_END
 
#endif // PROMEKI_ENABLE_NETWORK