| /dports/net/librdkafka/librdkafka-1.8.2/src/ |
| H A D | rdkafka_mock_handlers.c | 48 static int rd_kafka_mock_handle_Produce (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_Produce()
169 static int rd_kafka_mock_handle_Fetch (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_Fetch()
1014 rd_kafka_mock_handle_FindCoordinator (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_FindCoordinator()
1089 rd_kafka_mock_handle_JoinGroup (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_JoinGroup()
1202 rd_kafka_mock_handle_Heartbeat (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_Heartbeat()
1277 rd_kafka_mock_handle_LeaveGroup (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_LeaveGroup()
1348 rd_kafka_mock_handle_SyncGroup (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_SyncGroup()
1540 rd_kafka_mock_handle_InitProducerId (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_InitProducerId()
1710 rd_kafka_mock_handle_AddOffsetsToTxn (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_AddOffsetsToTxn()
1760 rd_kafka_mock_handle_TxnOffsetCommit (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_TxnOffsetCommit()
[all …]
|
| H A D | rdkafka_mock_cgrp.c | 236 rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_cgrp_member_sync_set()
327 rd_kafka_mock_connection_t *mconn; in rd_kafka_mock_cgrp_elect_leader() local
538 rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_cgrp_member_add()
687 rd_kafka_mock_connection_t *mconn) { in rd_kafka_mock_cgrps_connection_closed()
|
| H A D | rdkafka_mock.c | 641 static void rd_kafka_mock_connection_close (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_close()
713 rd_kafka_mock_connection_read_request (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_read_request()
890 rd_kafka_mock_connection_parse_request (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_parse_request()
945 rd_kafka_mock_connection_t *mconn = arg; in rd_kafka_mock_connection_write_out_tmr_cb() local
960 rd_kafka_mock_connection_write_out (rd_kafka_mock_connection_t *mconn) { in rd_kafka_mock_connection_write_out()
1020 rd_kafka_mock_connection_t *mconn, *tmp; in rd_kafka_mock_broker_connections_write_out() local
1035 rd_kafka_mock_connection_t *mconn = opaque; in rd_kafka_mock_connection_io() local
1082 void rd_kafka_mock_connection_set_blocking (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_set_blocking()
1093 rd_kafka_mock_connection_t *mconn; in rd_kafka_mock_connection_new() local
1257 rd_kafka_mock_connection_t *mconn; in rd_kafka_mock_broker_close_all() local
[all …]
|
| /dports/sysutils/vector/vector-0.10.0/cargo-crates/rdkafka-sys-2.0.0+1.4.2/librdkafka/src/ |
| H A D | rdkafka_mock_handlers.c | 48 static int rd_kafka_mock_handle_Produce (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_Produce()
170 static int rd_kafka_mock_handle_Fetch (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_Fetch()
1020 rd_kafka_mock_handle_FindCoordinator (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_FindCoordinator()
1096 rd_kafka_mock_handle_JoinGroup (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_JoinGroup()
1210 rd_kafka_mock_handle_Heartbeat (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_Heartbeat()
1286 rd_kafka_mock_handle_LeaveGroup (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_LeaveGroup()
1358 rd_kafka_mock_handle_SyncGroup (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_SyncGroup()
1489 rd_kafka_mock_handle_InitProducerId (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_InitProducerId()
1636 rd_kafka_mock_handle_AddOffsetsToTxn (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_AddOffsetsToTxn()
1684 rd_kafka_mock_handle_TxnOffsetCommit (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_TxnOffsetCommit()
[all …]
|
| H A D | rdkafka_mock_cgrp.c | 214 rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_cgrp_member_sync_set()
305 rd_kafka_mock_connection_t *mconn; in rd_kafka_mock_cgrp_elect_leader() local
493 rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_cgrp_member_add()
642 rd_kafka_mock_connection_t *mconn) { in rd_kafka_mock_cgrps_connection_closed()
|
| H A D | rdkafka_mock.c | 638 static void rd_kafka_mock_connection_close (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_close()
669 void rd_kafka_mock_connection_send_response (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_send_response()
702 rd_kafka_mock_connection_read_request (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_read_request()
869 rd_kafka_mock_connection_parse_request (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_parse_request()
924 rd_kafka_mock_connection_t *mconn = arg; in rd_kafka_mock_connection_write_out_tmr_cb() local
939 rd_kafka_mock_connection_write_out (rd_kafka_mock_connection_t *mconn) { in rd_kafka_mock_connection_write_out()
989 rd_kafka_mock_connection_t *mconn = opaque; in rd_kafka_mock_connection_io() local
1036 void rd_kafka_mock_connection_set_blocking (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_set_blocking()
1047 rd_kafka_mock_connection_t *mconn; in rd_kafka_mock_connection_new() local
1209 rd_kafka_mock_connection_t *mconn; in rd_kafka_mock_broker_close_all() local
|
| /dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/ |
| H A D | rdkafka_mock_handlers.c | 48 static int rd_kafka_mock_handle_Produce (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_Produce()
169 static int rd_kafka_mock_handle_Fetch (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_Fetch()
1015 rd_kafka_mock_handle_FindCoordinator (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_FindCoordinator()
1090 rd_kafka_mock_handle_JoinGroup (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_JoinGroup()
1203 rd_kafka_mock_handle_Heartbeat (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_Heartbeat()
1278 rd_kafka_mock_handle_LeaveGroup (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_LeaveGroup()
1349 rd_kafka_mock_handle_SyncGroup (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_SyncGroup()
1541 rd_kafka_mock_handle_InitProducerId (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_InitProducerId()
1711 rd_kafka_mock_handle_AddOffsetsToTxn (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_AddOffsetsToTxn()
1761 rd_kafka_mock_handle_TxnOffsetCommit (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_handle_TxnOffsetCommit()
[all …]
|
| H A D | rdkafka_mock_cgrp.c | 236 rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_cgrp_member_sync_set()
327 rd_kafka_mock_connection_t *mconn; in rd_kafka_mock_cgrp_elect_leader() local
538 rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_cgrp_member_add()
687 rd_kafka_mock_connection_t *mconn) { in rd_kafka_mock_cgrps_connection_closed()
|
| H A D | rdkafka_mock.c | 641 static void rd_kafka_mock_connection_close (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_close()
713 rd_kafka_mock_connection_read_request (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_read_request()
890 rd_kafka_mock_connection_parse_request (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_parse_request()
945 rd_kafka_mock_connection_t *mconn = arg; in rd_kafka_mock_connection_write_out_tmr_cb() local
960 rd_kafka_mock_connection_write_out (rd_kafka_mock_connection_t *mconn) { in rd_kafka_mock_connection_write_out()
1020 rd_kafka_mock_connection_t *mconn, *tmp; in rd_kafka_mock_broker_connections_write_out() local
1035 rd_kafka_mock_connection_t *mconn = opaque; in rd_kafka_mock_connection_io() local
1082 void rd_kafka_mock_connection_set_blocking (rd_kafka_mock_connection_t *mconn, in rd_kafka_mock_connection_set_blocking()
1093 rd_kafka_mock_connection_t *mconn; in rd_kafka_mock_connection_new() local
1257 rd_kafka_mock_connection_t *mconn; in rd_kafka_mock_broker_close_all() local
[all …]
|
| /dports/devel/cargo-c/cargo-c-0.9.6+cargo-0.58/cargo-crates/libnghttp2-sys-0.1.7+1.45.0/nghttp2/src/ |
| H A D | shrpx_memcached_connection.cc | 44 auto mconn = static_cast<MemcachedConnection *>(conn->data); in timeoutcb() local
61 auto mconn = static_cast<MemcachedConnection *>(conn->data); in readcb() local
73 auto mconn = static_cast<MemcachedConnection *>(conn->data); in writecb() local
85 auto mconn = static_cast<MemcachedConnection *>(conn->data); in connectcb() local
|
| /dports/net/proby/proby-1.0.2/cargo-crates/libnghttp2-sys-0.1.4+1.41.0/nghttp2/src/ |
| H A D | shrpx_memcached_connection.cc | 44 auto mconn = static_cast<MemcachedConnection *>(conn->data); in timeoutcb() local
61 auto mconn = static_cast<MemcachedConnection *>(conn->data); in readcb() local
73 auto mconn = static_cast<MemcachedConnection *>(conn->data); in writecb() local
85 auto mconn = static_cast<MemcachedConnection *>(conn->data); in connectcb() local
|
| /dports/devel/cargo-generate/cargo-generate-0.9.0/cargo-crates/libnghttp2-sys-0.1.6+1.43.0/nghttp2/src/ |
| H A D | shrpx_memcached_connection.cc | 44 auto mconn = static_cast<MemcachedConnection *>(conn->data); in timeoutcb() local
61 auto mconn = static_cast<MemcachedConnection *>(conn->data); in readcb() local
73 auto mconn = static_cast<MemcachedConnection *>(conn->data); in writecb() local
85 auto mconn = static_cast<MemcachedConnection *>(conn->data); in connectcb() local
|
| /dports/www/libnghttp2/nghttp2-1.46.0/src/ |
| H A D | shrpx_memcached_connection.cc | 44 auto mconn = static_cast<MemcachedConnection *>(conn->data); in timeoutcb() local
61 auto mconn = static_cast<MemcachedConnection *>(conn->data); in readcb() local
73 auto mconn = static_cast<MemcachedConnection *>(conn->data); in writecb() local
85 auto mconn = static_cast<MemcachedConnection *>(conn->data); in connectcb() local
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/libnghttp2-sys/nghttp2/src/ |
| H A D | shrpx_memcached_connection.cc | 44 auto mconn = static_cast<MemcachedConnection *>(conn->data); in timeoutcb() local
61 auto mconn = static_cast<MemcachedConnection *>(conn->data); in readcb() local
73 auto mconn = static_cast<MemcachedConnection *>(conn->data); in writecb() local
85 auto mconn = static_cast<MemcachedConnection *>(conn->data); in connectcb() local
|
| /dports/www/nghttp2/nghttp2-1.46.0/src/ |
| H A D | shrpx_memcached_connection.cc | 44 auto mconn = static_cast<MemcachedConnection *>(conn->data); in timeoutcb() local
61 auto mconn = static_cast<MemcachedConnection *>(conn->data); in readcb() local
73 auto mconn = static_cast<MemcachedConnection *>(conn->data); in writecb() local
85 auto mconn = static_cast<MemcachedConnection *>(conn->data); in connectcb() local
|
| /dports/java/springframework31/spring-framework-3.1.4.RELEASE/projects/org.springframework.transaction/src/main/java/org/springframework/jca/work/jboss/ |
| H A D | JBossWorkManagerUtils.java | 64 …MBeanServerConnection mconn = (MBeanServerConnection) jndiContext.lookup(MBEAN_SERVER_CONNECTION_J… in getWorkManager() local
|
| /dports/net-mgmt/hastmon/hastmon-0.3.4/hastmon/ |
| H A D | proto.c | 282 proto_connection_send(const struct proto_conn *conn, struct proto_conn *mconn) in proto_connection_send()
|
| /dports/net/kamailio/kamailio-5.4.5/src/modules/kazoo/ |
| H A D | kz_amqp.h | 332 amqp_connection_close_t *mconn; in kz_amqp_error() local
|