MulticastSocket.hpp

Go to the documentation of this file.

 
#pragma once
 
#include "common.hpp"
#include "DatagramSocket.hpp"
 
#include <cstddef>
#include <optional>
#include <string>
#include <string_view>
 
namespace jsocketpp
{

class MulticastSocket : public DatagramSocket
{
  public:
    MulticastSocket(Port localPort, std::string_view localAddress,
                    std::optional<std::size_t> recvBufferSize = std::nullopt,
                    std::optional<std::size_t> sendBufferSize = std::nullopt,
                    std::optional<std::size_t> internalBufferSize = std::nullopt, bool reuseAddress = true,
                    int soRecvTimeoutMillis = -1, int soSendTimeoutMillis = -1, bool nonBlocking = false,
                    bool dualStack = true, bool autoBind = true);

    void joinGroup(const std::string& groupAddr, const std::string& iface);

    void leaveGroup(const std::string& groupAddr, const std::string& iface = "");

    void setMulticastInterface(const std::string& iface);

    [[nodiscard]] std::string getMulticastInterface() const { return _currentInterface; }

    void setTimeToLive(int ttl);

    int getTimeToLive() const { return _ttl; }

    void setLoopbackMode(bool enable);

    [[nodiscard]] bool getLoopbackMode() const { return _loopbackEnabled; }

    std::string getCurrentGroup() const;
 
  protected:
    static in_addr resolveIPv4(std::string_view host);

    static in6_addr resolveIPv6(std::string_view host);

    static unsigned int toIfIndexFromString(const std::string& iface);
 
  private:
    std::string _currentGroup{};     
    std::string _currentInterface{}; 

    int _ttl = 1;

    bool _loopbackEnabled = true;
};
 
} // namespace jsocketpp