git.iko.soy/distributed-process
on master help sign in
Don't report invalid requests for expected cases.
9d88cf5Facundo Domínguez
src/Control/Distributed/Process/Node.hs+6−6
@@ -550,9 +550,9 @@ handleIncomingMessages node = go initConnectionState
550 Just proc ->
550 Just proc ->
551 go (incomingAt cid ^= Just (src, ToProc pid (processWeakQ proc)) $ st)
551 go (incomingAt cid ^= Just (src, ToProc pid (processWeakQ proc)) $ st)
552 Nothing ->
552 Nothing ->
553− invalidRequest cid st $
554− "incoming attempt to connect to unknown process "
553+ -- incoming attempt to connect to unknown process - might
555− ++ show pid
554+ -- be dead already
555+ go (incomingAt cid ^= Nothing $ st)
556 SendPortIdentifier chId -> do
556 SendPortIdentifier chId -> do
557 let lcid = sendPortLocalId chId
557 let lcid = sendPortLocalId chId
558 lpid = processLocalId (sendPortProcessId chId)
558 lpid = processLocalId (sendPortProcessId chId)
@@ -568,9 +568,9 @@ handleIncomingMessages node = go initConnectionState
568 "incoming attempt to connect to unknown channel of"
568 "incoming attempt to connect to unknown channel of"
569 ++ " process " ++ show (sendPortProcessId chId)
569 ++ " process " ++ show (sendPortProcessId chId)
570 Nothing ->
570 Nothing ->
571− invalidRequest cid st $
572− "incoming attempt to connect to channel of unknown"
571+ -- incoming attempt to connect to channel of unknown
573− ++ " process " ++ show (sendPortProcessId chId)
572+ -- process - might be dead already
573+ go (incomingAt cid ^= Nothing $ st)
574 NodeIdentifier nid ->
574 NodeIdentifier nid ->
575 if nid == localNodeId node
575 if nid == localNodeId node
576 then go (incomingAt cid ^= Just (src, ToNode) $ st)
576 then go (incomingAt cid ^= Just (src, ToNode) $ st)