Home
last modified time | relevance | path

Searched refs:write_and_free_json_kafka (Results 1 – 6 of 6) sorted by relevance

/dports/net-mgmt/pmacct/pmacct-1.7.5/src/
H A Dkafka_common.h110 extern int write_and_free_json_kafka(void *, void *);
H A Dkafka_common.c606 int write_and_free_json_kafka(void *kafka_log, void *obj) in write_and_free_json_kafka() function
634 int write_and_free_json_kafka(void *kafka_log, void *obj) in write_and_free_json_kafka() function
H A Dsfacctd.c2348 kafka_ret = write_and_free_json_kafka(peer->log->kafka_host, obj); in sf_cnt_log_msg()
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/bgp/
H A Dbgp_logdump.c218 kafka_ret = write_and_free_json_kafka(peer->log->kafka_host, obj); in bgp_peer_log_msg()
684 kafka_ret = write_and_free_json_kafka(peer->log->kafka_host, obj); in bgp_peer_log_init()
898 kafka_ret = write_and_free_json_kafka(kafka_log_ptr, obj); in bgp_peer_log_close()
1246 kafka_ret = write_and_free_json_kafka(peer->log->kafka_host, obj); in bgp_peer_dump_init()
1447 kafka_ret = write_and_free_json_kafka(peer->log->kafka_host, obj); in bgp_peer_dump_close()
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/telemetry/
H A Dtelemetry_logdump.c130 kafka_ret = write_and_free_json_kafka(peer->log->kafka_host, obj); in telemetry_log_msg()
/dports/net-mgmt/pmacct/pmacct-1.7.5/src/bmp/
H A Dbmp_logdump.c136 kafka_ret = write_and_free_json_kafka(peer->log->kafka_host, obj); in bmp_log_msg()