git.iko.soy/distributed-process
on master help sign in
Switch completely over to blocking reads
commit50b9eea3a3b26468a8131147bd8e5cc89886df72 authorTim Watson <watson.timothy@gmail.com> dateWed 2 Apr 2014, 13:02 (13 years ago) parent6366fa4
1 file changed+3−3
src/Control/Distributed/Process/Management.hs+3−3
src/Control/Distributed/Process/Management.hs+3−3
@@ -534,8 +534,8 @@ mxAgentWithFinalize mxId initState handlers dtor = do
534534 , matchSTM (readTChan chan) return]
535535 InputChan -> [ matchSTM (readTChan chan) return
536536 , matchAny return]
537− in getNextInput' matches 0
538−
537+ in receiveWait matches
538+{-
539539 getNextInput' ms n = do
540540 mIn <- receiveTimeout n ms
541541 case mIn of
@@ -545,7 +545,7 @@ mxAgentWithFinalize mxId initState handlers dtor = do
545545 tryNextInput ms n
546546 | n > 0 && n < 2000 = getNextInput' ms $ n * 2
547547 | otherwise = getNextInput' ms 100
548−
548+-}
549549 runAgentFinalizer :: MxAgent s () -> MxAgentState s -> Process ()
550550 runAgentFinalizer f s = ST.runStateT (unAgent f) s >>= return . fst
551551