src/rdkafka_broker.c
static void rd_kafka_broker_internal_serve (rd_kafka_broker_t *rkb,
                                     rd_ts_t abs_timeout) {
        int initial_state = rkb->rkb_state;

        do {
                rd_kafka_broker_toppars_serve(rkb);
                rd_kafka_broker_ops_io_serve(rkb, abs_timeout);
        } while (!rd_kafka_broker_terminating(rkb) &&
                 (int)rkb->rkb_state == initial_state &&
                 !rd_timeout_expired(rd_timeout_remains(abs_timeout)));
}
/**
 * @brief Idle function for the internal broker handle.
 */
@brief Idle function for the internal broker handle.
@brief Idle function for the internal broker handle .
static void rd_kafka_broker_internal_serve (rd_kafka_broker_t *rkb,
                                     rd_ts_t abs_timeout) {
        int initial_state = rkb->rkb_state;
        do {
                rd_kafka_broker_toppars_serve(rkb);
                rd_kafka_broker_ops_io_serve(rkb, abs_timeout);
        } while (!rd_kafka_broker_terminating(rkb) &&
                 (int)rkb->rkb_state == initial_state &&
                 !rd_timeout_expired(rd_timeout_remains(abs_timeout)));
}
static void rd_kafka_broker_internal_serve ( rd_kafka_broker_t * rkb , rd_ts_t abs_timeout ) { int initial_state = rkb -> rkb_state ; do { rd_kafka_broker_toppars_serve ( rkb ) ; rd_kafka_broker_ops_io_serve ( rkb , abs_timeout ) ; } while ( ! rd_kafka_broker_terminating ( rkb ) && ( int ) rkb -> rkb_state == initial_state && ! rd_timeout_expired ( rd_timeout_remains ( abs_timeout ) ) ) ; }
@brief Idle function for the internal broker handle.
@brief Idle function for the internal broker handle .