summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorMichael Klishin <mklishin@pivotal.io>2015-05-02 14:47:43 +0300
committerMichael Klishin <mklishin@pivotal.io>2015-05-02 14:47:43 +0300
commit3e936103ae7373d031c9c0f34015c69d4c811a69 (patch)
tree13d2708246285162d25b652520da6fcdd4ea6ffb /src
parent87ce609573a5682e1788cfc0bb3b63d5637149d8 (diff)
downloadrabbitmq-server-git-3e936103ae7373d031c9c0f34015c69d4c811a69.tar.gz
Include more information about processes blocked by credit_flow
Diffstat (limited to 'src')
-rw-r--r--src/credit_flow.erl10
1 files changed, 8 insertions, 2 deletions
diff --git a/src/credit_flow.erl b/src/credit_flow.erl
index 3e45dce8f6..4d30cf5001 100644
--- a/src/credit_flow.erl
+++ b/src/credit_flow.erl
@@ -70,9 +70,15 @@
-ifdef(CREDIT_FLOW_TRACING).
-define(TRACE_BLOCKED(THIS, FROM), rabbit_event:notify(credit_flow_blocked,
- [{process, THIS}, {from, FROM}])).
+ [{process, THIS},
+ {process_info, erlang:process_info(THIS)},
+ {from, FROM},
+ {from_info, erlang:process_info(FROM)},
+ {timestamp, os:timestamp()}])).
-define(TRACE_UNBLOCKED(THIS, FROM), rabbit_event:notify(credit_flow_unblocked,
- [{process, THIS}, {from, FROM}])).
+ [{process, THIS},
+ {from, FROM},
+ {timestamp, os:timestamp()}])).
-else.
-define(TRACE_BLOCKED(THIS, FROM), ok).
-define(TRACE_UNBLOCKED(THIS, FROM), ok).