From: Maria Matejka Date: Mon, 10 Jun 2024 12:10:51 +0000 (+0200) Subject: BGP: splitting TX by time, not number of messages sent X-Git-Tag: v3.0.0~155 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=f45c5190393a903d4538eee91f9b84f3c84a4b3b;p=thirdparty%2Fbird.git BGP: splitting TX by time, not number of messages sent --- diff --git a/proto/bgp/packets.c b/proto/bgp/packets.c index 35e59e1a1..f2a8e1f6b 100644 --- a/proto/bgp/packets.c +++ b/proto/bgp/packets.c @@ -3181,12 +3181,9 @@ bgp_kick_tx(void *vconn) struct bgp_conn *conn = vconn; DBG("BGP: kicking TX\n"); - uint max = 1024; - while (--max && (bgp_fire_tx(conn) > 0)) - ; - - if (!max && !ev_active(conn->tx_ev)) - proto_send_event(&conn->bgp->p, conn->tx_ev); + while (bgp_fire_tx(conn) > 0) + MAYBE_DEFER_TASK(proto_event_list(&conn->bgp->p), conn->tx_ev, + "BGP TX for %s", conn->bgp->p.name); } void @@ -3201,12 +3198,9 @@ bgp_tx(sock *sk) bgp_start_timer(conn->bgp, conn->send_hold_timer, conn->send_hold_time); DBG("BGP: TX hook\n"); - uint max = 1024; - while (--max && (bgp_fire_tx(conn) > 0)) - ; - - if (!max && !ev_active(conn->tx_ev)) - proto_send_event(&conn->bgp->p, conn->tx_ev); + while (bgp_fire_tx(conn) > 0) + MAYBE_DEFER_TASK(proto_event_list(&conn->bgp->p), conn->tx_ev, + "BGP TX for %s", conn->bgp->p.name); }