| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_interceptor.c | 56 void *ic_opaque; member
119 method->ic_opaque = ic_opaque; in rd_kafka_interceptor_method_new()
668 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_conf_set() argument
678 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_conf_dup() argument
688 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_conf_destroy() argument
700 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_new() argument
711 void *ic_opaque) { in rd_kafka_interceptor_add_on_destroy() argument
722 void *ic_opaque) { in rd_kafka_interceptor_add_on_send() argument
733 void *ic_opaque) { in rd_kafka_interceptor_add_on_acknowledgement() argument
747 void *ic_opaque) { in rd_kafka_interceptor_add_on_consume() argument
[all …]
|
| H A D | rdkafka.h | 5654 void *ic_opaque);
5694 void *ic_opaque);
5718 void *ic_opaque);
5745 void *ic_opaque);
5765 void *ic_opaque);
5784 void *ic_opaque);
5803 void *ic_opaque);
5831 void *ic_opaque);
5851 void *ic_opaque);
5870 void *ic_opaque);
[all …]
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_interceptor.c | 56 void *ic_opaque; member
119 method->ic_opaque = ic_opaque; in rd_kafka_interceptor_method_new()
668 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_conf_set() argument
678 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_conf_dup() argument
688 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_conf_destroy() argument
700 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_new() argument
711 void *ic_opaque) { in rd_kafka_interceptor_add_on_destroy() argument
722 void *ic_opaque) { in rd_kafka_interceptor_add_on_send() argument
733 void *ic_opaque) { in rd_kafka_interceptor_add_on_acknowledgement() argument
747 void *ic_opaque) { in rd_kafka_interceptor_add_on_consume() argument
[all …]
|
| H A D | rdkafka.h | 5648 void *ic_opaque);
5688 void *ic_opaque);
5712 void *ic_opaque);
5739 void *ic_opaque);
5759 void *ic_opaque);
5778 void *ic_opaque);
5797 void *ic_opaque);
5825 void *ic_opaque);
5845 void *ic_opaque);
5864 void *ic_opaque);
[all …]
|
| /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 | 54 void *ic_opaque; member
117 method->ic_opaque = ic_opaque; in rd_kafka_interceptor_method_new()
622 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_conf_set() argument
632 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_conf_dup() argument
642 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_conf_destroy() argument
654 void *ic_opaque) { in rd_kafka_conf_interceptor_add_on_new() argument
665 void *ic_opaque) { in rd_kafka_interceptor_add_on_destroy() argument
676 void *ic_opaque) { in rd_kafka_interceptor_add_on_send() argument
687 void *ic_opaque) { in rd_kafka_interceptor_add_on_acknowledgement() argument
701 void *ic_opaque) { in rd_kafka_interceptor_add_on_consume() argument
[all …]
|
| H A D | rdkafka.h | 5159 void *ic_opaque);
5183 void *ic_opaque);
5210 void *ic_opaque);
5230 void *ic_opaque);
5249 void *ic_opaque);
5268 void *ic_opaque);
5296 void *ic_opaque);
5316 void *ic_opaque);
5335 void *ic_opaque);
5353 void *ic_opaque);
[all …]
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/interceptor_test/ |
| H A D | interceptor_test.c | 82 void *ic_opaque) { in on_send() argument
83 struct ici *ici = ic_opaque; in on_send()
92 struct ici *ici = ic_opaque; in on_acknowledgement()
101 void *ic_opaque) { in on_consume() argument
102 struct ici *ici = ic_opaque; in on_consume()
111 struct ici *ici = ic_opaque; in on_commit()
128 struct ici *ici = ic_opaque; in on_destroy()
141 struct ici *ici = ic_opaque; in on_new()
179 struct ici *ici = ic_opaque; in on_conf_set()
238 struct ici *ici = ic_opaque; in on_conf_dup()
[all …]
|
| /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 | 82 void *ic_opaque) { in on_send() argument
83 struct ici *ici = ic_opaque; in on_send()
92 struct ici *ici = ic_opaque; in on_acknowledgement()
101 void *ic_opaque) { in on_consume() argument
102 struct ici *ici = ic_opaque; in on_consume()
111 struct ici *ici = ic_opaque; in on_commit()
128 struct ici *ici = ic_opaque; in on_destroy()
141 struct ici *ici = ic_opaque; in on_new()
179 struct ici *ici = ic_opaque; in on_conf_set()
238 struct ici *ici = ic_opaque; in on_conf_dup()
[all …]
|
| /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 | 82 void *ic_opaque) {
83 struct ici *ici = ic_opaque;
92 struct ici *ici = ic_opaque;
101 void *ic_opaque) {
102 struct ici *ici = ic_opaque;
111 struct ici *ici = ic_opaque;
128 struct ici *ici = ic_opaque;
141 struct ici *ici = ic_opaque;
179 struct ici *ici = ic_opaque;
238 struct ici *ici = ic_opaque;
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/tests/ |
| H A D | 0064-interceptors.c | 116 int ic_id = (int)(intptr_t)ic_opaque; in verify_msg()
151 void *ic_opaque) { in on_send() argument
152 TEST_ASSERT(ic_opaque != NULL); in on_send()
159 void *ic_opaque) { in on_ack() argument
160 TEST_ASSERT(ic_opaque != NULL); in on_ack()
168 TEST_ASSERT(ic_opaque != NULL); in on_consume()
170 ic_opaque); in on_consume()
177 rd_kafka_resp_err_t err, void *ic_opaque) { in on_commit() argument
178 int ic_id = (int)(intptr_t)ic_opaque; in on_commit()
182 TEST_ASSERT(ic_opaque != NULL); in on_commit()
[all …]
|
| H A D | 0100-thread_interceptors.cpp | 86 void *ic_opaque) { in on_thread_start_trampoline() argument
87 myThreadCb *threadcb = (myThreadCb *)ic_opaque; in on_thread_start_trampoline()
104 void *ic_opaque) { in on_thread_exit_trampoline() argument
105 myThreadCb *threadcb = (myThreadCb *)ic_opaque; in on_thread_exit_trampoline()
121 void *ic_opaque, in on_new() argument
126 ic_opaque); in on_new()
129 ic_opaque); in on_new()
142 void *ic_opaque) { in on_conf_dup() argument
145 on_new, ic_opaque); in on_conf_dup()
|
| H A D | 0073-headers.c | 233 void *ic_opaque) { in on_send1() argument
267 void *ic_opaque) { in on_send2() argument
288 void *ic_opaque, in on_new() argument
|
| H A D | 0072-headers_ut.c | 244 void *ic_opaque) { in on_send1() argument
326 void *ic_opaque) { in on_send2() argument
347 void *ic_opaque, in on_new() argument
|
| H A D | 0076-produce_retry.c | 179 void *ic_opaque) { in on_request_sent() argument
214 void *ic_opaque, in on_new_producer() argument
|
| /dports/net/librdkafka/librdkafka-1.8.2/tests/ |
| H A D | 0100-thread_interceptors.cpp | 86 void *ic_opaque) { in on_thread_start_trampoline() argument
87 myThreadCb *threadcb = (myThreadCb *)ic_opaque; in on_thread_start_trampoline()
104 void *ic_opaque) { in on_thread_exit_trampoline() argument
105 myThreadCb *threadcb = (myThreadCb *)ic_opaque; in on_thread_exit_trampoline()
121 void *ic_opaque, in on_new() argument
126 ic_opaque); in on_new()
129 ic_opaque); in on_new()
142 void *ic_opaque) { in on_conf_dup() argument
145 on_new, ic_opaque); in on_conf_dup()
|
| H A D | 0064-interceptors.c | 117 int ic_id = (int)(intptr_t)ic_opaque; in verify_msg()
156 void *ic_opaque) { in on_send() argument
157 TEST_ASSERT(ic_opaque != NULL); in on_send()
164 void *ic_opaque) { in on_ack() argument
165 TEST_ASSERT(ic_opaque != NULL); in on_ack()
173 TEST_ASSERT(ic_opaque != NULL); in on_consume()
175 ic_opaque); in on_consume()
182 rd_kafka_resp_err_t err, void *ic_opaque) { in on_commit() argument
183 int ic_id = (int)(intptr_t)ic_opaque; in on_commit()
187 TEST_ASSERT(ic_opaque != NULL); in on_commit()
[all …]
|
| H A D | 0073-headers.c | 233 void *ic_opaque) { in on_send1() argument
267 void *ic_opaque) { in on_send2() argument
288 void *ic_opaque, in on_new() argument
|
| H A D | 0072-headers_ut.c | 244 void *ic_opaque) { in on_send1() argument
326 void *ic_opaque) { in on_send2() argument
347 void *ic_opaque, in on_new() argument
|
| H A D | 0076-produce_retry.c | 179 void *ic_opaque) { in on_request_sent() argument
214 void *ic_opaque, in on_new_producer() argument
|
| H A D | 0086-purge.c | 78 void *ic_opaque) { in on_request_sent() argument
100 void *ic_opaque, in on_new_producer() argument
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/tests/ |
| H A D | 0100-thread_interceptors.cpp | 86 void *ic_opaque) { in mc_issue_attachment_delete()
87 myThreadCb *threadcb = (myThreadCb *)ic_opaque; in mc_issue_attachment_delete()
104 void *ic_opaque) {
105 myThreadCb *threadcb = (myThreadCb *)ic_opaque;
121 void *ic_opaque,
126 ic_opaque);
129 ic_opaque);
142 void *ic_opaque) {
145 on_new, ic_opaque);
|
| H A D | 0064-interceptors.c | 117 int ic_id = (int)(intptr_t)ic_opaque; in verify_msg()
156 void *ic_opaque) { in on_send() argument
157 TEST_ASSERT(ic_opaque != NULL); in on_send()
164 void *ic_opaque) { in on_ack() argument
165 TEST_ASSERT(ic_opaque != NULL); in on_ack()
173 TEST_ASSERT(ic_opaque != NULL); in on_consume()
175 ic_opaque); in on_consume()
182 rd_kafka_resp_err_t err, void *ic_opaque) { in on_commit() argument
183 int ic_id = (int)(intptr_t)ic_opaque; in on_commit()
187 TEST_ASSERT(ic_opaque != NULL); in on_commit()
[all …]
|
| H A D | 0073-headers.c | 233 void *ic_opaque) { in on_send1() argument
267 void *ic_opaque) { in on_send2() argument
288 void *ic_opaque, in on_new() argument
|
| H A D | 0072-headers_ut.c | 244 void *ic_opaque) { in on_send1() argument
326 void *ic_opaque) { in on_send2() argument
347 void *ic_opaque, in on_new() argument
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/src/ |
| H A D | bindings.rs | 1597 ic_opaque: *mut c_void,
1606 ic_opaque: *mut c_void,
1615 ic_opaque: *mut c_void,
1627 ic_opaque: *mut c_void,
1634 ic_opaque: *mut c_void,
1641 ic_opaque: *mut c_void,
1649 ic_opaque: *mut c_void,
1662 ic_opaque: *mut c_void,
1670 ic_opaque: *mut c_void,
1678 ic_opaque: *mut c_void,
[all …]
|