diff options
| author | Matthew Sackman <matthew@rabbitmq.com> | 2011-05-17 17:29:38 +0100 |
|---|---|---|
| committer | Matthew Sackman <matthew@rabbitmq.com> | 2011-05-17 17:29:38 +0100 |
| commit | 76bf983a059a1f431be1452896baed32b8eef4bf (patch) | |
| tree | 20f9de9a719ffb31c07ee1c78de353329d77cd5d /src | |
| parent | 86da4d3fdb023363d52eec0d95fd823d707ce29c (diff) | |
| download | rabbitmq-server-76bf983a059a1f431be1452896baed32b8eef4bf.tar.gz | |
Improve logging information
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_coordinator.erl | 3 | ||||
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 3 |
2 files changed, 4 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_coordinator.erl b/src/rabbit_mirror_queue_coordinator.erl index 05e4a808..729749dc 100644 --- a/src/rabbit_mirror_queue_coordinator.erl +++ b/src/rabbit_mirror_queue_coordinator.erl @@ -257,7 +257,8 @@ handle_call(get_gm, _From, State = #state { gm = GM }) -> handle_cast({gm_deaths, Deaths}, State = #state { q = #amqqueue { name = QueueName } }) -> rabbit_log:info("Master ~p saw deaths ~p for ~s~n", - [self(), Deaths, rabbit_misc:rs(QueueName)]), + [self(), [{Pid, node(Pid)} || Pid <- Deaths], + rabbit_misc:rs(QueueName)]), case rabbit_mirror_queue_misc:remove_from_queue(QueueName, Deaths) of {ok, Pid} when node(Pid) =:= node() -> noreply(State); diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 052078bd..fdf9d9bc 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -143,7 +143,8 @@ handle_call({gm_deaths, Deaths}, From, gm = GM, master_node = MNode }) -> rabbit_log:info("Slave ~p saw deaths ~p for ~s~n", - [self(), Deaths, rabbit_misc:rs(QueueName)]), + [self(), [{Pid, node(Pid)} || Pid <- Deaths], + rabbit_misc:rs(QueueName)]), %% The GM has told us about deaths, which means we're not going to %% receive any more messages from GM case rabbit_mirror_queue_misc:remove_from_queue(QueueName, Deaths) of |