diff options
| -rw-r--r-- | src/credit_flow.erl | 10 |
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). |