Lines Matching refs:flow
423 // 6.9.1 The Flow Control Window
424 // "If a sender receives a WINDOW_UPDATE that causes a flow control
430 func (http2goAwayFlowError) Error() string { return "connection exceeded flow control window size" }
522 // flow is the flow control window's size.
525 // A flow is kept both on a conn and a per-stream.
528 // conn points to the shared connection-level flow that is
529 // shared by all streams on that conn. It is nil for the flow
554 // add adds n bytes (positive or negative) to the flow control window.
1368 // A WindowUpdateFrame is used to implement flow control.
2458 http2initialWindowSize = 65535 // 6.9.2 Initial Flow Control Window Size
3154 sc.flow.add(http2initialWindowSize)
3214 flow http2flow // conn-wide (not stream-specific) outbound flow control
3215 inflow http2flow // conn-wide inbound flow control
3291 flow http2flow // limits writing from Handler to client
4025 if !st.flow.add(int32(f.Increment)) {
4029 if !sc.flow.add(int32(f.Increment)) {
4139 if !st.flow.add(growth) {
4397 st.flow.conn = &sc.flow
4398 st.flow.add(sc.initialWindowSize)
4660 // and schedules flow control tokens to be sent.
4689 // "The legal range for the increment to the flow control
5387 // transportDefaultConnFlow is how many connection-level flow control
5391 flow
5510 cond *sync.Cond // hold mu; broadcast on flow/closed changes
5511 flow http2flow // our conn-level flow control quota (cs.flow is per stream)
5512 inflow http2flow // peer's conn-level flow control
5545 bufPipe http2pipe // buffered pipe with the flow-controlled response payload
5550 flow http2flow // guarded by cc.mu
5848 cc.flow.add(int32(http2initialWindowSize))
6328 // awaitFlowControl waits for [1, min(maxBytes, cc.cs.maxFrameSize)] flow
6346 if a := cs.flow.available(); a > 0 {
6355 cs.flow.take(take)
6511 cs.flow.add(int32(cc.initialWindowSize))
6512 cs.flow.setConnFlow(&cc.flow)
7086 cs.flow.add(delta)
7119 fl := &cc.flow
7121 fl = &cs.flow
7783 // DataSize returns the number of flow control bytes that must be consumed
7793 // is the number of flow control bytes available on the stream. Consume returns
7797 // If flow control prevents consuming any bytes, this returns (_, _, 0). If
7801 // underlying stream's flow control budget.
7810 allowed := wr.stream.flow.available()
7821 wr.stream.flow.take(allowed)
7845 wr.stream.flow.take(int32(len(wd.p)))
