summaryrefslogtreecommitdiff
path: root/Assistant/ThreadedMonad.hs
diff options
context:
space:
mode:
authorGravatar Joey Hess <joey@kitenet.net>2012-07-18 18:42:41 -0400
committerGravatar Joey Hess <joey@kitenet.net>2012-07-18 18:42:41 -0400
commiteea0a3616cd1cbaf033649c11a5c2b650b6b632f (patch)
tree301720ffb8cef64907d798893ab5f53fc9bc904b /Assistant/ThreadedMonad.hs
parentf520a2c10359257ea6f920d26fe29831db8d07e3 (diff)
add thread id field to transferinfo
Also converted its timestand to posix seconds, like is used in the other log files.
Diffstat (limited to 'Assistant/ThreadedMonad.hs')
-rw-r--r--Assistant/ThreadedMonad.hs10
1 files changed, 4 insertions, 6 deletions
diff --git a/Assistant/ThreadedMonad.hs b/Assistant/ThreadedMonad.hs
index f32adff43..2fc526599 100644
--- a/Assistant/ThreadedMonad.hs
+++ b/Assistant/ThreadedMonad.hs
@@ -12,8 +12,6 @@ import qualified Annex
import Control.Concurrent
import Data.Tuple
-import System.Posix.Types
-import System.Posix.Process
{- The Annex state is stored in a MVar, so that threaded actions can access
- it. -}
@@ -39,14 +37,14 @@ withThreadState a = do
runThreadState :: ThreadState -> Annex a -> IO a
runThreadState mvar a = modifyMVar mvar $ \state -> swap <$> Annex.run state a
-{- Runs an Annex action in a separate process, using a copy of the state
+{- Runs an Annex action in a separate thread, using a copy of the state
- from the MVar.
-
- It's up to the action to perform any necessary shutdown tasks in order
- for state to not be lost. And it's up to the caller to resynchronise
- with any changes the action makes to eg, the git-annex branch.
-}
-unsafeForkProcessThreadState :: ThreadState -> Annex a -> IO ProcessID
-unsafeForkProcessThreadState mvar a = do
+unsafeForkIOThreadState :: ThreadState -> Annex a -> IO ThreadId
+unsafeForkIOThreadState mvar a = do
state <- readMVar mvar
- forkProcess $ void $ Annex.eval state a
+ forkIO $ void $ Annex.eval state a