diff options
author | Joey Hess <joey@kitenet.net> | 2012-11-03 14:16:17 -0400 |
---|---|---|
committer | Joey Hess <joey@kitenet.net> | 2012-11-03 14:16:17 -0400 |
commit | 1279d72b4e4fe77abb983954dc937021559d4169 (patch) | |
tree | 6c7d718be97634ddaaa2a9dd90637363cc0ebeb0 /Assistant/NetMessager.hs | |
parent | 85eb13a57a7c0c4f2df46ab4c01c434585370999 (diff) |
refactor XMPP client
Diffstat (limited to 'Assistant/NetMessager.hs')
-rw-r--r-- | Assistant/NetMessager.hs | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/Assistant/NetMessager.hs b/Assistant/NetMessager.hs new file mode 100644 index 000000000..08490e005 --- /dev/null +++ b/Assistant/NetMessager.hs @@ -0,0 +1,28 @@ +{- git-annex assistant out of band network messager interface + - + - Copyright 2012 Joey Hess <joey@kitenet.net> + - + - Licensed under the GNU GPL version 3 or higher. + -} + +module Assistant.NetMessager where + +import Assistant.Common +import Assistant.Types.NetMessager + +import Control.Concurrent.STM +import Control.Concurrent.MSampleVar + +sendNetMessage :: NetMessage -> Assistant () +sendNetMessage m = + (atomically . flip writeTChan m) <<~ (netMessages . netMessagerControl) + +waitNetMessage :: Assistant (NetMessage) +waitNetMessage = (atomically . readTChan) <<~ (netMessages . netMessagerControl) + +notifyNetMessagerRestart :: Assistant () +notifyNetMessagerRestart = + flip writeSV () <<~ (netMessagerRestart . netMessagerControl) + +waitNetMessagerRestart :: Assistant () +waitNetMessagerRestart = readSV <<~ (netMessagerRestart . netMessagerControl) |