Home
last modified time | relevance | path

Searched refs:zmq_ctx (Results 1 – 25 of 37) sorted by relevance

12

/dports/multimedia/handbrake/ffmpeg-4.4/tools/
H A Dzmqsend.c58 void *zmq_ctx, *socket; in main() local
92 zmq_ctx = zmq_ctx_new(); in main()
93 if (!zmq_ctx) { in main()
99 socket = zmq_socket(zmq_ctx, ZMQ_REQ); in main()
166 zmq_ctx_destroy(zmq_ctx); in main()
/dports/multimedia/gstreamer1-libav/gst-libav-1.16.2/gst-libs/ext/libav/tools/
H A Dzmqsend.c58 void *zmq_ctx, *socket; in main() local
92 zmq_ctx = zmq_ctx_new(); in main()
93 if (!zmq_ctx) { in main()
99 socket = zmq_socket(zmq_ctx, ZMQ_REQ); in main()
166 zmq_ctx_destroy(zmq_ctx); in main()
/dports/emulators/vice/vice-3.5/src/lib/libffmpeg/tools/
H A Dzmqsend.c57 void *zmq_ctx, *socket; in main() local
91 zmq_ctx = zmq_ctx_new(); in main()
92 if (!zmq_ctx) { in main()
98 socket = zmq_socket(zmq_ctx, ZMQ_REQ); in main()
165 zmq_ctx_destroy(zmq_ctx); in main()
/dports/multimedia/ffmpeg/ffmpeg-4.4.1/tools/
H A Dzmqsend.c58 void *zmq_ctx, *socket; in main() local
92 zmq_ctx = zmq_ctx_new(); in main()
93 if (!zmq_ctx) { in main()
99 socket = zmq_socket(zmq_ctx, ZMQ_REQ); in main()
166 zmq_ctx_destroy(zmq_ctx); in main()
/dports/www/qt5-webengine/qtwebengine-everywhere-src-5.15.2/src/3rdparty/chromium/third_party/ffmpeg/tools/
H A Dzmqsend.c58 void *zmq_ctx, *socket; in main() local
92 zmq_ctx = zmq_ctx_new(); in main()
93 if (!zmq_ctx) { in main()
99 socket = zmq_socket(zmq_ctx, ZMQ_REQ); in main()
166 zmq_ctx_destroy(zmq_ctx); in main()
/dports/emulators/libretro-vice/vice-libretro-5725415/vice/src/lib/libffmpeg/tools/
H A Dzmqsend.c57 void *zmq_ctx, *socket; in main() local
91 zmq_ctx = zmq_ctx_new(); in main()
92 if (!zmq_ctx) { in main()
98 socket = zmq_socket(zmq_ctx, ZMQ_REQ); in main()
165 zmq_ctx_destroy(zmq_ctx); in main()
/dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/ffmpeg/tools/
H A Dzmqsend.c58 void *zmq_ctx, *socket; in main() local
92 zmq_ctx = zmq_ctx_new(); in main()
93 if (!zmq_ctx) { in main()
99 socket = zmq_socket(zmq_ctx, ZMQ_REQ); in main()
166 zmq_ctx_destroy(zmq_ctx); in main()
/dports/net/nmsg/nmsg-1.0.1/nmsg/
H A Dzmqio.c104 nmsg_input_open_zmq_endpoint(void *zmq_ctx, const char *ep) { in nmsg_input_open_zmq_endpoint() argument
123 s = zmq_socket(zmq_ctx, socket_type); in nmsg_input_open_zmq_endpoint()
149 nmsg_output_open_zmq_endpoint(void *zmq_ctx, const char *ep, size_t bufsz) { in nmsg_output_open_zmq_endpoint() argument
168 s = zmq_socket(zmq_ctx, socket_type); in nmsg_output_open_zmq_endpoint()
198 nmsg_input_open_zmq_endpoint(void *zmq_ctx __attribute__((unused)), in nmsg_input_open_zmq_endpoint() argument
205 nmsg_output_open_zmq_endpoint(void *zmq_ctx __attribute__((unused)), in nmsg_output_open_zmq_endpoint() argument
H A Doutput.h118 nmsg_output_open_zmq_endpoint(void *zmq_ctx, const char *ep, size_t bufsz);
H A Dio.c504 _nmsg_io_add_input_zmq(nmsg_io_t io, void *zmq_ctx, const char *str_socket, void *user) { in _nmsg_io_add_input_zmq() argument
507 input = nmsg_input_open_zmq_endpoint(zmq_ctx, str_socket); in _nmsg_io_add_input_zmq()
518 nmsg_io_add_input_zmq_channel(nmsg_io_t io, void *zmq_ctx, const char *chan, void *user) { in nmsg_io_add_input_zmq_channel() argument
531 res = _nmsg_io_add_input_zmq(io, zmq_ctx, alias[i], user); in nmsg_io_add_input_zmq_channel()
544 void *zmq_ctx __attribute__((unused)), in nmsg_io_add_input_zmq_channel() argument
/dports/security/amavisd-new/amavis-v2.12.0/
H A Damavis-services348 $zmq_ctx = zmq_init(1);
352 $outer_sock = zmq_socket($zmq_ctx, ZMQ_SUB);
373 $inner_sock = zmq_socket($zmq_ctx, ZMQ_PUB);
518 $zmq_ctx = zmq_init(1);
522 $outer_sock = zmq_socket($zmq_ctx, ZMQ_SUB);
545 $snmp_sock = zmq_socket($zmq_ctx, ZMQ_REP);
675 $zmq_ctx = zmq_init(1);
680 $inner_sock = zmq_socket($zmq_ctx, ZMQ_SUB);
715 $outer_sock = zmq_socket($zmq_ctx, ZMQ_PUB);
860 if ($zmq_ctx) {
[all …]
H A Damavisd-status184 my($zmq_ctx, $zmq_sock);
321 $zmq_ctx = zmq_init();
322 $zmq_ctx or die "Can't create ZMQ context: $!";
323 $zmq_sock = zmq_socket($zmq_ctx,ZMQ_SUB);
390 zmq_term($zmq_ctx) if $zmq_ctx;
H A Damavisd-snmp-subagent-zmq68 use vars qw($zmq_ctx $zmq_sock $snmp_sock_specs $agentx_sock_specs);
1193 $zmq_ctx = zmq_init();
1194 $zmq_ctx or die "Can't create ZMQ context: $!";
1197 $zmq_sock = zmq_socket($zmq_ctx,ZMQ_REQ);
1258 zmq_term($zmq_ctx) if $zmq_ctx; # ignoring status
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/mroonga/vendor/groonga/src/suggest/
H A Dgroonga_suggest_httpd.c88 void *zmq_ctx; member
539 if ((zmq_recv_sock = zmq_socket(thd->zmq_ctx, ZMQ_SUB))) { in recv_from_learner()
581 serve_threads(int nthreads, int port, const char *db_path, void *zmq_ctx, in serve_threads() argument
606 if (!(threads[i].zmq_sock = zmq_socket(zmq_ctx, ZMQ_PUB))) { in serve_threads()
649 rthd.zmq_ctx = zmq_ctx; in serve_threads()
786 void *zmq_ctx; in main() local
840 if ((zmq_ctx = zmq_init(1))) { in main()
846 serve_threads(max_threads, port_no, argv[n_processed_args], zmq_ctx, in main()
848 zmq_term(zmq_ctx); in main()
H A Dgroonga_suggest_learner.c56 void *zmq_ctx; member
382 if ((zmq_send_sock = zmq_socket(thd->zmq_ctx, ZMQ_PUB))) { in send_to_httpd()
804 void *zmq_ctx, *zmq_recv_sock; in main() local
805 if (!(zmq_ctx = zmq_init(1))) { in main()
808 if (!(zmq_recv_sock = zmq_socket(zmq_ctx, ZMQ_SUB))) { in main()
822 thd.zmq_ctx = zmq_ctx; in main()
832 zmq_term(zmq_ctx); in main()
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/mroonga/vendor/groonga/src/suggest/
H A Dgroonga_suggest_httpd.c88 void *zmq_ctx; member
539 if ((zmq_recv_sock = zmq_socket(thd->zmq_ctx, ZMQ_SUB))) { in recv_from_learner()
581 serve_threads(int nthreads, int port, const char *db_path, void *zmq_ctx, in serve_threads() argument
606 if (!(threads[i].zmq_sock = zmq_socket(zmq_ctx, ZMQ_PUB))) { in serve_threads()
649 rthd.zmq_ctx = zmq_ctx; in serve_threads()
786 void *zmq_ctx; in main() local
840 if ((zmq_ctx = zmq_init(1))) { in main()
846 serve_threads(max_threads, port_no, argv[n_processed_args], zmq_ctx, in main()
848 zmq_term(zmq_ctx); in main()
H A Dgroonga_suggest_learner.c56 void *zmq_ctx; member
382 if ((zmq_send_sock = zmq_socket(thd->zmq_ctx, ZMQ_PUB))) { in send_to_httpd()
804 void *zmq_ctx, *zmq_recv_sock; in main() local
805 if (!(zmq_ctx = zmq_init(1))) { in main()
808 if (!(zmq_recv_sock = zmq_socket(zmq_ctx, ZMQ_SUB))) { in main()
822 thd.zmq_ctx = zmq_ctx; in main()
832 zmq_term(zmq_ctx); in main()
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/mroonga/vendor/groonga/src/suggest/
H A Dgroonga_suggest_httpd.c88 void *zmq_ctx; member
539 if ((zmq_recv_sock = zmq_socket(thd->zmq_ctx, ZMQ_SUB))) { in recv_from_learner()
581 serve_threads(int nthreads, int port, const char *db_path, void *zmq_ctx, in serve_threads() argument
606 if (!(threads[i].zmq_sock = zmq_socket(zmq_ctx, ZMQ_PUB))) { in serve_threads()
649 rthd.zmq_ctx = zmq_ctx; in serve_threads()
786 void *zmq_ctx; in main() local
840 if ((zmq_ctx = zmq_init(1))) { in main()
846 serve_threads(max_threads, port_no, argv[n_processed_args], zmq_ctx, in main()
848 zmq_term(zmq_ctx); in main()
H A Dgroonga_suggest_learner.c56 void *zmq_ctx; member
382 if ((zmq_send_sock = zmq_socket(thd->zmq_ctx, ZMQ_PUB))) { in send_to_httpd()
804 void *zmq_ctx, *zmq_recv_sock; in main() local
805 if (!(zmq_ctx = zmq_init(1))) { in main()
808 if (!(zmq_recv_sock = zmq_socket(zmq_ctx, ZMQ_SUB))) { in main()
822 thd.zmq_ctx = zmq_ctx; in main()
832 zmq_term(zmq_ctx); in main()
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/mroonga/vendor/groonga/src/suggest/
H A Dgroonga_suggest_httpd.c88 void *zmq_ctx; member
539 if ((zmq_recv_sock = zmq_socket(thd->zmq_ctx, ZMQ_SUB))) { in recv_from_learner()
581 serve_threads(int nthreads, int port, const char *db_path, void *zmq_ctx, in serve_threads() argument
606 if (!(threads[i].zmq_sock = zmq_socket(zmq_ctx, ZMQ_PUB))) { in serve_threads()
649 rthd.zmq_ctx = zmq_ctx; in serve_threads()
786 void *zmq_ctx; in main() local
840 if ((zmq_ctx = zmq_init(1))) { in main()
846 serve_threads(max_threads, port_no, argv[n_processed_args], zmq_ctx, in main()
848 zmq_term(zmq_ctx); in main()
H A Dgroonga_suggest_learner.c56 void *zmq_ctx; member
382 if ((zmq_send_sock = zmq_socket(thd->zmq_ctx, ZMQ_PUB))) { in send_to_httpd()
804 void *zmq_ctx, *zmq_recv_sock; in main() local
805 if (!(zmq_ctx = zmq_init(1))) { in main()
808 if (!(zmq_recv_sock = zmq_socket(zmq_ctx, ZMQ_SUB))) { in main()
822 thd.zmq_ctx = zmq_ctx; in main()
832 zmq_term(zmq_ctx); in main()
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/mroonga/vendor/groonga/src/suggest/
H A Dgroonga_suggest_httpd.c88 void *zmq_ctx; member
539 if ((zmq_recv_sock = zmq_socket(thd->zmq_ctx, ZMQ_SUB))) { in recv_from_learner()
581 serve_threads(int nthreads, int port, const char *db_path, void *zmq_ctx, in serve_threads() argument
606 if (!(threads[i].zmq_sock = zmq_socket(zmq_ctx, ZMQ_PUB))) { in serve_threads()
649 rthd.zmq_ctx = zmq_ctx; in serve_threads()
786 void *zmq_ctx; in main() local
840 if ((zmq_ctx = zmq_init(1))) { in main()
846 serve_threads(max_threads, port_no, argv[n_processed_args], zmq_ctx, in main()
848 zmq_term(zmq_ctx); in main()
H A Dgroonga_suggest_learner.c56 void *zmq_ctx;
382 if ((zmq_send_sock = zmq_socket(thd->zmq_ctx, ZMQ_PUB))) {
804 void *zmq_ctx, *zmq_recv_sock;
805 if (!(zmq_ctx = zmq_init(1))) {
808 if (!(zmq_recv_sock = zmq_socket(zmq_ctx, ZMQ_SUB))) {
822 thd.zmq_ctx = zmq_ctx;
832 zmq_term(zmq_ctx);
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/mroonga/vendor/groonga/src/suggest/
H A Dgroonga_suggest_httpd.c88 void *zmq_ctx; member
539 if ((zmq_recv_sock = zmq_socket(thd->zmq_ctx, ZMQ_SUB))) { in recv_from_learner()
581 serve_threads(int nthreads, int port, const char *db_path, void *zmq_ctx, in serve_threads() argument
606 if (!(threads[i].zmq_sock = zmq_socket(zmq_ctx, ZMQ_PUB))) { in serve_threads()
649 rthd.zmq_ctx = zmq_ctx; in serve_threads()
786 void *zmq_ctx; in main() local
840 if ((zmq_ctx = zmq_init(1))) { in main()
846 serve_threads(max_threads, port_no, argv[n_processed_args], zmq_ctx, in main()
848 zmq_term(zmq_ctx); in main()
H A Dgroonga_suggest_learner.c56 void *zmq_ctx; member
382 if ((zmq_send_sock = zmq_socket(thd->zmq_ctx, ZMQ_PUB))) { in send_to_httpd()
804 void *zmq_ctx, *zmq_recv_sock; in main() local
805 if (!(zmq_ctx = zmq_init(1))) { in main()
808 if (!(zmq_recv_sock = zmq_socket(zmq_ctx, ZMQ_SUB))) { in main()
822 thd.zmq_ctx = zmq_ctx; in main()
832 zmq_term(zmq_ctx); in main()

12