Skip to content

Commit a056ea7

Browse files
Don't report invalid requests for expected cases.
1 parent 633baf7 commit a056ea7

File tree

1 file changed

+6
-6
lines changed
  • src/Control/Distributed/Process

1 file changed

+6
-6
lines changed

src/Control/Distributed/Process/Node.hs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -558,9 +558,9 @@ handleIncomingMessages node = go initConnectionState
558558
Just proc ->
559559
go (incomingAt cid ^= Just (src, ToProc pid (processWeakQ proc)) $ st)
560560
Nothing ->
561-
invalidRequest cid st $
562-
"incoming attempt to connect to unknown process "
563-
++ show pid
561+
-- incoming attempt to connect to unknown process - might
562+
-- be dead already
563+
go (incomingAt cid ^= Nothing $ st)
564564
SendPortIdentifier chId -> do
565565
let lcid = sendPortLocalId chId
566566
lpid = processLocalId (sendPortProcessId chId)
@@ -576,9 +576,9 @@ handleIncomingMessages node = go initConnectionState
576576
"incoming attempt to connect to unknown channel of"
577577
++ " process " ++ show (sendPortProcessId chId)
578578
Nothing ->
579-
invalidRequest cid st $
580-
"incoming attempt to connect to channel of unknown"
581-
++ " process " ++ show (sendPortProcessId chId)
579+
-- incoming attempt to connect to channel of unknown
580+
-- process - might be dead already
581+
go (incomingAt cid ^= Nothing $ st)
582582
NodeIdentifier nid ->
583583
if nid == localNodeId node
584584
then go (incomingAt cid ^= Just (src, ToNode) $ st)

0 commit comments

Comments
 (0)