Skip to content

Commit 629a6fa

Browse files
committed
Fix MX notification of re-registration events
1 parent e0092ac commit 629a6fa

File tree

1 file changed

+5
-1
lines changed
  • src/Control/Distributed/Process

1 file changed

+5
-1
lines changed

src/Control/Distributed/Process/Node.hs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -955,7 +955,11 @@ ncEffectRegister from label atnode mPid reregistration = do
955955
do modify' $ registeredHereFor label ^= mPid
956956
updateRemote node currentVal mPid
957957
case mPid of
958-
(Just p) -> liftIO $ trace node (MxRegistered p label)
958+
(Just p) -> do
959+
if reregistration
960+
then liftIO $ trace node (MxUnRegistered (fromJust currentVal) label)
961+
else return ()
962+
liftIO $ trace node (MxRegistered p label)
959963
Nothing -> liftIO $ trace node (MxUnRegistered (fromJust currentVal) label)
960964
newVal <- gets (^. registeredHereFor label)
961965
ncSendToProcess from $ unsafeCreateUnencodedMessage $

0 commit comments

Comments
 (0)