Searched refs:rkbuf_retries (Results 1 – 12 of 12) sorted by relevance
309 rkbuf->rkbuf_retries, in rd_kafka_bufq_dump()360 rkbuf->rkbuf_retries + incr_retry > in rd_kafka_buf_retry()372 rkbuf->rkbuf_retries += incr_retry; in rd_kafka_buf_retry()
623 int rkbuf_retries; /**< Retries so far. */ member
3188 request->rkbuf_retries = 0; in rd_kafka_query_wmark_offsets_resp_cb()3372 request->rkbuf_retries = 0; in rd_kafka_get_offsets_for_times_resp_cb()
2496 rkbuf->rkbuf_retries, rkbuf->rkbuf_max_retries, in rd_kafka_broker_buf_retry()
325 rkbuf->rkbuf_retries, in rd_kafka_bufq_dump()376 rkbuf->rkbuf_retries + incr_retry > in rd_kafka_buf_retry()388 rkbuf->rkbuf_retries += incr_retry; in rd_kafka_buf_retry()
244 int rkbuf_retries; /**< Retries so far. */
3402 request->rkbuf_retries = 0;3584 request->rkbuf_retries = 0;
2728 rkbuf->rkbuf_retries, rkbuf->rkbuf_max_retries, in rd_kafka_broker_buf_retry()
328 rkbuf->rkbuf_retries, in rd_kafka_bufq_dump()379 rkbuf->rkbuf_retries + incr_retry > in rd_kafka_buf_retry()391 rkbuf->rkbuf_retries += incr_retry; in rd_kafka_buf_retry()
297 int rkbuf_retries; /**< Retries so far. */ member
3403 request->rkbuf_retries = 0; in rd_kafka_query_wmark_offsets_resp_cb()3584 request->rkbuf_retries = 0; in rd_kafka_get_offsets_for_times_resp_cb()
2776 rkbuf->rkbuf_retries, rkbuf->rkbuf_max_retries, in rd_kafka_broker_buf_retry()