diff options
| author | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-16 11:30:08 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@rabbitmq.com> | 2010-07-16 11:30:08 +0100 |
| commit | 4fb7de5a232e4fccef5fdc40d635bb22c2a560db (patch) | |
| tree | e1c79ca4f80d65c632173e5de20734a6b40ab22e | |
| parent | 2111eefcfa8783c3581a68c9a9bf9359420879b8 (diff) | |
| download | rabbitmq-server-git-4fb7de5a232e4fccef5fdc40d635bb22c2a560db.tar.gz | |
add pending_acks to bq state report
it turns out to be useful
| -rw-r--r-- | src/rabbit_variable_queue.erl | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 3f73ac0bfe..15509b3c35 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -652,6 +652,7 @@ handle_pre_hibernate(State = #vqstate { index_state = IndexState }) -> status(#vqstate { q1 = Q1, q2 = Q2, delta = Delta, q3 = Q3, q4 = Q4, len = Len, + pending_ack = PA, on_sync = {_, _, From}, target_ram_msg_count = TargetRamMsgCount, ram_msg_count = RamMsgCount, @@ -666,6 +667,7 @@ status(#vqstate { q1 = Q1, q2 = Q2, delta = Delta, q3 = Q3, q4 = Q4, {q3 , bpqueue:len(Q3)}, {q4 , queue:len(Q4)}, {len , Len}, + {pending_acks , dict:size(PA)}, {outstanding_txns , length(From)}, {target_ram_msg_count , TargetRamMsgCount}, {ram_msg_count , RamMsgCount}, |