forked from quic-go/quic-go
minor cleanup
This commit is contained in:
@@ -33,12 +33,3 @@ type ReceivedPacketHandler interface {
|
||||
|
||||
GetAckFrame(dequeue bool) (*frames.AckFrame, error)
|
||||
}
|
||||
|
||||
// StopWaitingManager manages StopWaitings for sent packets
|
||||
// TODO: remove once we drop support for QUIC 33
|
||||
type StopWaitingManager interface {
|
||||
RegisterPacketForRetransmission(packet *Packet)
|
||||
GetStopWaitingFrame() *frames.StopWaitingFrame
|
||||
SentStopWaitingWithPacket(packetNumber protocol.PacketNumber)
|
||||
ReceivedAckForPacketNumber(packetNumber protocol.PacketNumber)
|
||||
}
|
||||
|
||||
@@ -98,7 +98,6 @@ ReadLoop:
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
// TODO: Remove once all frames are implemented
|
||||
if frame != nil {
|
||||
fs = append(fs, frame)
|
||||
}
|
||||
|
||||
@@ -52,7 +52,6 @@ type Session struct {
|
||||
|
||||
sentPacketHandler ackhandler.SentPacketHandler
|
||||
receivedPacketHandler ackhandler.ReceivedPacketHandler
|
||||
stopWaitingManager ackhandler.StopWaitingManager
|
||||
streamFramer *streamFramer
|
||||
|
||||
flowControlManager flowcontrol.FlowControlManager
|
||||
@@ -93,7 +92,6 @@ func newSession(conn connection, v protocol.VersionNumber, connectionID protocol
|
||||
connectionParametersManager := handshake.NewConnectionParamatersManager()
|
||||
flowControlManager := flowcontrol.NewFlowControlManager(connectionParametersManager)
|
||||
|
||||
var stopWaitingManager ackhandler.StopWaitingManager
|
||||
var sentPacketHandler ackhandler.SentPacketHandler
|
||||
var receivedPacketHandler ackhandler.ReceivedPacketHandler
|
||||
|
||||
@@ -108,7 +106,6 @@ func newSession(conn connection, v protocol.VersionNumber, connectionID protocol
|
||||
closeCallback: closeCallback,
|
||||
sentPacketHandler: sentPacketHandler,
|
||||
receivedPacketHandler: receivedPacketHandler,
|
||||
stopWaitingManager: stopWaitingManager,
|
||||
flowControlManager: flowControlManager,
|
||||
receivedPackets: make(chan receivedPacket, protocol.MaxSessionUnprocessedPackets),
|
||||
closeChan: make(chan *qerr.QuicError, 1),
|
||||
|
||||
Reference in New Issue
Block a user