Searched refs:kafka_handle (Results 1 – 5 of 5) sorted by relevance
| /dports/net-mgmt/collectd5/collectd-5.12.0/src/ |
| H A D | write_kafka.c | 59 static int kafka_handle(struct kafka_topic_context *);
117 static int kafka_handle(struct kafka_topic_context *ctx) /* {{{ */ in kafka_handle() function
188 status = kafka_handle(ctx); in kafka_write()
|
| /dports/net/wireshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-kafka.c | 10302 static dissector_handle_t kafka_handle; in proto_reg_handoff_kafka() local
10304 kafka_handle = register_dissector("kafka", dissect_kafka_tcp, proto_kafka); in proto_reg_handoff_kafka()
10306 dissector_add_uint_range_with_preference("tcp.port", KAFKA_TCP_DEFAULT_RANGE, kafka_handle); in proto_reg_handoff_kafka()
10307 ssl_dissector_add(0, kafka_handle); in proto_reg_handoff_kafka()
|
| /dports/net/wireshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-kafka.c | 10302 static dissector_handle_t kafka_handle; in proto_reg_handoff_kafka() local
10304 kafka_handle = register_dissector("kafka", dissect_kafka_tcp, proto_kafka); in proto_reg_handoff_kafka()
10306 dissector_add_uint_range_with_preference("tcp.port", KAFKA_TCP_DEFAULT_RANGE, kafka_handle); in proto_reg_handoff_kafka()
10307 ssl_dissector_add(0, kafka_handle); in proto_reg_handoff_kafka()
|
| /dports/net/tshark-lite/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-kafka.c | 10302 static dissector_handle_t kafka_handle;
10304 kafka_handle = register_dissector("kafka", dissect_kafka_tcp, proto_kafka);
10306 dissector_add_uint_range_with_preference("tcp.port", KAFKA_TCP_DEFAULT_RANGE, kafka_handle);
10307 ssl_dissector_add(0, kafka_handle);
|
| /dports/net/tshark/wireshark-3.6.1/epan/dissectors/ |
| H A D | packet-kafka.c | 10302 static dissector_handle_t kafka_handle; in proto_reg_handoff_kafka() local
10304 kafka_handle = register_dissector("kafka", dissect_kafka_tcp, proto_kafka); in proto_reg_handoff_kafka()
10306 dissector_add_uint_range_with_preference("tcp.port", KAFKA_TCP_DEFAULT_RANGE, kafka_handle); in proto_reg_handoff_kafka()
10307 ssl_dissector_add(0, kafka_handle); in proto_reg_handoff_kafka()
|