on master help sign in
refactoring.
commit47996f9c29a567c9322c4940a9289b92b90db353 authorKazu Yamamoto <kazu@iij.ad.jp> dateMon 27 Jun 2016, 11:04 (10 years ago) parent3a68341
1 file changed+3−3
warp/Network/Wai/Handler/Warp/HTTP2/Sender.hs+3−3
warp/Network/Wai/Handler/Warp/HTTP2/Sender.hs+3−3
@@ -92,7 +92,7 @@ frameSender ctx@Context{outputQ,controlQ,connectionWindow,encodeDynamicTable}
9292 O (_,pre,out) -> do
9393 let strm = outputStream out
9494 writeIORef (streamPrecedence strm) pre
95− off' <- whenReadyOrEnqueueAgain out off $ output out off
95+ off' <- outputOrEnqueueAgain out off
9696 case off' of
9797 0 -> loop 0
9898 _ | off' > 15872 -> flushN off' >> loop 0 -- fixme: hard-coding
@@ -164,7 +164,7 @@ frameSender ctx@Context{outputQ,controlQ,connectionWindow,encodeDynamicTable}
164164 maybeEnqueueNext strm (Just tbq) mnext
165165 return off'
166166
167− whenReadyOrEnqueueAgain out off body = E.handle resetStream $ do
167+ outputOrEnqueueAgain out off = E.handle resetStream $ do
168168 state <- readIORef $ streamState strm
169169 if isClosed state then
170170 return off
@@ -189,7 +189,7 @@ frameSender ctx@Context{outputQ,controlQ,connectionWindow,encodeDynamicTable}
189189 else do
190190 cws <- atomically $ readTVar connectionWindow -- not 0
191191 let !lim = min cws sws
192− body lim
192+ output out off lim
193193 resetStream e = do
194194 closed ctx strm (ResetByMe e)
195195 let !rst = resetFrame InternalError $ streamNumber strm