bgp_reads_on(peer);
bgp_writes_on(peer);
- thread_add_timer_msec(bm->master, bgp_process_packet, peer, 0,
- &peer->t_process_packet);
+ thread_add_event(bm->master, bgp_process_packet, peer, 0,
+ &peer->t_process_packet);
return (peer);
}
thread_add_read(fpt->master, bgp_process_reads, peer, peer->fd,
&peer->t_read);
if (added_pkt)
- thread_add_timer_msec(bm->master, bgp_process_packet,
- peer, 0, &peer->t_process_packet);
+ thread_add_event(bm->master, bgp_process_packet,
+ peer, 0, &peer->t_process_packet);
}
return 0;
frr_with_mutex(&peer->io_mtx) {
// more work to do, come back later
if (peer->ibuf->count > 0)
- thread_add_timer_msec(
+ thread_add_event(
bm->master, bgp_process_packet, peer, 0,
&peer->t_process_packet);
}