File tree Expand file tree Collapse file tree 1 file changed +6
-6
lines changed
src/Control/Distributed/Process Expand file tree Collapse file tree 1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -558,9 +558,9 @@ handleIncomingMessages node = go initConnectionState
558
558
Just proc ->
559
559
go (incomingAt cid ^= Just (src, ToProc pid (processWeakQ proc )) $ st)
560
560
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)
564
564
SendPortIdentifier chId -> do
565
565
let lcid = sendPortLocalId chId
566
566
lpid = processLocalId (sendPortProcessId chId)
@@ -576,9 +576,9 @@ handleIncomingMessages node = go initConnectionState
576
576
" incoming attempt to connect to unknown channel of"
577
577
++ " process " ++ show (sendPortProcessId chId)
578
578
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 )
582
582
NodeIdentifier nid ->
583
583
if nid == localNodeId node
584
584
then go (incomingAt cid ^= Just (src, ToNode ) $ st)
You can’t perform that action at this time.
0 commit comments