git.iko.soy/distributed-process
on master help sign in
Don't report invalid requests for expected cases.
commit9d88cf501d46967c3d67f2cc7dbb095d9c6518fa authorFacundo Domínguez <facundo.dominguez@tweag.io> dateFri 10 Jun 2016, 09:29 (10 years ago) parent12cdcfc
1 file changed+6−6
src/Control/Distributed/Process/Node.hs+6−6
src/Control/Distributed/Process/Node.hs+6−6
@@ -550,9 +550,9 @@ handleIncomingMessages node = go initConnectionState
550550 Just proc ->
551551 go (incomingAt cid ^= Just (src, ToProc pid (processWeakQ proc)) $ st)
552552 Nothing ->
553− invalidRequest cid st $
554− "incoming attempt to connect to unknown process "
555− ++ show pid
553+ -- incoming attempt to connect to unknown process - might
554+ -- be dead already
555+ go (incomingAt cid ^= Nothing $ st)
556556 SendPortIdentifier chId -> do
557557 let lcid = sendPortLocalId chId
558558 lpid = processLocalId (sendPortProcessId chId)
@@ -568,9 +568,9 @@ handleIncomingMessages node = go initConnectionState
568568 "incoming attempt to connect to unknown channel of"
569569 ++ " process " ++ show (sendPortProcessId chId)
570570 Nothing ->
571− invalidRequest cid st $
572− "incoming attempt to connect to channel of unknown"
573− ++ " process " ++ show (sendPortProcessId chId)
571+ -- incoming attempt to connect to channel of unknown
572+ -- process - might be dead already
573+ go (incomingAt cid ^= Nothing $ st)
574574 NodeIdentifier nid ->
575575 if nid == localNodeId node
576576 then go (incomingAt cid ^= Just (src, ToNode) $ st)