Searched defs:remains_ms (Results 1 – 9 of 9) sorted by relevance
286 rd_timeout_remains_limit0 (int remains_ms, int limit_ms) { in rd_timeout_remains_limit0()
1639 int remains_ms = rd_timeout_remains(rko->rko_u.txn.abs_timeout); in rd_kafka_txn_handle_TxnOffsetCommit() local1795 int remains_ms; in rd_kafka_txn_handle_AddOffsetsToTxn() local
4130 int remains_ms; in rd_kafka_clusterid() local4172 int remains_ms; in rd_kafka_controllerid() local
1700 int remains_ms; in rd_kafka_broker_controller() local
1469 int remains_ms = rd_timeout_remains(rko->rko_u.txn.abs_timeout); in rd_kafka_txn_handle_TxnOffsetCommit() local1600 int remains_ms; in rd_kafka_txn_handle_AddOffsetsToTxn() local
3928 int remains_ms; in rd_kafka_clusterid() local3970 int remains_ms; in rd_kafka_controllerid() local
1483 int remains_ms; in rd_kafka_broker_controller() local
1687 int remains_ms; in rd_kafka_broker_controller() local