Code Review
/
vpp.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
VAPI/VOM: Removing legacy stats tests, add string type.
[vpp.git]
/
extras
/
vom
/
vom
/
igmp_listen_cmds.cpp
diff --git
a/extras/vom/vom/igmp_listen_cmds.cpp
b/extras/vom/vom/igmp_listen_cmds.cpp
index
683b2b9
..
69e243d
100644
(file)
--- 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,
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)
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
{
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
}
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();
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
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,
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)
: 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;
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());
VAPI_CALL(req.execute());