Keep mcast addr in addon

Author: linev

plugins/dogma/dogma/UdpTransport.h

@@ -97,6 +97,7 @@ namespace dogma {
          dabc::BufferSize_t fBufferSize{0};      ///< available buffer size
          std::string        fHostName;           ///< host name used to create UDP socket
          int                fRecvBufLen{100000}; ///< recv buf len
+         std::string        fMcastAddr;          ///< mcast address
          unsigned           fMTU{0};             ///< maximal size of packet expected from DOG
          void*              fMtuBuffer{nullptr}; ///< buffer used to skip packets when no normal buffer is available
          int                fSkipCnt{0};         ///< counter used to control buffers skipping
@@ -121,7 +122,7 @@ namespace dogma {
          bool CloseBuffer();
 
       public:
-         UdpAddon(int fd, const std::string &host, int nport, int rcvbuflen, int mtu, bool debug, bool print, int maxloop, double reduce);
+         UdpAddon(int fd, const std::string &host, int nport, int rcvbuflen, const std::string &mcast, int mtu, bool debug, bool print, int maxloop, double reduce);
          ~UdpAddon() override;
 
          bool HasBuffer() const { return !fTgtPtr.null(); }

plugins/dogma/src/Factory.cxx

@@ -111,6 +111,6 @@ dabc::Module* dogma::Factory::CreateTransport(const dabc::Reference& port, const
 
    DOUT0("Start DOGMA UDP transport on %s", url.GetHostNameWithPort().c_str());
 
-   auto addon = new dogma::UdpAddon(fd, host, nport, rcvbuflen, mtu, debug, print, maxloop, reduce);
+   auto addon = new dogma::UdpAddon(fd, host, nport, rcvbuflen, mcast, mtu, debug, print, maxloop, reduce);
 	return new dogma::UdpTransport(cmd, portref, addon, flush, heartbeat);
 }

plugins/dogma/src/UdpTransport.cxx

@@ -34,12 +34,13 @@
 // according to specification maximal UDP packet is 65,507 or 0xFFE3
 #define DEFAULT_MTU 0xFFF0
 
-dogma::UdpAddon::UdpAddon(int fd, const std::string &host, int nport, int rcvbuflen, int mtu, bool debug, bool print, int maxloop, double reduce) :
+dogma::UdpAddon::UdpAddon(int fd, const std::string &host, int nport, int rcvbuflen, const std::string &mcast, int mtu, bool debug, bool print, int maxloop, double reduce) :
    dabc::SocketAddon(fd),
    TransportInfo(nport),
    fTgtPtr(),
    fHostName(host),
    fRecvBufLen(rcvbuflen),
+   fMcastAddr(mcast),
    fMTU(mtu > 0 ? mtu : DEFAULT_MTU),
    fMtuBuffer(nullptr),
    fSkipCnt(0),
@@ -355,7 +356,7 @@ int dogma::UdpTransport::ExecuteCommand(dabc::Command cmd)
       auto addon = static_cast<UdpAddon *>(fAddon());
       if (addon) {
          addon->CloseSocket();
-         int fd = dogma::UdpAddon::OpenUdp(addon->fHostName, addon->fNPort, addon->fRecvBufLen);
+         int fd = dogma::UdpAddon::OpenUdp(addon->fHostName, addon->fNPort, addon->fRecvBufLen, addon->fMcastAddr);
          if (fd <= 0) {
             EOUT("Cannot recreate UDP socket for port %d", addon->fNPort);
             dabc::mgr.StopApplication();