-
Notifications
You must be signed in to change notification settings - Fork 3.2k
Open
Description
Since inflight_cnt, retry_cnt, outq_cnt has int type
librdkafka/src/rdkafka_broker.c
Lines 941 to 942 in 9387761
| static void rd_kafka_broker_timeout_scan(rd_kafka_broker_t *rkb, rd_ts_t now) { | |
| int inflight_cnt, retry_cnt, outq_cnt; |
And rd_atomic64_add accepts two int64
Lines 144 to 145 in 9387761
| static RD_INLINE int64_t RD_UNUSED rd_atomic64_add(rd_atomic64_t *ra, | |
| int64_t v) { |
There is possible integer overflow at:
librdkafka/src/rdkafka_broker.c
Lines 969 to 970 in 9387761
| rd_atomic64_add(&rkb->rkb_c.req_timeouts, | |
| inflight_cnt + outq_cnt); |
Possible fix:
<static_cast>(int64) inflight_cnt + outq_cnt
Metadata
Metadata
Assignees
Labels
No labels