mirror of
https://github.com/caddyserver/caddy.git
synced 2025-01-13 22:51:08 -05:00
dfbc2e81e3
quic-go now vendors all of its dependencies, so we don't need to vendor them here. Created by running: gvt delete github.com/lucas-clemente/quic-go gvt delete github.com/bifurcation/mint gvt delete github.com/lucas-clemente/aes12 gvt delete github.com/lucas-clemente/fnv128a gvt delete github.com/lucas-clemente/quic-go-certificates gvt delete github.com/aead/chacha20 gvt delete github.com/hashicorp/golang-lru gvt fetch -tag v0.10.0-no-integrationtests github.com/lucas-clemente/quic-go
38 lines
1.3 KiB
Go
38 lines
1.3 KiB
Go
package flowcontrol
|
|
|
|
import "github.com/lucas-clemente/quic-go/internal/protocol"
|
|
|
|
type flowController interface {
|
|
// for sending
|
|
SendWindowSize() protocol.ByteCount
|
|
UpdateSendWindow(protocol.ByteCount)
|
|
AddBytesSent(protocol.ByteCount)
|
|
// for receiving
|
|
AddBytesRead(protocol.ByteCount)
|
|
GetWindowUpdate() protocol.ByteCount // returns 0 if no update is necessary
|
|
MaybeQueueWindowUpdate() // queues a window update, if necessary
|
|
IsNewlyBlocked() (bool, protocol.ByteCount)
|
|
}
|
|
|
|
// A StreamFlowController is a flow controller for a QUIC stream.
|
|
type StreamFlowController interface {
|
|
flowController
|
|
// for receiving
|
|
// UpdateHighestReceived should be called when a new highest offset is received
|
|
// final has to be to true if this is the final offset of the stream, as contained in a STREAM frame with FIN bit, and the RST_STREAM frame
|
|
UpdateHighestReceived(offset protocol.ByteCount, final bool) error
|
|
}
|
|
|
|
// The ConnectionFlowController is the flow controller for the connection.
|
|
type ConnectionFlowController interface {
|
|
flowController
|
|
}
|
|
|
|
type connectionFlowControllerI interface {
|
|
ConnectionFlowController
|
|
// The following two methods are not supposed to be called from outside this packet, but are needed internally
|
|
// for sending
|
|
EnsureMinimumWindowSize(protocol.ByteCount)
|
|
// for receiving
|
|
IncrementHighestReceived(protocol.ByteCount) error
|
|
}
|