diff options
Diffstat (limited to 'extras/vom/vom/igmp_listen_cmds.cpp')
-rw-r--r-- | extras/vom/vom/igmp_listen_cmds.cpp | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/extras/vom/vom/igmp_listen_cmds.cpp b/extras/vom/vom/igmp_listen_cmds.cpp index 683b2b9a0b6..69e243d9b4a 100644 --- a/extras/vom/vom/igmp_listen_cmds.cpp +++ b/extras/vom/vom/igmp_listen_cmds.cpp @@ -22,7 +22,7 @@ namespace VOM { namespace igmp_listen_cmds { listen_cmd::listen_cmd(HW::item<bool>& item, const handle_t& itf, - const boost::asio::ip::address& gaddr, + const boost::asio::ip::address_v4& gaddr, const igmp_listen::src_addrs_t& saddrs) : rpc_cmd(item) , m_itf(itf) @@ -34,7 +34,8 @@ listen_cmd::listen_cmd(HW::item<bool>& item, bool listen_cmd::operator==(const listen_cmd& other) const { - return ((m_itf == other.m_itf) && (m_gaddr == other.m_gaddr)); + return ((m_itf == other.m_itf) && (m_gaddr == other.m_gaddr) && + (m_saddrs == other.m_saddrs)); } rc_t @@ -45,7 +46,7 @@ listen_cmd::issue(connection& con) auto& payload = req.get_request().get_payload(); payload.group.sw_if_index = m_itf.value(); - to_api(m_gaddr.to_v4(), payload.group.gaddr); + to_api(m_gaddr, payload.group.gaddr); if (0 == size) { // no sources => (*,G) join @@ -85,7 +86,7 @@ listen_cmd::to_string() const unlisten_cmd::unlisten_cmd(HW::item<bool>& item, const handle_t& itf, - const boost::asio::ip::address& gaddr) + const boost::asio::ip::address_v4& gaddr) : rpc_cmd(item) , m_itf(itf) , m_gaddr(gaddr) @@ -107,7 +108,7 @@ unlisten_cmd::issue(connection& con) payload.group.sw_if_index = m_itf.value(); payload.group.n_srcs = 0; payload.group.filter = INCLUDE; - to_api(m_gaddr.to_v4(), payload.group.gaddr); + to_api(m_gaddr, payload.group.gaddr); VAPI_CALL(req.execute()); |