| /dports/net/frr7-pythontools/frr-frr-7.5.1/tests/lib/ |
| H A D | test_zmq.c | 60 void *zmqsock; in run_client() local
80 send_delim(zmqsock); in run_client()
95 send_delim(zmqsock); in run_client()
109 recv_delim(zmqsock); in run_client()
126 send_delim(zmqsock); in run_client()
138 zmq_close(zmqsock); in run_client()
150 recv_delim(zmqsock); in recv_id_and_delim()
156 send_delim(zmqsock); in send_id_and_delim()
229 zmqsock, &cb); in serverpartfn()
278 void *zmqsock; in run_server() local
[all …]
|
| /dports/net/frr7/frr-frr-7.5.1/tests/lib/ |
| H A D | test_zmq.c | 60 void *zmqsock; in run_client() local
80 send_delim(zmqsock); in run_client()
95 send_delim(zmqsock); in run_client()
109 recv_delim(zmqsock); in run_client()
126 send_delim(zmqsock); in run_client()
138 zmq_close(zmqsock); in run_client()
150 recv_delim(zmqsock); in recv_id_and_delim()
156 send_delim(zmqsock); in send_id_and_delim()
229 zmqsock, &cb); in serverpartfn()
278 void *zmqsock; in run_server() local
[all …]
|
| /dports/net/frr7-pythontools/frr-frr-7.5.1/lib/ |
| H A D | frr_zmq.c | 64 if (!cb || !cb->zmqsock) in frrzmq_read_msg()
68 zmq_pollitem_t polli = {.socket = cb->zmqsock, in frrzmq_read_msg()
79 cb->read.cb_msg(cb->read.arg, cb->zmqsock); in frrzmq_read_msg()
147 cb->read.cb_error(cb->read.arg, cb->zmqsock); in frrzmq_read_msg()
157 void *arg, void *zmqsock, in funcname_frrzmq_thread_add_read()
169 if (zmq_getsockopt(zmqsock, ZMQ_FD, &fd, &len)) in funcname_frrzmq_thread_add_read()
184 cb->zmqsock = zmqsock; in funcname_frrzmq_thread_add_read()
217 if (!cb || !cb->zmqsock) in frrzmq_write_msg()
265 void *arg, void *zmqsock, in funcname_frrzmq_thread_add_write()
292 cb->zmqsock = zmqsock; in funcname_frrzmq_thread_add_write()
[all …]
|
| H A D | frr_zmq.h | 47 void (*cb_msg)(void *arg, void *zmqsock);
48 void (*cb_part)(void *arg, void *zmqsock, zmq_msg_t *msg,
50 void (*cb_error)(void *arg, void *zmqsock);
53 void *zmqsock; member
108 struct thread_master *master, void (*msgfunc)(void *arg, void *zmqsock),
109 void (*partfunc)(void *arg, void *zmqsock, zmq_msg_t *msg,
111 void (*errfunc)(void *arg, void *zmqsock), void *arg, void *zmqsock,
114 struct thread_master *master, void (*msgfunc)(void *arg, void *zmqsock),
115 void (*errfunc)(void *arg, void *zmqsock), void *arg, void *zmqsock,
|
| /dports/net/frr7/frr-frr-7.5.1/lib/ |
| H A D | frr_zmq.c | 64 if (!cb || !cb->zmqsock) in frrzmq_read_msg()
68 zmq_pollitem_t polli = {.socket = cb->zmqsock, in frrzmq_read_msg()
79 cb->read.cb_msg(cb->read.arg, cb->zmqsock); in frrzmq_read_msg()
147 cb->read.cb_error(cb->read.arg, cb->zmqsock); in frrzmq_read_msg()
157 void *arg, void *zmqsock, in funcname_frrzmq_thread_add_read()
169 if (zmq_getsockopt(zmqsock, ZMQ_FD, &fd, &len)) in funcname_frrzmq_thread_add_read()
184 cb->zmqsock = zmqsock; in funcname_frrzmq_thread_add_read()
217 if (!cb || !cb->zmqsock) in frrzmq_write_msg()
265 void *arg, void *zmqsock, in funcname_frrzmq_thread_add_write()
292 cb->zmqsock = zmqsock; in funcname_frrzmq_thread_add_write()
[all …]
|
| H A D | frr_zmq.h | 47 void (*cb_msg)(void *arg, void *zmqsock);
48 void (*cb_part)(void *arg, void *zmqsock, zmq_msg_t *msg,
50 void (*cb_error)(void *arg, void *zmqsock);
53 void *zmqsock; member
108 struct thread_master *master, void (*msgfunc)(void *arg, void *zmqsock),
109 void (*partfunc)(void *arg, void *zmqsock, zmq_msg_t *msg,
111 void (*errfunc)(void *arg, void *zmqsock), void *arg, void *zmqsock,
114 struct thread_master *master, void (*msgfunc)(void *arg, void *zmqsock),
115 void (*errfunc)(void *arg, void *zmqsock), void *arg, void *zmqsock,
|