multicastmanager.h

Go to the documentation of this file.

 
#pragma once
 
#include <promeki/core/objectbase.h>
#include <promeki/core/error.h>
#include <promeki/core/list.h>
#include <promeki/core/string.h>
#include <promeki/network/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