Searched refs:write_binary_kafka (Results 1 – 4 of 4) sorted by relevance
| /dports/net-mgmt/pmacct/pmacct-1.7.5/src/ |
| H A D | kafka_common.h | 111 extern int write_binary_kafka(void *, void *, size_t);
|
| H A D | kafka_common.c | 640 int write_binary_kafka(void *kafka_log, void *obj, size_t len) in write_binary_kafka() function
|
| /dports/net-mgmt/pmacct/pmacct-1.7.5/src/bgp/ |
| H A D | bgp_logdump.c | 544 kafka_ret = write_binary_kafka(peer->log->kafka_host, p_avro_local_buf, p_avro_len); in bgp_peer_log_msg()
552 …kafka_ret = write_binary_kafka(peer->log->kafka_host, avro_local_str, (strlen(avro_local_str) + 1)… in bgp_peer_log_msg()
795 kafka_ret = write_binary_kafka(peer->log->kafka_host, p_avro_local_buf, p_avro_len); in bgp_peer_log_init()
803 …kafka_ret = write_binary_kafka(peer->log->kafka_host, avro_local_str, (strlen(avro_local_str) + 1)… in bgp_peer_log_init()
1010 kafka_ret = write_binary_kafka(peer->log->kafka_host, p_avro_local_buf, p_avro_len); in bgp_peer_log_close()
1018 …kafka_ret = write_binary_kafka(peer->log->kafka_host, avro_local_str, (strlen(avro_local_str) + 1)… in bgp_peer_log_close()
1360 kafka_ret = write_binary_kafka(peer->log->kafka_host, p_avro_local_buf, p_avro_len); in bgp_peer_dump_init()
1368 …kafka_ret = write_binary_kafka(peer->log->kafka_host, avro_local_str, (strlen(avro_local_str) + 1)… in bgp_peer_dump_init()
1575 kafka_ret = write_binary_kafka(peer->log->kafka_host, p_avro_local_buf, p_avro_len); in bgp_peer_dump_close()
1583 …kafka_ret = write_binary_kafka(peer->log->kafka_host, avro_local_str, (strlen(avro_local_str) + 1)… in bgp_peer_dump_close()
|
| /dports/net-mgmt/pmacct/pmacct-1.7.5/src/bmp/ |
| H A D | bmp_logdump.c | 298 kafka_ret = write_binary_kafka(peer->log->kafka_host, p_avro_local_buf, p_avro_len); in bmp_log_msg()
306 …kafka_ret = write_binary_kafka(peer->log->kafka_host, avro_local_str, (strlen(avro_local_str) + 1)… in bmp_log_msg()
|