Home
last modified time | relevance | path

Searched refs:state_duration_ms (Results 1 – 2 of 2) sorted by relevance

/dports/net/librdkafka/librdkafka-1.8.2/src/
H A Drdkafka_broker.c394 int state_duration_ms = (int)((rd_clock() - rkb->rkb_ts_state)/1000); in rd_kafka_broker_set_error() local
448 state_duration_ms < 2000/*2s*/ && in rd_kafka_broker_set_error()
484 state_duration_ms, in rd_kafka_broker_set_error()
/dports/sysutils/fluent-bit/fluent-bit-1.8.11/plugins/out_kafka/librdkafka-1.7.0/src/
H A Drdkafka_broker.c385 int state_duration_ms = (int)((rd_clock() - rkb->rkb_ts_state)/1000); in rd_kafka_broker_set_error() local
438 state_duration_ms < 2000/*2s*/ && in rd_kafka_broker_set_error()
474 state_duration_ms, in rd_kafka_broker_set_error()