blob: a04366fd136676596cf3b590eb88f3ac398c3e35 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
|
# Print rd_kafka_msgq_t
define dump_msgq
set $rkmq = $arg0
set $rkm = $rkmq.rkmq_msgs.tqh_first
set $exp_msgid = 0
set $cnt = 0
while $rkm != 0
set $msgid = $rkm.rkm_u.producer.msgid
printf "#%d ((rd_kafka_msgq_t *)%p) msgid %llu\n", $cnt, $rkm, $msgid
if $exp_msgid != 0 && $exp_msgid != $msgid
printf " ^ WARNING: expected msgid %llu, not %llu\n", $exp_msgid, $msgid
end
set $exp_msgid = $msgid + 1
set $rkm = $rkm.rkm_link.tqe_next
set $cnt++
end
end
|
