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

Merge pull request #12315 from donaldsharp/dplane_sorry

Browse Source 
Dplane sorry
This commit is contained in:
Donatas Abraitis 2022-11-15 09:11:33 +02:00 committed by GitHub
commit 01637c3819
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
zebra/dplane_fpm_nl.c
View File

@ -98,6 +98,7 @@ struct fpm_nl_ctx {
struct thread *t_read;
struct thread *t_write;
struct thread *t_event;
struct thread *t_nhg;
struct thread *t_dequeue;
/* zebra events. */
@ -271,7 +272,7 @@ DEFUN(fpm_use_nhg, fpm_use_nhg_cmd,
return CMD_SUCCESS;
thread_add_event(gfnc->fthread->master, fpm_process_event, gfnc,
FNE_TOGGLE_NHG, &gfnc->t_event);
FNE_TOGGLE_NHG, &gfnc->t_nhg);
return CMD_SUCCESS;
}
@ -287,7 +288,7 @@ DEFUN(no_fpm_use_nhg, no_fpm_use_nhg_cmd,
return CMD_SUCCESS;
thread_add_event(gfnc->fthread->master, fpm_process_event, gfnc,
FNE_TOGGLE_NHG, &gfnc->t_event);
FNE_TOGGLE_NHG, &gfnc->t_nhg);
return CMD_SUCCESS;
}
@ -1275,7 +1276,7 @@ static void fpm_process_queue(struct thread *t)
static void fpm_process_event(struct thread *t)
{
struct fpm_nl_ctx *fnc = THREAD_ARG(t);
int event = THREAD_VAL(t);
enum fpm_nl_events event = THREAD_VAL(t);
switch (event) {
case FNE_DISABLE:
@ -1328,11 +1329,6 @@ static void fpm_process_event(struct thread *t)
if (IS_ZEBRA_DEBUG_FPM)
zlog_debug("%s: LSP walk finished", __func__);
break;
default:
if (IS_ZEBRA_DEBUG_FPM)
zlog_debug("%s: unhandled event %d", __func__, event);
break;
}
}
@ -1372,6 +1368,8 @@ static int fpm_nl_finish_early(struct fpm_nl_ctx *fnc)
THREAD_OFF(fnc->t_ribwalk);
THREAD_OFF(fnc->t_rmacreset);
THREAD_OFF(fnc->t_rmacwalk);
THREAD_OFF(fnc->t_event);
THREAD_OFF(fnc->t_nhg);
thread_cancel_async(fnc->fthread->master, &fnc->t_read, NULL);
thread_cancel_async(fnc->fthread->master, &fnc->t_write, NULL);
thread_cancel_async(fnc->fthread->master, &fnc->t_connect, NULL);