| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0066-plugins.cpp | 78 ictest_cnt_init(&ictest.on_new, 1, 1); in do_test_plugin()
94 if (ictest.on_new.cnt < ictest.on_new.min || in do_test_plugin()
95 ictest.on_new.cnt > ictest.on_new.max) in do_test_plugin()
96 Test::Fail(tostr() << "on_new.cnt " << ictest.on_new.cnt << in do_test_plugin()
97 " not within range " << ictest.on_new.min << ".." << in do_test_plugin()
98 ictest.on_new.max); in do_test_plugin()
|
| H A D | 0100-thread_interceptors.cpp | 120 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
145 on_new, ic_opaque); in on_conf_dup()
165 rd_kafka_conf_interceptor_add_on_new(c_conf, "test:0100", on_new, in test_thread_cbs()
|
| H A D | 0073-headers.c | 287 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
306 rd_kafka_conf_interceptor_add_on_new(conf, __FILE__, on_new, NULL); in do_produce()
|
| H A D | 0072-headers_ut.c | 346 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
368 rd_kafka_conf_interceptor_add_on_new(conf, __FILE__, on_new, NULL); in main_0072_headers_ut()
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0066-plugins.cpp | 78 ictest_cnt_init(&ictest.on_new, 1, 1); in do_test_plugin()
94 if (ictest.on_new.cnt < ictest.on_new.min || in do_test_plugin()
95 ictest.on_new.cnt > ictest.on_new.max) in do_test_plugin()
96 Test::Fail(tostr() << "on_new.cnt " << ictest.on_new.cnt << in do_test_plugin()
97 " not within range " << ictest.on_new.min << ".." << in do_test_plugin()
98 ictest.on_new.max); in do_test_plugin()
|
| H A D | 0100-thread_interceptors.cpp | 120 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
145 on_new, ic_opaque); in on_conf_dup()
165 rd_kafka_conf_interceptor_add_on_new(c_conf, "test:0100", on_new, in test_thread_cbs()
|
| H A D | 0073-headers.c | 287 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
306 rd_kafka_conf_interceptor_add_on_new(conf, __FILE__, on_new, NULL); in do_produce()
|
| H A D | 0072-headers_ut.c | 346 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
368 rd_kafka_conf_interceptor_add_on_new(conf, __FILE__, on_new, NULL); in main_0072_headers_ut()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0066-plugins.cpp | 78 ictest_cnt_init(&ictest.on_new, 1, 1); in do_test_plugin()
94 if (ictest.on_new.cnt < ictest.on_new.min || in do_test_plugin()
95 ictest.on_new.cnt > ictest.on_new.max) in do_test_plugin()
96 Test::Fail(tostr() << "on_new.cnt " << ictest.on_new.cnt << in do_test_plugin()
97 " not within range " << ictest.on_new.min << ".." << in do_test_plugin()
98 ictest.on_new.max); in do_test_plugin()
|
| H A D | 0100-thread_interceptors.cpp | 120 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf,
145 on_new, ic_opaque);
165 rd_kafka_conf_interceptor_add_on_new(c_conf, "test:0100", on_new,
|
| H A D | 0073-headers.c | 287 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
306 rd_kafka_conf_interceptor_add_on_new(conf, __FILE__, on_new, NULL); in do_produce()
|
| H A D | 0072-headers_ut.c | 346 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
368 rd_kafka_conf_interceptor_add_on_new(conf, __FILE__, on_new, NULL); in main_0072_headers_ut()
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/interceptor_test/ |
| H A D | interceptor_test.c | 138 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
143 ictest.on_new.cnt++; in on_new()
147 rk, conf, ici->conf, ici, ictest.on_new.cnt); in on_new()
149 ICTEST_CNT_CHECK(on_new); in on_new()
284 rd_kafka_conf_interceptor_add_on_new(conf, __FILE__, on_new, ici); in conf_init0()
|
| H A D | interceptor_test.h | 13 struct ictcnt on_new; member
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/interceptor_test/ |
| H A D | interceptor_test.c | 138 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf, in on_new() function
143 ictest.on_new.cnt++; in on_new()
147 rk, conf, ici->conf, ici, ictest.on_new.cnt); in on_new()
149 ICTEST_CNT_CHECK(on_new); in on_new()
284 rd_kafka_conf_interceptor_add_on_new(conf, __FILE__, on_new, ici); in conf_init0()
|
| H A D | interceptor_test.h | 13 struct ictcnt on_new; member
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/interceptor_test/ |
| H A D | interceptor_test.c | 138 static rd_kafka_resp_err_t on_new (rd_kafka_t *rk, const rd_kafka_conf_t *conf,
143 ictest.on_new.cnt++;
147 rk, conf, ici->conf, ici, ictest.on_new.cnt);
149 ICTEST_CNT_CHECK(on_new);
284 rd_kafka_conf_interceptor_add_on_new(conf, __FILE__, on_new, ici);
|
| H A D | interceptor_test.h | 13 struct ictcnt on_new; member
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_interceptor.c | 41 rd_kafka_interceptor_f_on_new_t *on_new; member
172 rd_list_destroy(&conf->interceptors.on_new); in rd_kafka_interceptors_destroy()
202 rd_list_init(&conf->interceptors.on_new, 0, in rd_kafka_interceptors_init()
384 RD_LIST_FOREACH(method, &rk->rk_conf.interceptors.on_new, i) { in rd_kafka_interceptors_on_new()
387 err = method->u.on_new(rk, conf, method->ic_opaque, in rd_kafka_interceptors_on_new()
653 rd_kafka_interceptor_f_on_new_t *on_new, in rd_kafka_conf_interceptor_add_on_new() argument
655 return rd_kafka_interceptor_method_add(&conf->interceptors.on_new, in rd_kafka_conf_interceptor_add_on_new()
656 ic_name, (void *)on_new, in rd_kafka_conf_interceptor_add_on_new()
|
| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_interceptor.c | 41 rd_kafka_interceptor_f_on_new_t *on_new; member
174 rd_list_destroy(&conf->interceptors.on_new); in rd_kafka_interceptors_destroy()
205 rd_list_init(&conf->interceptors.on_new, 0, in rd_kafka_interceptors_init()
390 RD_LIST_FOREACH(method, &rk->rk_conf.interceptors.on_new, i) { in rd_kafka_interceptors_on_new()
393 err = method->u.on_new(rk, conf, method->ic_opaque, in rd_kafka_interceptors_on_new()
699 rd_kafka_interceptor_f_on_new_t *on_new, in rd_kafka_conf_interceptor_add_on_new() argument
701 return rd_kafka_interceptor_method_add(&conf->interceptors.on_new, in rd_kafka_conf_interceptor_add_on_new()
702 ic_name, (void *)on_new, in rd_kafka_conf_interceptor_add_on_new()
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_interceptor.c | 41 rd_kafka_interceptor_f_on_new_t *on_new; member
174 rd_list_destroy(&conf->interceptors.on_new); in rd_kafka_interceptors_destroy()
205 rd_list_init(&conf->interceptors.on_new, 0, in rd_kafka_interceptors_init()
390 RD_LIST_FOREACH(method, &rk->rk_conf.interceptors.on_new, i) { in rd_kafka_interceptors_on_new()
393 err = method->u.on_new(rk, conf, method->ic_opaque, in rd_kafka_interceptors_on_new()
699 rd_kafka_interceptor_f_on_new_t *on_new, in rd_kafka_conf_interceptor_add_on_new() argument
701 return rd_kafka_interceptor_method_add(&conf->interceptors.on_new, in rd_kafka_conf_interceptor_add_on_new()
702 ic_name, (void *)on_new, in rd_kafka_conf_interceptor_add_on_new()
|
| /dports/editors/deforaos-editor/Editor-0.4.0/src/ |
| H A D | callbacks.h | 62 void on_new(gpointer data);
|
| /dports/multimedia/quodlibet/quodlibet-4.3.0/quodlibet/ext/events/trayicon/ |
| H A D | menu.py | 199 def on_new(widget, playlist): function
201 playlist_menu.connect('new', on_new)
|
| /dports/print/deforaos-pdfviewer/PDFViewer-0.0.2/src/ |
| H A D | callbacks.c | 165 void on_new(gpointer data) in on_new() function
|
| /dports/graphics/inkscape/inkscape-1.1_2021-05-24_c4e8f9ed74/src/ |
| H A D | inkscape-application.h | 62 void on_new();
|