git.iko.soy/distributed-process
on master help sign in
Don't report invalid requests for expected cases.
a056ea7Facundo Domínguez
src/Control/Distributed/Process/Node.hs+6−6
@@ -558,9 +558,9 @@ handleIncomingMessages node = go initConnectionState
558 Just proc ->
558 Just proc ->
559 go (incomingAt cid ^= Just (src, ToProc pid (processWeakQ proc)) $ st)
559 go (incomingAt cid ^= Just (src, ToProc pid (processWeakQ proc)) $ st)
560 Nothing ->
560 Nothing ->
561− invalidRequest cid st $
562− "incoming attempt to connect to unknown process "
561+ -- incoming attempt to connect to unknown process - might
563− ++ show pid
562+ -- be dead already
563+ go (incomingAt cid ^= Nothing $ st)
564 SendPortIdentifier chId -> do
564 SendPortIdentifier chId -> do
565 let lcid = sendPortLocalId chId
565 let lcid = sendPortLocalId chId
566 lpid = processLocalId (sendPortProcessId chId)
566 lpid = processLocalId (sendPortProcessId chId)
@@ -576,9 +576,9 @@ handleIncomingMessages node = go initConnectionState
576 "incoming attempt to connect to unknown channel of"
576 "incoming attempt to connect to unknown channel of"
577 ++ " process " ++ show (sendPortProcessId chId)
577 ++ " process " ++ show (sendPortProcessId chId)
578 Nothing ->
578 Nothing ->
579− invalidRequest cid st $
580− "incoming attempt to connect to channel of unknown"
579+ -- incoming attempt to connect to channel of unknown
581− ++ " process " ++ show (sendPortProcessId chId)
580+ -- process - might be dead already
581+ go (incomingAt cid ^= Nothing $ st)
582 NodeIdentifier nid ->
582 NodeIdentifier nid ->
583 if nid == localNodeId node
583 if nid == localNodeId node
584 then go (incomingAt cid ^= Just (src, ToNode) $ st)
584 then go (incomingAt cid ^= Just (src, ToNode) $ st)