diff options
author | Marco Pfatschbacher <mpf@cvs.openbsd.org> | 2008-06-15 19:00:58 +0000 |
---|---|---|
committer | Marco Pfatschbacher <mpf@cvs.openbsd.org> | 2008-06-15 19:00:58 +0000 |
commit | c90e5a5502fbeebc73f91a48389aaf3d3993f23c (patch) | |
tree | 684fe76935e61f2eab3599f83f1d5bee6857fcce /sys/net/trunklacp.c | |
parent | 0c3c7ab9fd68d47e11c21794a48e8e2e42551dc9 (diff) |
A bit of cleanup:
- we prefer u_int*_t over uint_*t.
- static is bad for debugging.
- header files should not contain functions.
Diffstat (limited to 'sys/net/trunklacp.c')
-rw-r--r-- | sys/net/trunklacp.c | 288 |
1 files changed, 159 insertions, 129 deletions
diff --git a/sys/net/trunklacp.c b/sys/net/trunklacp.c index 61e1492fed6..92fe9f2fde9 100644 --- a/sys/net/trunklacp.c +++ b/sys/net/trunklacp.c @@ -1,4 +1,4 @@ -/* $OpenBSD: trunklacp.c,v 1.1 2008/06/15 06:56:09 mpf Exp $ */ +/* $OpenBSD: trunklacp.c,v 1.2 2008/06/15 19:00:57 mpf Exp $ */ /* $NetBSD: ieee8023ad_lacp.c,v 1.3 2005/12/11 12:24:54 christos Exp $ */ /* $FreeBSD:ieee8023ad_lacp.c,v 1.15 2008/03/16 19:25:30 thompsa Exp $ */ @@ -64,10 +64,10 @@ #define LACP_SYSTEM_PRIO 0x8000 #define LACP_PORT_PRIO 0x8000 -const uint8_t ethermulticastaddr_slowprotocols[ETHER_ADDR_LEN] = +const u_int8_t ethermulticastaddr_slowprotocols[ETHER_ADDR_LEN] = { 0x01, 0x80, 0xc2, 0x00, 0x00, 0x02 }; -static const struct tlv_template lacp_info_tlv_template[] = { +const struct tlv_template lacp_info_tlv_template[] = { { LACP_TYPE_ACTORINFO, sizeof(struct tlvhdr) + sizeof(struct lacp_peerinfo) }, { LACP_TYPE_PARTNERINFO, @@ -77,13 +77,13 @@ static const struct tlv_template lacp_info_tlv_template[] = { { 0, 0 }, }; -static const struct tlv_template marker_info_tlv_template[] = { +const struct tlv_template marker_info_tlv_template[] = { { MARKER_TYPE_INFO, sizeof(struct tlvhdr) + sizeof(struct lacp_markerinfo) }, { 0, 0 }, }; -static const struct tlv_template marker_response_tlv_template[] = { +const struct tlv_template marker_response_tlv_template[] = { { MARKER_TYPE_RESPONSE, sizeof(struct tlvhdr) + sizeof(struct lacp_markerinfo) }, { 0, 0 }, @@ -91,103 +91,103 @@ static const struct tlv_template marker_response_tlv_template[] = { typedef void (*lacp_timer_func_t)(struct lacp_port *); -static void lacp_fill_actorinfo(struct lacp_port *, struct lacp_peerinfo *); -static void lacp_fill_markerinfo(struct lacp_port *, +void lacp_fill_actorinfo(struct lacp_port *, struct lacp_peerinfo *); +void lacp_fill_markerinfo(struct lacp_port *, struct lacp_markerinfo *); -static uint64_t lacp_aggregator_bandwidth(struct lacp_aggregator *); -static void lacp_suppress_distributing(struct lacp_softc *, +u_int64_t lacp_aggregator_bandwidth(struct lacp_aggregator *); +void lacp_suppress_distributing(struct lacp_softc *, struct lacp_aggregator *); -static void lacp_transit_expire(void *); -static void lacp_update_portmap(struct lacp_softc *); -static void lacp_select_active_aggregator(struct lacp_softc *); -static uint16_t lacp_compose_key(struct lacp_port *); -static int tlv_check(const void *, size_t, const struct tlvhdr *, +void lacp_transit_expire(void *); +void lacp_update_portmap(struct lacp_softc *); +void lacp_select_active_aggregator(struct lacp_softc *); +u_int16_t lacp_compose_key(struct lacp_port *); +int tlv_check(const void *, size_t, const struct tlvhdr *, const struct tlv_template *, int); -static void lacp_tick(void *); +void lacp_tick(void *); -static void lacp_fill_aggregator_id(struct lacp_aggregator *, +void lacp_fill_aggregator_id(struct lacp_aggregator *, const struct lacp_port *); -static void lacp_fill_aggregator_id_peer(struct lacp_peerinfo *, +void lacp_fill_aggregator_id_peer(struct lacp_peerinfo *, const struct lacp_peerinfo *); -static int lacp_aggregator_is_compatible(const struct lacp_aggregator *, +int lacp_aggregator_is_compatible(const struct lacp_aggregator *, const struct lacp_port *); -static int lacp_peerinfo_is_compatible(const struct lacp_peerinfo *, +int lacp_peerinfo_is_compatible(const struct lacp_peerinfo *, const struct lacp_peerinfo *); -static struct lacp_aggregator *lacp_aggregator_get(struct lacp_softc *, +struct lacp_aggregator *lacp_aggregator_get(struct lacp_softc *, struct lacp_port *); -static void lacp_aggregator_addref(struct lacp_softc *, +void lacp_aggregator_addref(struct lacp_softc *, struct lacp_aggregator *); -static void lacp_aggregator_delref(struct lacp_softc *, +void lacp_aggregator_delref(struct lacp_softc *, struct lacp_aggregator *); /* receive machine */ -static int lacp_pdu_input(struct lacp_port *, struct mbuf *); -static int lacp_marker_input(struct lacp_port *, struct mbuf *); -static void lacp_sm_rx(struct lacp_port *, const struct lacpdu *); -static void lacp_sm_rx_timer(struct lacp_port *); -static void lacp_sm_rx_set_expired(struct lacp_port *); -static void lacp_sm_rx_update_ntt(struct lacp_port *, +int lacp_pdu_input(struct lacp_port *, struct mbuf *); +int lacp_marker_input(struct lacp_port *, struct mbuf *); +void lacp_sm_rx(struct lacp_port *, const struct lacpdu *); +void lacp_sm_rx_timer(struct lacp_port *); +void lacp_sm_rx_set_expired(struct lacp_port *); +void lacp_sm_rx_update_ntt(struct lacp_port *, const struct lacpdu *); -static void lacp_sm_rx_record_pdu(struct lacp_port *, +void lacp_sm_rx_record_pdu(struct lacp_port *, const struct lacpdu *); -static void lacp_sm_rx_update_selected(struct lacp_port *, +void lacp_sm_rx_update_selected(struct lacp_port *, const struct lacpdu *); -static void lacp_sm_rx_record_default(struct lacp_port *); -static void lacp_sm_rx_update_default_selected(struct lacp_port *); -static void lacp_sm_rx_update_selected_from_peerinfo(struct lacp_port *, +void lacp_sm_rx_record_default(struct lacp_port *); +void lacp_sm_rx_update_default_selected(struct lacp_port *); +void lacp_sm_rx_update_selected_from_peerinfo(struct lacp_port *, const struct lacp_peerinfo *); /* mux machine */ -static void lacp_sm_mux(struct lacp_port *); -static void lacp_set_mux(struct lacp_port *, enum lacp_mux_state); -static void lacp_sm_mux_timer(struct lacp_port *); +void lacp_sm_mux(struct lacp_port *); +void lacp_set_mux(struct lacp_port *, enum lacp_mux_state); +void lacp_sm_mux_timer(struct lacp_port *); /* periodic transmit machine */ -static void lacp_sm_ptx_update_timeout(struct lacp_port *, uint8_t); -static void lacp_sm_ptx_tx_schedule(struct lacp_port *); -static void lacp_sm_ptx_timer(struct lacp_port *); +void lacp_sm_ptx_update_timeout(struct lacp_port *, u_int8_t); +void lacp_sm_ptx_tx_schedule(struct lacp_port *); +void lacp_sm_ptx_timer(struct lacp_port *); /* transmit machine */ -static void lacp_sm_tx(struct lacp_port *); -static void lacp_sm_assert_ntt(struct lacp_port *); +void lacp_sm_tx(struct lacp_port *); +void lacp_sm_assert_ntt(struct lacp_port *); -static void lacp_run_timers(struct lacp_port *); -static int lacp_compare_peerinfo(const struct lacp_peerinfo *, +void lacp_run_timers(struct lacp_port *); +int lacp_compare_peerinfo(const struct lacp_peerinfo *, const struct lacp_peerinfo *); -static int lacp_compare_systemid(const struct lacp_systemid *, +int lacp_compare_systemid(const struct lacp_systemid *, const struct lacp_systemid *); -static void lacp_port_enable(struct lacp_port *); -static void lacp_port_disable(struct lacp_port *); -static void lacp_select(struct lacp_port *); -static void lacp_unselect(struct lacp_port *); -static void lacp_disable_collecting(struct lacp_port *); -static void lacp_enable_collecting(struct lacp_port *); -static void lacp_disable_distributing(struct lacp_port *); -static void lacp_enable_distributing(struct lacp_port *); -static int lacp_xmit_lacpdu(struct lacp_port *); -static int lacp_xmit_marker(struct lacp_port *); +void lacp_port_enable(struct lacp_port *); +void lacp_port_disable(struct lacp_port *); +void lacp_select(struct lacp_port *); +void lacp_unselect(struct lacp_port *); +void lacp_disable_collecting(struct lacp_port *); +void lacp_enable_collecting(struct lacp_port *); +void lacp_disable_distributing(struct lacp_port *); +void lacp_enable_distributing(struct lacp_port *); +int lacp_xmit_lacpdu(struct lacp_port *); +int lacp_xmit_marker(struct lacp_port *); #if defined(LACP_DEBUG) -static void lacp_dump_lacpdu(const struct lacpdu *); -static const char *lacp_format_partner(const struct lacp_peerinfo *, char *, +void lacp_dump_lacpdu(const struct lacpdu *); +const char *lacp_format_partner(const struct lacp_peerinfo *, char *, size_t); -static const char *lacp_format_lagid(const struct lacp_peerinfo *, +const char *lacp_format_lagid(const struct lacp_peerinfo *, const struct lacp_peerinfo *, char *, size_t); -static const char *lacp_format_lagid_aggregator(const struct lacp_aggregator *, +const char *lacp_format_lagid_aggregator(const struct lacp_aggregator *, char *, size_t); -static const char *lacp_format_state(uint8_t, char *, size_t); -static const char *lacp_format_mac(const uint8_t *, char *, size_t); -static const char *lacp_format_systemid(const struct lacp_systemid *, char *, +const char *lacp_format_state(u_int8_t, char *, size_t); +const char *lacp_format_mac(const u_int8_t *, char *, size_t); +const char *lacp_format_systemid(const struct lacp_systemid *, char *, size_t); -static const char *lacp_format_portid(const struct lacp_portid *, char *, +const char *lacp_format_portid(const struct lacp_portid *, char *, size_t); -static void lacp_dprintf(const struct lacp_port *, const char *, ...) +void lacp_dprintf(const struct lacp_port *, const char *, ...) __attribute__((__format__(__printf__, 2, 3))); #define LACP_DPRINTF(a) lacp_dprintf a #else @@ -199,7 +199,7 @@ static void lacp_dprintf(const struct lacp_port *, const char *, ...) * XXX should be configurable. */ -static const struct lacp_peerinfo lacp_partner_admin = { +const struct lacp_peerinfo lacp_partner_admin = { { 0xffff }, /* lip_systemid.lsi_prio */ 0, /* lip_key */ { 0xffff }, /* lip_portid.lpi_prio */ @@ -213,7 +213,7 @@ static const struct lacp_peerinfo lacp_partner_admin = { #endif }; -static const lacp_timer_func_t lacp_timer_funcs[LACP_NTIMER] = { +const lacp_timer_func_t lacp_timer_funcs[LACP_NTIMER] = { [LACP_TIMER_CURRENT_WHILE] = lacp_sm_rx_timer, [LACP_TIMER_PERIODIC] = lacp_sm_ptx_timer, [LACP_TIMER_WAIT_WHILE] = lacp_sm_mux_timer, @@ -223,7 +223,7 @@ struct mbuf * lacp_input(struct trunk_port *tp, struct mbuf *m) { struct lacp_port *lp = LACP_PORT(tp); - uint8_t subtype; + u_int8_t subtype; if (m->m_pkthdr.len < sizeof(struct ether_header) + sizeof(subtype)) { m_freem(m); @@ -249,7 +249,7 @@ lacp_input(struct trunk_port *tp, struct mbuf *m) /* * lacp_pdu_input: process lacpdu */ -static int +int lacp_pdu_input(struct lacp_port *lp, struct mbuf *m) { struct lacpdu *du; @@ -311,7 +311,37 @@ bad: return (EINVAL); } -static void +__inline int +lacp_isactive(struct trunk_port *lgp) +{ + struct lacp_port *lp = LACP_PORT(lgp); + struct lacp_softc *lsc = lp->lp_lsc; + struct lacp_aggregator *la = lp->lp_aggregator; + + /* This port is joined to the active aggregator */ + if (la != NULL && la == lsc->lsc_active_aggregator) + return (1); + + return (0); +} + +__inline int +lacp_iscollecting(struct trunk_port *lgp) +{ + struct lacp_port *lp = LACP_PORT(lgp); + + return ((lp->lp_state & LACP_STATE_COLLECTING) != 0); +} + +__inline int +lacp_isdistributing(struct trunk_port *lgp) +{ + struct lacp_port *lp = LACP_PORT(lgp); + + return ((lp->lp_state & LACP_STATE_DISTRIBUTING) != 0); +} + +void lacp_fill_actorinfo(struct lacp_port *lp, struct lacp_peerinfo *info) { struct trunk_port *tp = lp->lp_trunk; @@ -325,7 +355,7 @@ lacp_fill_actorinfo(struct lacp_port *lp, struct lacp_peerinfo *info) info->lip_state = lp->lp_state; } -static void +void lacp_fill_markerinfo(struct lacp_port *lp, struct lacp_markerinfo *info) { struct ifnet *ifp = lp->lp_ifp; @@ -336,7 +366,7 @@ lacp_fill_markerinfo(struct lacp_port *lp, struct lacp_markerinfo *info) info->mi_rq_xid = htonl(0); } -static int +int lacp_xmit_lacpdu(struct lacp_port *lp) { struct trunk_port *tp = lp->lp_trunk; @@ -388,7 +418,7 @@ lacp_xmit_lacpdu(struct lacp_port *lp) return (error); } -static int +int lacp_xmit_marker(struct lacp_port *lp) { struct trunk_port *tp = lp->lp_trunk; @@ -431,8 +461,8 @@ void lacp_linkstate(struct trunk_port *tp) { struct lacp_port *lp = LACP_PORT(tp); - uint8_t old_state; - uint16_t old_key; + u_int8_t old_state; + u_int16_t old_key; old_state = lp->lp_state; old_key = lp->lp_key; @@ -456,7 +486,7 @@ lacp_linkstate(struct trunk_port *tp) } } -static void +void lacp_tick(void *arg) { struct lacp_softc *lsc = arg; @@ -600,21 +630,21 @@ lacp_portreq(struct trunk_port *tp, caddr_t data) req->partner_state = lp->lp_partner.lip_state; } -static void +void lacp_disable_collecting(struct lacp_port *lp) { LACP_DPRINTF((lp, "collecting disabled\n")); lp->lp_state &= ~LACP_STATE_COLLECTING; } -static void +void lacp_enable_collecting(struct lacp_port *lp) { LACP_DPRINTF((lp, "collecting enabled\n")); lp->lp_state |= LACP_STATE_COLLECTING; } -static void +void lacp_disable_distributing(struct lacp_port *lp) { struct lacp_aggregator *la = lp->lp_aggregator; @@ -649,7 +679,7 @@ lacp_disable_distributing(struct lacp_port *lp) lp->lp_state &= ~LACP_STATE_DISTRIBUTING; } -static void +void lacp_enable_distributing(struct lacp_port *lp) { struct lacp_aggregator *la = lp->lp_aggregator; @@ -681,7 +711,7 @@ lacp_enable_distributing(struct lacp_port *lp) lacp_select_active_aggregator(lsc); } -static void +void lacp_transit_expire(void *vp) { struct lacp_softc *lsc = vp; @@ -757,7 +787,7 @@ lacp_select_tx_port(struct trunk_softc *sc, struct mbuf *m) struct lacp_softc *lsc = LACP_SOFTC(sc); struct lacp_portmap *pm; struct lacp_port *lp; - uint32_t hash; + u_int32_t hash; if (__predict_false(lsc->lsc_suppress_distributing)) { LACP_DPRINTF((NULL, "%s: waiting transit\n", __func__)); @@ -783,7 +813,7 @@ lacp_select_tx_port(struct trunk_softc *sc, struct mbuf *m) * to preserve packet ordering. */ -static void +void lacp_suppress_distributing(struct lacp_softc *lsc, struct lacp_aggregator *la) { struct lacp_port *lp; @@ -805,14 +835,14 @@ lacp_suppress_distributing(struct lacp_softc *lsc, struct lacp_aggregator *la) timeout_add(&lsc->lsc_transit_callout, LACP_TRANSIT_DELAY * hz / 1000); } -static int +int lacp_compare_peerinfo(const struct lacp_peerinfo *a, const struct lacp_peerinfo *b) { return (memcmp(a, b, offsetof(struct lacp_peerinfo, lip_state))); } -static int +int lacp_compare_systemid(const struct lacp_systemid *a, const struct lacp_systemid *b) { @@ -820,7 +850,7 @@ lacp_compare_systemid(const struct lacp_systemid *a, } #if 0 /* unused */ -static int +int lacp_compare_portid(const struct lacp_portid *a, const struct lacp_portid *b) { @@ -828,11 +858,11 @@ lacp_compare_portid(const struct lacp_portid *a, } #endif -static uint64_t +u_int64_t lacp_aggregator_bandwidth(struct lacp_aggregator *la) { struct lacp_port *lp; - uint64_t speed; + u_int64_t speed; lp = TAILQ_FIRST(&la->la_ports); if (lp == NULL) { @@ -855,12 +885,12 @@ lacp_aggregator_bandwidth(struct lacp_aggregator *la) * packets from trunk(4) interface. */ -static void +void lacp_select_active_aggregator(struct lacp_softc *lsc) { struct lacp_aggregator *la; struct lacp_aggregator *best_la = NULL; - uint64_t best_speed = 0; + u_int64_t best_speed = 0; #if defined(LACP_DEBUG) char buf[LACP_LAGIDSTR_MAX+1]; #endif /* defined(LACP_DEBUG) */ @@ -868,7 +898,7 @@ lacp_select_active_aggregator(struct lacp_softc *lsc) LACP_DPRINTF((NULL, "%s:\n", __func__)); TAILQ_FOREACH(la, &lsc->lsc_aggregators, la_q) { - uint64_t speed; + u_int64_t speed; if (la->la_nports == 0) { continue; @@ -923,7 +953,7 @@ lacp_select_active_aggregator(struct lacp_softc *lsc) * Updated the inactive portmap array with the new list of ports and * make it live. */ -static void +void lacp_update_portmap(struct lacp_softc *lsc) { struct lacp_aggregator *la; @@ -952,13 +982,13 @@ lacp_update_portmap(struct lacp_softc *lsc) lsc->lsc_pmap[lsc->lsc_activemap].pm_count)); } -static uint16_t +u_int16_t lacp_compose_key(struct lacp_port *lp) { struct trunk_port *tp = lp->lp_trunk; struct trunk_softc *sc = tp->tp_trunk; u_int media = lp->lp_media; - uint16_t key; + u_int16_t key; if ((lp->lp_state & LACP_STATE_AGGREGATION) == 0) { @@ -987,7 +1017,7 @@ lacp_compose_key(struct lacp_port *lp) return (htons(key)); } -static void +void lacp_aggregator_addref(struct lacp_softc *lsc, struct lacp_aggregator *la) { #if defined(LACP_DEBUG) @@ -1005,7 +1035,7 @@ lacp_aggregator_addref(struct lacp_softc *lsc, struct lacp_aggregator *la) KASSERT(la->la_refcnt > la->la_nports); } -static void +void lacp_aggregator_delref(struct lacp_softc *lsc, struct lacp_aggregator *la) { #if defined(LACP_DEBUG) @@ -1036,7 +1066,7 @@ lacp_aggregator_delref(struct lacp_softc *lsc, struct lacp_aggregator *la) * lacp_aggregator_get: allocate an aggregator. */ -static struct lacp_aggregator * +struct lacp_aggregator * lacp_aggregator_get(struct lacp_softc *lsc, struct lacp_port *lp) { struct lacp_aggregator *la; @@ -1057,7 +1087,7 @@ lacp_aggregator_get(struct lacp_softc *lsc, struct lacp_port *lp) * lacp_fill_aggregator_id: setup a newly allocated aggregator from a port. */ -static void +void lacp_fill_aggregator_id(struct lacp_aggregator *la, const struct lacp_port *lp) { lacp_fill_aggregator_id_peer(&la->la_partner, &lp->lp_partner); @@ -1066,7 +1096,7 @@ lacp_fill_aggregator_id(struct lacp_aggregator *la, const struct lacp_port *lp) la->la_actor.lip_state = lp->lp_state & LACP_STATE_AGGREGATION; } -static void +void lacp_fill_aggregator_id_peer(struct lacp_peerinfo *lpi_aggr, const struct lacp_peerinfo *lpi_port) { @@ -1079,7 +1109,7 @@ lacp_fill_aggregator_id_peer(struct lacp_peerinfo *lpi_aggr, * lacp_aggregator_is_compatible: check if a port can join to an aggregator. */ -static int +int lacp_aggregator_is_compatible(const struct lacp_aggregator *la, const struct lacp_port *lp) { @@ -1103,7 +1133,7 @@ lacp_aggregator_is_compatible(const struct lacp_aggregator *la, return (1); } -static int +int lacp_peerinfo_is_compatible(const struct lacp_peerinfo *a, const struct lacp_peerinfo *b) { @@ -1119,13 +1149,13 @@ lacp_peerinfo_is_compatible(const struct lacp_peerinfo *a, return (1); } -static void +void lacp_port_enable(struct lacp_port *lp) { lp->lp_state |= LACP_STATE_AGGREGATION; } -static void +void lacp_port_disable(struct lacp_port *lp) { lacp_set_mux(lp, LACP_MUX_DETACHED); @@ -1140,7 +1170,7 @@ lacp_port_disable(struct lacp_port *lp) /* * lacp_select: select an aggregator. create one if necessary. */ -static void +void lacp_select(struct lacp_port *lp) { struct lacp_softc *lsc = lp->lp_lsc; @@ -1197,7 +1227,7 @@ lacp_select(struct lacp_port *lp) * lacp_unselect: finish unselect/detach process. */ -static void +void lacp_unselect(struct lacp_port *lp) { struct lacp_softc *lsc = lp->lp_lsc; @@ -1215,7 +1245,7 @@ lacp_unselect(struct lacp_port *lp) /* mux machine */ -static void +void lacp_sm_mux(struct lacp_port *lp) { enum lacp_mux_state new_state; @@ -1278,7 +1308,7 @@ re_eval: goto re_eval; } -static void +void lacp_set_mux(struct lacp_port *lp, enum lacp_mux_state new_state) { struct lacp_aggregator *la = lp->lp_aggregator; @@ -1328,7 +1358,7 @@ lacp_set_mux(struct lacp_port *lp, enum lacp_mux_state new_state) lp->lp_mux_state = new_state; } -static void +void lacp_sm_mux_timer(struct lacp_port *lp) { struct lacp_aggregator *la = lp->lp_aggregator; @@ -1348,8 +1378,8 @@ lacp_sm_mux_timer(struct lacp_port *lp) /* periodic transmit machine */ -static void -lacp_sm_ptx_update_timeout(struct lacp_port *lp, uint8_t oldpstate) +void +lacp_sm_ptx_update_timeout(struct lacp_port *lp, u_int8_t oldpstate) { if (LACP_STATE_EQ(oldpstate, lp->lp_partner.lip_state, LACP_STATE_TIMEOUT)) { @@ -1377,7 +1407,7 @@ lacp_sm_ptx_update_timeout(struct lacp_port *lp, uint8_t oldpstate) } } -static void +void lacp_sm_ptx_tx_schedule(struct lacp_port *lp) { int timeout; @@ -1403,13 +1433,13 @@ lacp_sm_ptx_tx_schedule(struct lacp_port *lp) LACP_TIMER_ARM(lp, LACP_TIMER_PERIODIC, timeout); } -static void +void lacp_sm_ptx_timer(struct lacp_port *lp) { lacp_sm_assert_ntt(lp); } -static void +void lacp_sm_rx(struct lacp_port *lp, const struct lacpdu *du) { int timeout; @@ -1452,7 +1482,7 @@ lacp_sm_rx(struct lacp_port *lp, const struct lacpdu *du) lacp_sm_tx(lp); } -static void +void lacp_sm_rx_set_expired(struct lacp_port *lp) { lp->lp_partner.lip_state &= ~LACP_STATE_SYNC; @@ -1461,7 +1491,7 @@ lacp_sm_rx_set_expired(struct lacp_port *lp) lp->lp_state |= LACP_STATE_EXPIRED; } -static void +void lacp_sm_rx_timer(struct lacp_port *lp) { if ((lp->lp_state & LACP_STATE_EXPIRED) == 0) { @@ -1477,11 +1507,11 @@ lacp_sm_rx_timer(struct lacp_port *lp) } } -static void +void lacp_sm_rx_record_pdu(struct lacp_port *lp, const struct lacpdu *du) { int active; - uint8_t oldpstate; + u_int8_t oldpstate; #if defined(LACP_DEBUG) char buf[LACP_STATESTR_MAX+1]; #endif @@ -1518,7 +1548,7 @@ lacp_sm_rx_record_pdu(struct lacp_port *lp, const struct lacpdu *du) lacp_sm_ptx_update_timeout(lp, oldpstate); } -static void +void lacp_sm_rx_update_ntt(struct lacp_port *lp, const struct lacpdu *du) { /* LACP_DPRINTF((lp, "%s\n", __func__)); */ @@ -1531,10 +1561,10 @@ lacp_sm_rx_update_ntt(struct lacp_port *lp, const struct lacpdu *du) } } -static void +void lacp_sm_rx_record_default(struct lacp_port *lp) { - uint8_t oldpstate; + u_int8_t oldpstate; /* LACP_DPRINTF((lp, "%s\n", __func__)); */ @@ -1544,7 +1574,7 @@ lacp_sm_rx_record_default(struct lacp_port *lp) lacp_sm_ptx_update_timeout(lp, oldpstate); } -static void +void lacp_sm_rx_update_selected_from_peerinfo(struct lacp_port *lp, const struct lacp_peerinfo *info) { @@ -1558,7 +1588,7 @@ lacp_sm_rx_update_selected_from_peerinfo(struct lacp_port *lp, } } -static void +void lacp_sm_rx_update_selected(struct lacp_port *lp, const struct lacpdu *du) { /* LACP_DPRINTF((lp, "%s\n", __func__)); */ @@ -1566,7 +1596,7 @@ lacp_sm_rx_update_selected(struct lacp_port *lp, const struct lacpdu *du) lacp_sm_rx_update_selected_from_peerinfo(lp, &du->ldu_actor); } -static void +void lacp_sm_rx_update_default_selected(struct lacp_port *lp) { /* LACP_DPRINTF((lp, "%s\n", __func__)); */ @@ -1576,7 +1606,7 @@ lacp_sm_rx_update_default_selected(struct lacp_port *lp) /* transmit machine */ -static void +void lacp_sm_tx(struct lacp_port *lp) { int error; @@ -1611,14 +1641,14 @@ lacp_sm_tx(struct lacp_port *lp) } } -static void +void lacp_sm_assert_ntt(struct lacp_port *lp) { lp->lp_flags |= LACP_PORT_NTT; } -static void +void lacp_run_timers(struct lacp_port *lp) { int i; @@ -1731,7 +1761,7 @@ bad: return (EINVAL); } -static int +int tlv_check(const void *p, size_t size, const struct tlvhdr *tlv, const struct tlv_template *tmpl, int check_type) { @@ -1756,7 +1786,7 @@ tlv_check(const void *p, size_t size, const struct tlvhdr *tlv, #if defined(LACP_DEBUG) const char * -lacp_format_mac(const uint8_t *mac, char *buf, size_t buflen) +lacp_format_mac(const u_int8_t *mac, char *buf, size_t buflen) { snprintf(buf, buflen, "%02X-%02X-%02X-%02X-%02X-%02X", (int)mac[0], @@ -1847,13 +1877,13 @@ lacp_format_lagid_aggregator(const struct lacp_aggregator *la, } const char * -lacp_format_state(uint8_t state, char *buf, size_t buflen) +lacp_format_state(u_int8_t state, char *buf, size_t buflen) { snprintf(buf, buflen, "%b", state, LACP_STATE_BITS); return (buf); } -static void +void lacp_dump_lacpdu(const struct lacpdu *du) { char buf[LACP_PARTNERSTR_MAX+1]; @@ -1871,7 +1901,7 @@ lacp_dump_lacpdu(const struct lacpdu *du) printf("maxdelay=%d\n", ntohs(du->ldu_collector.lci_maxdelay)); } -static void +void lacp_dprintf(const struct lacp_port *lp, const char *fmt, ...) { va_list va; |