diff options
author | stuebinm | 2022-02-17 00:06:22 +0100 |
---|---|---|
committer | stuebinm | 2022-03-19 19:26:32 +0100 |
commit | 252a4a3e1553295ffafbfa5150306f0f31dda8cd (patch) | |
tree | 4a19c8c9d73d070a38d6badf12accdddda062336 /server/Main.hs | |
parent | 07483578e4034838ac7978b8d94d2358e33d6f37 (diff) |
server: remove a thunk leak
(really a lot of these data structures should be eagerly evaluated into
normal form, i suspect there's still a lot to be gained)
Diffstat (limited to 'server/Main.hs')
-rw-r--r-- | server/Main.hs | 28 |
1 files changed, 13 insertions, 15 deletions
diff --git a/server/Main.hs b/server/Main.hs index 1a18c6a..d9c548b 100644 --- a/server/Main.hs +++ b/server/Main.hs @@ -31,9 +31,9 @@ import Network.Wai.Middleware.RequestLogger (OutputFormat (..), RequestLoggerSettings (..), mkRequestLogger) import Servant (Application, Capture, - EmptyAPI, Get, JSON, - PlainText, Post, Raw, - ReqBody, Server, serve, + Get, JSON, PlainText, + Post, Raw, ReqBody, + Server, serve, type (:<|>) (..), type (:>)) import Servant.HTML.Lucid (HTML) @@ -47,10 +47,8 @@ import Server (JobStatus, Org (..), import Worker (Job (Job), linterThread) import Servant.API (Header) -import Servant.Client (BaseUrl (BaseUrl), - ClientM, Scheme (Http), - client, mkClientEnv, - runClientM) +import Servant.Client (ClientM, client, + mkClientEnv, runClientM) type family PolyEndpoint method format payload where PolyEndpoint Get format payload = Get format payload @@ -114,19 +112,19 @@ main = do -- TODO: what about tls / https? manager' <- newManager defaultManagerSettings - updater <- async $ forever $ do - done <- readMVar state - res <- runClientM - (postNewMaps (view token config) (MapService done)) - (mkClientEnv manager' (view exneuland config)) - print res - threadDelay (view interval config * 1000000) + -- updater <- async $ forever $ do + -- done <- readMVar state + -- res <- runClientM + -- (postNewMaps (view token config) (MapService done)) + -- (mkClientEnv manager' (view exneuland config)) + -- print res + -- threadDelay (view interval config * 1000000) -- spawns threads for each job in the queue linter <- async $ void $ linterThread config queue state link linter link poker - link updater + -- link updater let warpsettings = setPort (view port config) |