git.iko.soy/typeable/wai
on master help sign in
changing the names of APIs (suggested by @alexanderkjeldaas).
commit9be26ff901f4c8020279b343d70db06d5a127322 authorKazu Yamamoto <kazu@iij.ad.jp> dateTue 21 Jul 2015, 11:25 (11 years ago) parent02f7c1f
3 files changed+11−11
compare with master
unifiedsplit
warp/Network/Wai/Handler/Warp/HTTP2.hs+1−1 warp/Network/Wai/Handler/Warp/HTTP2/Manager.hs+9−9 warp/Network/Wai/Handler/Warp/HTTP2/Worker.hs+1−1
warp/Network/Wai/Handler/Warp/HTTP2.hs+1−1
@@ -34,7 +34,7 @@ http2 conn ii addr transport settings readN app = do
3434 action = worker ctx settings tm app responder
3535 setAction mgr action
3636 -- fixme: hard coding: 10
37− replicateM_ 10 $ spawn mgr
37+ replicateM_ 10 $ spawnAction mgr
3838 -- Receiver
3939 let mkreq = mkRequest settings addr
4040 tid <- forkIO $ frameReceiver ctx mkreq readN
warp/Network/Wai/Handler/Warp/HTTP2/Manager.hs+9−9
@@ -1,12 +1,12 @@
11{-# LANGUAGE CPP #-}
22
33module Network.Wai.Handler.Warp.HTTP2.Manager (
4− start
5− , stop
6− , spawn
7− , replace
4+ Manager
5+ , start
86 , setAction
9− , Manager
7+ , stop
8+ , spawnAction
9+ , replaceWithAction
1010 ) where
1111
1212#if __GLASGOW_HASKELL__ < 709
@@ -57,11 +57,11 @@ setAction (Manager _ ref) action = writeIORef ref action
5757stop :: Manager -> IO ()
5858stop (Manager q _) = atomically $ writeTQueue q Stop
5959
60−spawn :: Manager -> IO ()
61−spawn (Manager q _) = atomically $ writeTQueue q Spawn
60+spawnAction :: Manager -> IO ()
61+spawnAction (Manager q _) = atomically $ writeTQueue q Spawn
6262
63−replace :: Manager -> ThreadId -> IO ()
64−replace (Manager q _) tid = atomically $ writeTQueue q $ Replace tid
63+replaceWithAction :: Manager -> ThreadId -> IO ()
64+replaceWithAction (Manager q _) tid = atomically $ writeTQueue q $ Replace tid
6565
6666----------------------------------------------------------------
6767
warp/Network/Wai/Handler/Warp/HTTP2/Worker.hs+1−1
@@ -44,7 +44,7 @@ response Context{outputQ} mgr tconf th strm pri req rsp = do
4444 -- So, this work occupies this thread.
4545 --
4646 -- We need to increase the number of workers.
47− myThreadId >>= replace mgr
47+ myThreadId >>= replaceWithAction mgr
4848 -- After this work, this thread stops to decease
4949 -- the number of workers.
5050 setThreadContinue tconf False