d71c65ca0a
This is similar to the pusher thread, but a separate thread because git pushes can be done in parallel with exports, and updating a big export should not prevent other git pushes going out in the meantime. The exportThread only runs at most every 30 seconds, since updating an export is more expensive than pushing. This may need to be tuned. Added a separate channel for export commits; the committer records a commit in that channel. Also, reconnectRemotes records a dummy commit, to make the exporter thread wake up and make sure all exports are up-to-date. So, connecting a drive with a directory special remote export will immediately update it, and getting online will automatically update S3 and WebDAV exports. The transfer queue is not involved in exports. Instead, failed exports are retried much like failed pushes. This commit was sponsored by Ewen McNeill.
32 lines
944 B
Haskell
32 lines
944 B
Haskell
{- git-annex assistant commit tracking
|
|
-
|
|
- Copyright 2012 Joey Hess <id@joeyh.name>
|
|
-
|
|
- Licensed under the GNU GPL version 3 or higher.
|
|
-}
|
|
|
|
module Assistant.Commits where
|
|
|
|
import Assistant.Common
|
|
import Assistant.Types.Commits
|
|
import Utility.TList
|
|
|
|
import Control.Concurrent.STM
|
|
|
|
{- Gets all unhandled commits.
|
|
- Blocks until at least one commit is made. -}
|
|
getCommits :: Assistant [Commit]
|
|
getCommits = (atomically . getTList) <<~ commitChan
|
|
|
|
{- Records a commit in the channel. -}
|
|
recordCommit :: Assistant ()
|
|
recordCommit = (atomically . flip consTList Commit) <<~ commitChan
|
|
|
|
{- Gets all unhandled export commits.
|
|
- Blocks until at least one export commit is made. -}
|
|
getExportCommits :: Assistant [Commit]
|
|
getExportCommits = (atomically . getTList) <<~ exportCommitChan
|
|
|
|
{- Records an export commit in the channel. -}
|
|
recordExportCommit :: Assistant ()
|
|
recordExportCommit = (atomically . flip consTList Commit) <<~ exportCommitChan
|