proxmox-mirrors/mirror_frr
1
0
Fork 0
mirror of https://git.proxmox.com/git/mirror_frr synced 2025-08-16 00:25:01 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

bgpd: bye bye THREAD_BACKGROUND

Browse Source 
Signed-off-by: Quentin Young <qlyoung@cumulusnetworks.com>
This commit is contained in:
Quentin Young 2017-06-08 20:41:21 +00:00
parent 151044ce3e
commit a9794991c7
No known key found for this signature in database
GPG Key ID: DAF48E0F57E0834F
2 changed files with 4 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
bgpd/bgp_fsm.c
View File

@ -457,7 +457,7 @@ int bgp_routeadv_timer(struct thread *thread)
peer->synctime = bgp_clock(); peer->synctime = bgp_clock();
thread_add_background(bm->master, bgp_generate_updgrp_packets, peer, 0, thread_add_timer_msec(bm->master, bgp_generate_updgrp_packets, peer, 0,
&peer->t_generate_updgrp_packets); &peer->t_generate_updgrp_packets);
/* MRAI timer will be started again when FIFO is built, no need to /* MRAI timer will be started again when FIFO is built, no need to
@ -665,7 +665,7 @@ void bgp_adjust_routeadv(struct peer *peer)
BGP_TIMER_OFF(peer->t_routeadv); BGP_TIMER_OFF(peer->t_routeadv);
peer->synctime = bgp_clock(); peer->synctime = bgp_clock();
thread_add_background(bm->master, bgp_generate_updgrp_packets, thread_add_timer_msec(bm->master, bgp_generate_updgrp_packets,
peer, 0, peer, 0,
&peer->t_generate_updgrp_packets); &peer->t_generate_updgrp_packets);
return; return;

7
bgpd/bgp_io.c
View File

@ -150,7 +150,7 @@ void bgp_reads_on(struct peer *peer)
{ {
thread_add_read(fpt->master, bgp_process_reads, peer, peer->fd, thread_add_read(fpt->master, bgp_process_reads, peer, peer->fd,
&peer->t_read); &peer->t_read);
thread_add_background(bm->master, bgp_process_packet, peer, 0, thread_add_timer_msec(bm->master, bgp_process_packet, peer, 0,
&peer->t_process_packet); &peer->t_process_packet);
SET_FLAG(peer->thread_flags, PEER_THREAD_READS_ON); SET_FLAG(peer->thread_flags, PEER_THREAD_READS_ON);
} }
@ -205,7 +205,7 @@ static int bgp_process_writes(struct thread *thread)
if (reschedule) { if (reschedule) {
thread_add_write(fpt->master, bgp_process_writes, peer, thread_add_write(fpt->master, bgp_process_writes, peer,
peer->fd, &peer->t_write); peer->fd, &peer->t_write);
thread_add_background(bm->master, bgp_generate_updgrp_packets, thread_add_timer_msec(bm->master, bgp_generate_updgrp_packets,
peer, 0, peer, 0,
&peer->t_generate_updgrp_packets); &peer->t_generate_updgrp_packets);
} }
@ -334,9 +334,6 @@ static int bgp_process_reads(struct thread *thread)
if (added_pkt) if (added_pkt)
thread_add_event(bm->master, bgp_process_packet, peer, thread_add_event(bm->master, bgp_process_packet, peer,
0, NULL); 0, NULL);
// thread_add_background(bm->master,
// bgp_process_packet, peer,
// 0, NULL);
} }
return 0; return 0;