blob: 623fb49371735b22ffb01438031f1a00a5a5ee8d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
{-# LANGUAGE ForeignFunctionInterface #-}
{-# LANGUAGE ScopedTypeVariables #-}
module FGConsole where
import Data.Word
import System.Posix.IO
import System.Posix.Types
import Control.Concurrent
-- import GHC.IO.Handle
import Unsafe.Coerce
import Control.Exception as E
-- import Prelude as E
import Control.Monad
import Foreign.C.Error
import Foreign.C
import Logging
import System.Posix.Signals
-- c_monitorTTY fd = trace "c_monitorTTY" (return ()) -- (trace "WTF" todo)
foreign import ccall "monitorTTY" c_monitorTTY :: Fd -> IO ()
foreign import ccall "closeTTY" c_closeTTY :: IO ()
monitorTTY :: (Word8 -> IO ()) -> IO (Fd,ThreadId)
monitorTTY handler = do
(rfd,wfd) <- createPipe
thread <- forkIO $ do
let cleanup = do
trace "quitting monitorTTY thread." (return ())
closeFd wfd `E.catch` \(e::IOException) -> return ()
closeFd rfd `E.catch` \(e::IOException) -> return ()
c_closeTTY
-- rh <- fdToHandle rfd
c_monitorTTY wfd
let monitor =
(do
threadWaitRead rfd
(cs,cnt) <- fdRead rfd 1
forM_ cs (handler . unsafeCoerce {- . trace "read byte" -})
monitor)
`E.catch`
\(e :: IOException) -> do
err <- getErrno
case () of
_ | err==eAGAIN -> monitor
_ | otherwise -> cleanup
`E.catch`
\(e :: AsyncException) -> cleanup
monitor
return (rfd,thread)
unmonitorTTY :: (Fd, ThreadId) -> IO ()
unmonitorTTY (rfd,thread) = do
closeFd rfd
yield
killThread thread
raiseSignal sigUSR1
-- threadDelay 1000000
-- vim:ft=haskell:
|
