diff --git a/clock.c b/clock.c index f027305..6ec3e72 100644 --- a/clock.c +++ b/clock.c @@ -96,6 +96,7 @@ struct clock { int pollfd_valid; int nports; /* does not include the UDS port */ int last_port_number; + int sde; struct hash *index2port; int free_running; int freq_est_interval; @@ -341,6 +342,11 @@ static void clock_link_status(void *ctx, int index, int linkup) port_dispatch(p, EV_FAULT_CLEARED, 0); } else { port_dispatch(p, EV_FAULT_DETECTED, 0); + /* + * A port going down can affect the BMCA result. + * Force a state decision event. + */ + c->sde = 1; } } @@ -1463,7 +1469,7 @@ struct PortIdentity clock_parent_identity(struct clock *c) int clock_poll(struct clock *c) { - int cnt, i, sde = 0; + int cnt, i; enum fsm_event event; struct pollfd *cur; struct port *p; @@ -1494,9 +1500,9 @@ int clock_poll(struct clock *c) if (cur[i].revents & (POLLIN|POLLPRI)) { event = port_event(p, i); if (EV_STATE_DECISION_EVENT == event) - sde = 1; + c->sde = 1; if (EV_ANNOUNCE_RECEIPT_TIMEOUT_EXPIRES == event) - sde = 1; + c->sde = 1; port_dispatch(p, event, 0); /* Clear any fault after a little while. */ if (PS_FAULTY == port_state(p)) { @@ -1525,13 +1531,14 @@ int clock_poll(struct clock *c) if (cur[i].revents & (POLLIN|POLLPRI)) { event = port_event(c->uds_port, i); if (EV_STATE_DECISION_EVENT == event) - sde = 1; + c->sde = 1; } } - if (sde) + if (c->sde) { handle_state_decision_event(c); - + c->sde = 0; + } clock_prune_subscriptions(c); return 0; }