forked from quic-go/quic-go
link to the wiki explaining the UDP receive buffer size
This commit is contained in:
@@ -96,7 +96,7 @@ func newPacketHandlerMap(
|
|||||||
) (packetHandlerManager, error) {
|
) (packetHandlerManager, error) {
|
||||||
if err := setReceiveBuffer(c, logger); err != nil {
|
if err := setReceiveBuffer(c, logger); err != nil {
|
||||||
receiveBufferWarningOnce.Do(func() {
|
receiveBufferWarningOnce.Do(func() {
|
||||||
log.Println(err)
|
log.Printf("%s. See https://github.com/lucas-clemente/quic-go/wiki/UDP-Receive-Buffer-Size for details.", err)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
conn, err := wrapConn(c)
|
conn, err := wrapConn(c)
|
||||||
|
|||||||
@@ -4,10 +4,7 @@ import (
|
|||||||
"bytes"
|
"bytes"
|
||||||
"crypto/rand"
|
"crypto/rand"
|
||||||
"errors"
|
"errors"
|
||||||
"io/ioutil"
|
|
||||||
"log"
|
|
||||||
"net"
|
"net"
|
||||||
"os"
|
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
mocklogging "github.com/lucas-clemente/quic-go/internal/mocks/logging"
|
mocklogging "github.com/lucas-clemente/quic-go/internal/mocks/logging"
|
||||||
@@ -66,7 +63,6 @@ var _ = Describe("Packet Handler Map", func() {
|
|||||||
})
|
})
|
||||||
|
|
||||||
JustBeforeEach(func() {
|
JustBeforeEach(func() {
|
||||||
log.SetOutput(ioutil.Discard)
|
|
||||||
conn = NewMockPacketConn(mockCtrl)
|
conn = NewMockPacketConn(mockCtrl)
|
||||||
conn.EXPECT().LocalAddr().Return(&net.UDPAddr{}).AnyTimes()
|
conn.EXPECT().LocalAddr().Return(&net.UDPAddr{}).AnyTimes()
|
||||||
conn.EXPECT().ReadFrom(gomock.Any()).DoAndReturn(func(b []byte) (int, net.Addr, error) {
|
conn.EXPECT().ReadFrom(gomock.Any()).DoAndReturn(func(b []byte) (int, net.Addr, error) {
|
||||||
@@ -81,8 +77,6 @@ var _ = Describe("Packet Handler Map", func() {
|
|||||||
handler = phm.(*packetHandlerMap)
|
handler = phm.(*packetHandlerMap)
|
||||||
})
|
})
|
||||||
|
|
||||||
AfterEach(func() { log.SetOutput(os.Stdout) })
|
|
||||||
|
|
||||||
It("closes", func() {
|
It("closes", func() {
|
||||||
getMultiplexer() // make the sync.Once execute
|
getMultiplexer() // make the sync.Once execute
|
||||||
// replace the clientMuxer. getClientMultiplexer will now return the MockMultiplexer
|
// replace the clientMuxer. getClientMultiplexer will now return the MockMultiplexer
|
||||||
|
|||||||
@@ -1,6 +1,8 @@
|
|||||||
package quic
|
package quic
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"io/ioutil"
|
||||||
|
"log"
|
||||||
"sync"
|
"sync"
|
||||||
"testing"
|
"testing"
|
||||||
|
|
||||||
@@ -23,6 +25,10 @@ var _ = BeforeEach(func() {
|
|||||||
connMuxerOnce = *new(sync.Once)
|
connMuxerOnce = *new(sync.Once)
|
||||||
})
|
})
|
||||||
|
|
||||||
|
var _ = BeforeSuite(func() {
|
||||||
|
log.SetOutput(ioutil.Discard)
|
||||||
|
})
|
||||||
|
|
||||||
var _ = AfterEach(func() {
|
var _ = AfterEach(func() {
|
||||||
mockCtrl.Finish()
|
mockCtrl.Finish()
|
||||||
})
|
})
|
||||||
|
|||||||
Reference in New Issue
Block a user