Searched refs:sr_subscription (Results 1 – 4 of 4) sorted by relevance
| /dports/net/frr7-pythontools/frr-frr-7.5.1/lib/ |
| H A D | northbound_sysrepo.c | 528 sr_subscription_ctx_t *sr_subscription = THREAD_ARG(thread); in frr_sr_read_cb() local
532 ret = sr_process_events(sr_subscription, session, NULL); in frr_sr_read_cb()
540 thread_add_read(master, frr_sr_read_cb, sr_subscription, fd, &thread); in frr_sr_read_cb()
556 &module->sr_subscription); in frr_sr_subscribe_config()
581 NULL, SR_SUBSCR_CTX_REUSE, &module->sr_subscription); in frr_sr_subscribe_state()
605 &module->sr_subscription); in frr_sr_subscribe_rpc()
692 ret = sr_get_event_pipe(module->sr_subscription, &event_pipe); in frr_sr_init()
699 thread_add_read(master, frr_sr_read_cb, module->sr_subscription, in frr_sr_init()
718 if (!module->sr_subscription) in frr_sr_finish()
720 sr_unsubscribe(module->sr_subscription); in frr_sr_finish()
|
| H A D | yang.h | 65 sr_subscription_ctx_t *sr_subscription; member
|
| /dports/net/frr7/frr-frr-7.5.1/lib/ |
| H A D | northbound_sysrepo.c | 528 sr_subscription_ctx_t *sr_subscription = THREAD_ARG(thread); in frr_sr_read_cb() local
532 ret = sr_process_events(sr_subscription, session, NULL); in frr_sr_read_cb()
540 thread_add_read(master, frr_sr_read_cb, sr_subscription, fd, &thread); in frr_sr_read_cb()
556 &module->sr_subscription); in frr_sr_subscribe_config()
581 NULL, SR_SUBSCR_CTX_REUSE, &module->sr_subscription); in frr_sr_subscribe_state()
605 &module->sr_subscription); in frr_sr_subscribe_rpc()
692 ret = sr_get_event_pipe(module->sr_subscription, &event_pipe); in frr_sr_init()
699 thread_add_read(master, frr_sr_read_cb, module->sr_subscription, in frr_sr_init()
718 if (!module->sr_subscription) in frr_sr_finish()
720 sr_unsubscribe(module->sr_subscription); in frr_sr_finish()
|
| H A D | yang.h | 65 sr_subscription_ctx_t *sr_subscription; member
|