forked from quic-go/quic-go
remove some unused functions
This commit is contained in:
@@ -323,10 +323,6 @@ func (s *sendStream) closeForShutdown(err error) {
|
|||||||
s.ctxCancel()
|
s.ctxCancel()
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *sendStream) getWriteOffset() protocol.ByteCount {
|
|
||||||
return s.writeOffset
|
|
||||||
}
|
|
||||||
|
|
||||||
// signalWrite performs a non-blocking send on the writeChan
|
// signalWrite performs a non-blocking send on the writeChan
|
||||||
func (s *sendStream) signalWrite() {
|
func (s *sendStream) signalWrite() {
|
||||||
select {
|
select {
|
||||||
|
|||||||
@@ -62,11 +62,6 @@ func areSessionsRunning() bool {
|
|||||||
return strings.Contains(b.String(), "quic-go.(*session).run")
|
return strings.Contains(b.String(), "quic-go.(*session).run")
|
||||||
}
|
}
|
||||||
|
|
||||||
func insertPacketBuffer(p *receivedPacket) *receivedPacket {
|
|
||||||
p.buffer = getPacketBuffer()
|
|
||||||
return p
|
|
||||||
}
|
|
||||||
|
|
||||||
var _ = Describe("Session", func() {
|
var _ = Describe("Session", func() {
|
||||||
var (
|
var (
|
||||||
sess *session
|
sess *session
|
||||||
|
|||||||
Reference in New Issue
Block a user