summaryrefslogtreecommitdiff
path: root/lib/frr_zmq.c
diff options
context:
space:
mode:
Diffstat (limited to 'lib/frr_zmq.c')
-rw-r--r--lib/frr_zmq.c6
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/frr_zmq.c b/lib/frr_zmq.c
index 4a860fe253..1a5b35d1e6 100644
--- a/lib/frr_zmq.c
+++ b/lib/frr_zmq.c
@@ -150,7 +150,7 @@ out_err:
}
int _frrzmq_event_add_read(const struct xref_threadsched *xref,
- struct thread_master *master,
+ struct event_master *master,
void (*msgfunc)(void *arg, void *zmqsock),
void (*partfunc)(void *arg, void *zmqsock,
zmq_msg_t *msg, unsigned partnum),
@@ -258,7 +258,7 @@ out_err:
}
int _frrzmq_event_add_write(const struct xref_threadsched *xref,
- struct thread_master *master,
+ struct event_master *master,
void (*msgfunc)(void *arg, void *zmqsock),
void (*errfunc)(void *arg, void *zmqsock),
void *arg, void *zmqsock, struct frrzmq_cb **cbp)
@@ -342,7 +342,7 @@ void frrzmq_check_events(struct frrzmq_cb **cbp, struct cb_core *core,
if (zmq_getsockopt(cb->zmqsock, ZMQ_EVENTS, &events, &len))
return;
if ((events & event) && core->thread && !core->cancelled) {
- struct thread_master *tm = core->thread->master;
+ struct event_master *tm = core->thread->master;
event_cancel(&core->thread);