- payload.group.filter = EXCLUDE;
- to_bytes(m_gaddr.to_v4(), (u8*)&payload.group.gaddr);
- auto addr = m_saddrs.cbegin();
- u8 i = 0;
- while (addr != m_saddrs.cend()) {
- to_bytes(addr->to_v4(), (u8*)&payload.group.saddrs[i]);
- addr++;
- i++;
+ to_api(m_gaddr.to_v4(), payload.group.gaddr);
+
+ if (0 == size) {
+ // no sources => (*,G) join
+ payload.group.filter = EXCLUDE;
+ payload.group.n_srcs = 0;
+ } else {
+ // source => (S,G) join
+ payload.group.filter = INCLUDE;
+ u8 i = 0;
+
+ for (auto addr : m_saddrs) {
+ to_api(addr, payload.group.saddrs[i]);
+ i++;
+ }
+ payload.group.n_srcs = i;