Add master_pid to queue_slave_synchronised event; this will reduce the amount of bookkeeping mgmt needs to do and is pretty trivial.

1 files changed, 4 insertions, 2 deletions

diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl
index 02212ef9a5..6db8e7ad77 100644
--- a/src/rabbit_mirror_queue_slave.erl
+++ b/src/rabbit_mirror_queue_slave.erl
@@ -893,8 +893,10 @@ maybe_store_ack(true, MsgId, AckTag, State = #state { msg_id_ack = MA,
 
 %% We intentionally leave out the head where a slave becomes
 %% unsynchronised: we assert that can never happen.
-set_synchronised(true, State = #state { synchronised = false }) ->
-    rabbit_event:notify(queue_slave_synchronised, [{pid, self()}]),
+set_synchronised(true, State = #state { master_pid   = MasterPid,
+                                        synchronised = false }) ->
+    rabbit_event:notify(queue_slave_synchronised, [{master_pid, MasterPid},
+                                                   {pid,        self()}]),
     State #state { synchronised = true };
 set_synchronised(true, State) ->
     State;