Lines Matching refs:zmq
26 #include <zmq.h>
38 void *zmq;
54 ZMQContext *zmq = ctx->priv;
56 zmq->zmq = zmq_ctx_new();
57 if (!zmq->zmq) {
63 zmq->responder = zmq_socket(zmq->zmq, ZMQ_REP);
64 if (!zmq->responder) {
70 if (zmq_bind(zmq->responder, zmq->bind_address) == -1) {
73 zmq->bind_address, zmq_strerror(errno));
77 zmq->command_count = -1;
83 ZMQContext *zmq = ctx->priv;
85 zmq_close(zmq->responder);
86 zmq_ctx_destroy(zmq->zmq);
119 ZMQContext *zmq = ctx->priv;
129 if (zmq_msg_recv(&msg, zmq->responder, ZMQ_DONTWAIT) == -1) {
154 ZMQContext *zmq = ctx->priv;
166 zmq->command_count++;
170 av_log(ctx, AV_LOG_ERROR, "Could not parse command #%d\n", zmq->command_count);
177 zmq->command_count, cmd.target, cmd.command, cmd.arg);
190 zmq->command_count, send_buf);
191 if (zmq_send(zmq->responder, send_buf, strlen(send_buf), 0) == -1)
193 zmq->command_count, zmq_strerror(ret));
210 AVFILTER_DEFINE_CLASS(zmq);
230 .name = "zmq",