transient 0.1.0.9 → 0.1.1

raw patch · 3 files changed

+8/−4 lines, 3 filesdep ~HTTPdep ~SHAdep ~TCache

Dependency ranges changed: HTTP, SHA, TCache, base, bytestring, containers, directory, filepath, mtl, network, network-info, process, random, stm, time, transformers

Files

• src/Transient/Base.hs +1/−1
• src/Transient/Move.hs +6/−2
• transient.cabal +1/−1

@@ -499,7 +499,7 @@         liftIO $ loop cont ioaction
         return Nothing
 
--- executes the an IO action and then the continuation included in the first parameter
+-- executes the IO action and then the continuation included in the first parameter
 loop :: EventF -> IO (StreamData t) -> IO ()
 loop (cont'@(EventF e x fs a b c d peers childs g))  rec  =  do
   chs <- liftIO $ newTVarIO []

@@ -102,9 +102,10 @@       if rec
          then
           runTrans $ do
-            rnum <- liftIO $ newMVar (0 :: Int)
+--            rnum <- liftIO $ newMVar (0 :: Int)
             Connection _(Just (ConnectionData _ h sock blocked )) _ _ <- getSData  <|> error "callTo: no hander"
-            r <- remoteProc                       !> "executing remoteProc" !> "CALLTO REMOTE" -- LOg="++ show fulLog
+
+            r <- remoteProc         !> "executing remoteProc" !> "CALLTO REMOTE" -- LOg="++ show fulLog
             n <- liftIO $ do
 --                modifyMVar_ rnum $ \n -> return (n+1)
                 withMVar blocked $ const $ hPutStrLn   h (show r)  `catch` (\(e::SomeException) -> sClose sock)
@@ -113,6 +114,9 @@ 
  --           adjustSenderThreads n
 
+            setSData WasRemote
+            stop
+          <|> do
             setSData WasRemote
             stop
 

@@ -1,5 +1,5 @@ name: transient
-version: 0.1.0.9
+version: 0.1.1
 cabal-version: >=1.10
 build-type: Simple
 license: GPL-3