--- fwsync/driver/fwsync_workers.c 2022/08/18 13:42:37 1.17 +++ fwsync/driver/fwsync_workers.c 2022/08/19 09:37:33 1.18 @@ -57,8 +57,8 @@ fwsync_add_alias(const struct fws_proto *pkt) DTRACE(); - if (!pkt || pkt->fws_addrtype == 1) - return 0; /* skip ethernet packet */ + if (!pkt || pkt->fws_addrtype == 1 || pkt->fws_addrtype == 6) + return 0; /* skip packet */ p = malloc(sizeof(struct fws_sndpkt), M_FWSYNC, M_NOWAIT | M_ZERO); if (!p) { @@ -304,25 +304,29 @@ fwsync_alias_sync(const void *arg, const void *extdata DTRACE(); mtx_lock(&fws_mtx_n); - pkt = TAILQ_FIRST(&fwsync_natpkt); - if (pkt) + while ((pkt = TAILQ_FIRST(&fwsync_natpkt))) { TAILQ_REMOVE(&fwsync_natpkt, pkt, sp_next); - mtx_unlock(&fws_mtx_n); - if (!pkt) /* update queue is empty */ - return 0; + if (!(fws_cfg.cfg.on & CFG_SYNC_EDGE)) { + free(pkt, M_FWSYNC); + continue; + } - if (!(fws_cfg.cfg.on & CFG_SYNC_EDGE)) { + if (t) { + LIBALIAS_LOCK(t->lib); + AddLink(t->lib, pkt->sp_proto.fws_saddr, + pkt->sp_proto.fws_daddr, + pkt->sp_proto.fws_aaddr, + pkt->sp_proto.fws_sport, + pkt->sp_proto.fws_dport, + pkt->sp_proto.fws_aport, + pkt->sp_proto.fws_linktype | LINK_SYNC_MASK); + LIBALIAS_UNLOCK(t->lib); + } + free(pkt, M_FWSYNC); - return EAGAIN; } + mtx_unlock(&fws_mtx_n); - LIBALIAS_LOCK(t->lib); - AddLink(t->lib, pkt->sp_proto.fws_saddr, pkt->sp_proto.fws_daddr, pkt->sp_proto.fws_aaddr, - pkt->sp_proto.fws_sport, pkt->sp_proto.fws_dport, pkt->sp_proto.fws_aport, - pkt->sp_proto.fws_linktype | LINK_SYNC_MASK); - LIBALIAS_UNLOCK(t->lib); - - free(pkt, M_FWSYNC); return 0; }