equal
deleted
inserted
replaced
18 #if !defined(mingw32_HOST_OS) |
18 #if !defined(mingw32_HOST_OS) |
19 import System.Posix |
19 import System.Posix |
20 #endif |
20 #endif |
21 |
21 |
22 |
22 |
23 {-data Messages = |
|
24 Accept ClientInfo |
|
25 | ClientMessage ([String], ClientInfo) |
|
26 | CoreMessage [String] |
|
27 | TimerTick |
|
28 |
|
29 messagesLoop :: TChan String -> IO() |
|
30 messagesLoop messagesChan = forever $ do |
|
31 threadDelay (25 * 10^6) -- 25 seconds |
|
32 atomically $ writeTChan messagesChan "PING" |
|
33 |
|
34 timerLoop :: TChan String -> IO() |
|
35 timerLoop messagesChan = forever $ do |
|
36 threadDelay (60 * 10^6) -- 60 seconds |
|
37 atomically $ writeTChan messagesChan "MINUTELY"-} |
|
38 |
|
39 setupLoggers = |
23 setupLoggers = |
40 updateGlobalLogger "Clients" |
24 updateGlobalLogger "Clients" |
41 (setLevel DEBUG) |
25 (setLevel DEBUG) |
42 |
26 |
43 main = withSocketsDo $ do |
27 main = withSocketsDo $ do |
53 serverInfo <- getOpts $ newServerInfo stats coreChan dbQueriesChan |
37 serverInfo <- getOpts $ newServerInfo stats coreChan dbQueriesChan |
54 |
38 |
55 bracket |
39 bracket |
56 (Network.listenOn $ Network.PortNumber $ listenPort serverInfo) |
40 (Network.listenOn $ Network.PortNumber $ listenPort serverInfo) |
57 (sClose) |
41 (sClose) |
58 (startServer serverInfo coreChan) |
42 (startServer serverInfo) |