diff options
| author |  Joey Hess <joey@kitenet.net> | 2012-09-06 14:56:04 -0400 |
|---|---|---|
| committer | Joey Hess <joey@kitenet.net> | 2012-09-06 14:56:04 -0400 |
| commit | a00f1d26bc3f121e49ee3f6ff5f46d7b330161ff (patch) | |
| tree | 1951e9ca7e482fc67f9c232b0fb22680ee19f5a0 /Assistant/Threads/Transferrer.hs | |
| parent | d11ded822cf68d4f33a886e0f97f95a3781e0dc1 (diff) | |
display errors when any named thread crashes
Diffstat (limited to 'Assistant/Threads/Transferrer.hs')
| -rw-r--r-- | Assistant/Threads/Transferrer.hs | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/Assistant/Threads/Transferrer.hs b/Assistant/Threads/Transferrer.hs index a2cf08c1c..3c1c44b9d 100644 --- a/Assistant/Threads/Transferrer.hs +++ b/Assistant/Threads/Transferrer.hs @@ -30,9 +30,10 @@ maxTransfers :: Int maxTransfers = 1 {- Dispatches transfers from the queue. -} -transfererThread :: ThreadState -> DaemonStatusHandle -> TransferQueue -> TransferSlots -> IO () -transfererThread st dstatus transferqueue slots = go =<< readProgramFile +transfererThread :: ThreadState -> DaemonStatusHandle -> TransferQueue -> TransferSlots -> NamedThread +transfererThread st dstatus transferqueue slots = thread $ go =<< readProgramFile where + thread = NamedThread thisThread go program = forever $ inTransferSlot dstatus slots $ maybe (return Nothing) (uncurry $ startTransfer st dstatus program) =<< getNextTransfer transferqueue dstatus notrunning |