summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--igmp.c31
-rw-r--r--server.c8
2 files changed, 21 insertions, 18 deletions
diff --git a/igmp.c b/igmp.c
index a9a8980..dc43a9f 100644
--- a/igmp.c
+++ b/igmp.c
@@ -289,13 +289,13 @@ igmp_parse(struct igmp *igmp)
debug(DBG_IGMP, "igmp_v3_membership_report %s -> %s",
src_str, dst_str);
- debug(DBG_IGMP, "IGMPv3\n"
- " * Type: %x\n"
- " * Reserved: %u\n"
- " * Csum: %u\n"
- " * Reserved: %u\n"
- " * NRecs: %u\n"
- " * Size: %zu bytes",
+ debug(DBG_IGMP, "IGMPv3"
+ " type: %x,"
+ " reserved: %u,"
+ " csum: %u,"
+ " reserved: %u,"
+ " nrecs: %u,"
+ " size: %zu\n",
igmp_msg->v3.type,
igmp_msg->v3.reserved1,
igmp_msg->v3.checksum,
@@ -330,12 +330,12 @@ igmp_parse(struct igmp *igmp)
inet_ntop(AF_INET, &grp, grp_str, sizeof(grp_str));
debug(DBG_IGMP, "received IGMPv3 record to %s", grp_str);
- debug(DBG_IGMP, "IGMPv3 rec"
- " * Type: %un"
- " * Auxlen: %u"
- " * NSrcs: %u"
- " * Addr: %s"
- " * Size: %zu bytes",
+ debug(DBG_IGMP, "IGMPv3 rec, "
+ " type: %u,"
+ " auxlen: %u,"
+ " nsrcs: %u,"
+ " addr: %s,"
+ " size: %zu bytes",
record->type,
record->auxlen,
record->nsrcs,
@@ -363,9 +363,10 @@ igmp_parse(struct igmp *igmp)
pos += sizeof(record->saddr[addr]);
}
+ /* Yes, EXCL, not INCL, see RFC3376 */
if ((htonl(record->addr) == cinet_addr(224,0,2,60)) &&
- ((record->type == IGMP_V3_REC_MODE_IS_INCL) ||
- (record->type == IGMP_V3_REC_MODE_CH_INCL)))
+ ((record->type == IGMP_V3_REC_MODE_IS_EXCL) ||
+ (record->type == IGMP_V3_REC_MODE_CH_EXCL)))
igmp_match();
body_len -= record->auxlen;
diff --git a/server.c b/server.c
index 5811ef5..e1c2f4b 100644
--- a/server.c
+++ b/server.c
@@ -247,7 +247,7 @@ server_exec(struct server *server, const char *cmd)
r = clone(server_exec_child, stack + sizeof(stack),
CLONE_VM | CLONE_VFORK | CLONE_PIDFD | SIGCHLD,
(void *)cmd, &pidfd);
- if (r != 0) {
+ if (r < 0) {
error("clone: %m: %i", r);
return false;
}
@@ -435,9 +435,11 @@ server_announce_cb(struct uring_task *task, int res)
assert_return(task);
if (res < 0)
- error("failure %i", res);
+ error("%s: failure %i", server->name, res);
+ else if (res == server->ann_buf.len)
+ debug(DBG_ANN, "%s: ok (%i)", server->name, res);
else
- debug(DBG_ANN, "result %i", res);
+ debug(DBG_ANN, "%s: unexpected result: %i", server->name, res);
uring_task_set_fd(&server->ann_task, -1);
}