Skip to content

Commit a53d9e5

Browse files
committed
Revert "TUN-10557: Bump quic-go v0.59.1"
This reverts commit 02eb75b.
1 parent 9171757 commit a53d9e5

367 files changed

Lines changed: 76549 additions & 8708 deletions

File tree

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

‎carrier/websocket_test.go‎

Lines changed: 15 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ package carrier
22

33
import (
44
"context"
5-
"crypto/rand"
5+
crand "crypto/rand"
66
"crypto/tls"
77
"crypto/x509"
88
"errors"
@@ -35,6 +35,15 @@ func websocketClientTLSConfig(t *testing.T) *tls.Config {
3535
return &tls.Config{RootCAs: certPool}
3636
}
3737

38+
func TestWebsocketHeaders(t *testing.T) {
39+
req := testRequest(t, "http://example.com", nil)
40+
wsHeaders := websocketHeaders(req)
41+
for _, header := range stripWebsocketHeaders {
42+
assert.Empty(t, wsHeaders[header])
43+
}
44+
assert.Equal(t, "curl/7.59.0", wsHeaders.Get("User-Agent"))
45+
}
46+
3847
func TestServe(t *testing.T) {
3948
log := zerolog.Nop()
4049
shutdownC := make(chan struct{})
@@ -57,16 +66,12 @@ func TestServe(t *testing.T) {
5766
defer func() { _ = resp.Body.Close() }()
5867
assert.Equal(t, "websocket", resp.Header.Get("Upgrade"))
5968

60-
for range 1000 {
61-
messageSize, err := rand.Int(rand.Reader, big.NewInt(2048))
69+
for i := 0; i < 1000; i++ {
70+
messageSize, err := crand.Int(crand.Reader, big.NewInt(2048))
71+
require.NoError(t, err)
72+
clientMessage := make([]byte, int(messageSize.Int64())+1)
73+
_, err = crand.Read(clientMessage)
6274
require.NoError(t, err)
63-
clientMessage := make([]byte, messageSize.Int64()+1)
64-
for i := range clientMessage {
65-
n, err := rand.Int(rand.Reader, big.NewInt(256))
66-
n8 := uint8(n.Uint64()) //nolint:gosec // test-only
67-
require.NoError(t, err)
68-
clientMessage[i] = n8
69-
}
7075
err = conn.WriteMessage(websocket.BinaryFrame, clientMessage)
7176
require.NoError(t, err)
7277

‎connection/quic_connection.go‎

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -143,7 +143,7 @@ func (q *quicConnection) Serve(ctx context.Context) error {
143143
}
144144

145145
// serveControlStream will serve the RPC; blocking until the control plane is done.
146-
func (q *quicConnection) serveControlStream(ctx context.Context, controlStream *quic.Stream) error {
146+
func (q *quicConnection) serveControlStream(ctx context.Context, controlStream quic.Stream) error {
147147
return q.controlStreamHandler.ServeControlStream(ctx, controlStream, q.connOptions.ConnectionOptions(), q.orchestrator)
148148
}
149149

@@ -166,7 +166,7 @@ func (q *quicConnection) acceptStream(ctx context.Context) error {
166166
}
167167
}
168168

169-
func (q *quicConnection) runStream(quicStream *quic.Stream) {
169+
func (q *quicConnection) runStream(quicStream quic.Stream) {
170170
ctx := quicStream.Context()
171171
stream := cfdquic.NewSafeStreamCloser(quicStream, q.streamWriteTimeout, q.logger)
172172
defer func() { _ = stream.Close() }()

‎connection/quic_connection_test.go‎

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -530,7 +530,7 @@ func TestServeUDPSession(t *testing.T) {
530530
ctx, cancel := context.WithCancel(t.Context())
531531

532532
// Establish QUIC connection with edge
533-
edgeQUICSessionChan := make(chan *quic.Conn)
533+
edgeQUICSessionChan := make(chan quic.Connection)
534534
go func() {
535535
earlyListener, err := quic.Listen(udpListener, testTLSServerConfig, testQUICConfig)
536536
assert.NoError(t, err)
@@ -779,7 +779,7 @@ func TestDialQuicWithSkipPortReuse(t *testing.T) {
779779
<-serverDone
780780
}
781781

782-
func serveSession(ctx context.Context, datagramConn *datagramV2Connection, edgeQUICSession cfdquic.QUICConnection, closeType closeReason, expectedReason string, t *testing.T) {
782+
func serveSession(ctx context.Context, datagramConn *datagramV2Connection, edgeQUICSession quic.Connection, closeType closeReason, expectedReason string, t *testing.T) {
783783
payload := []byte(t.Name())
784784
sessionID := uuid.New()
785785
cfdConn, originConn := net.Pipe()
@@ -843,7 +843,7 @@ const (
843843
closedByTimeout
844844
)
845845

846-
func runRPCServer(ctx context.Context, session cfdquic.QUICConnection, sessionRPCServer pogs.SessionManager, configRPCServer pogs.ConfigurationManager, t *testing.T) {
846+
func runRPCServer(ctx context.Context, session quic.Connection, sessionRPCServer pogs.SessionManager, configRPCServer pogs.ConfigurationManager, t *testing.T) {
847847
stream, err := session.AcceptStream(ctx)
848848
require.NoError(t, err)
849849

‎connection/quic_datagram_v2.go‎

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ import (
88
"time"
99

1010
"github.com/google/uuid"
11-
"github.com/pkg/errors"
11+
pkgerrors "github.com/pkg/errors"
1212
"github.com/rs/zerolog"
1313
"go.opentelemetry.io/otel/attribute"
1414
"go.opentelemetry.io/otel/trace"
@@ -22,7 +22,7 @@ import (
2222
"github.com/cloudflare/cloudflared/packet"
2323
cfdquic "github.com/cloudflare/cloudflared/quic"
2424
"github.com/cloudflare/cloudflared/tracing"
25-
"github.com/cloudflare/cloudflared/tunnelrpc/pogs"
25+
tunnelpogs "github.com/cloudflare/cloudflared/tunnelrpc/pogs"
2626
rpcquic "github.com/cloudflare/cloudflared/tunnelrpc/quic"
2727
)
2828

@@ -31,14 +31,14 @@ const (
3131
demuxChanCapacity = 16
3232
)
3333

34-
var errInvalidDestinationIP = errors.New("unable to parse destination IP")
34+
var errInvalidDestinationIP = pkgerrors.New("unable to parse destination IP")
3535

3636
// DatagramSessionHandler is a service that can serve datagrams for a connection and handle sessions from incoming
3737
// connection streams.
3838
type DatagramSessionHandler interface {
3939
Serve(context.Context) error
4040

41-
pogs.SessionManager
41+
tunnelpogs.SessionManager
4242
}
4343

4444
type datagramV2Connection struct {
@@ -111,7 +111,7 @@ func (d *datagramV2Connection) Serve(ctx context.Context) error {
111111
}
112112

113113
// RegisterUdpSession is the RPC method invoked by edge to register and run a session
114-
func (q *datagramV2Connection) RegisterUdpSession(ctx context.Context, sessionID uuid.UUID, dstIP net.IP, dstPort uint16, closeAfterIdleHint time.Duration, traceContext string) (*pogs.RegisterUdpSessionResponse, error) {
114+
func (q *datagramV2Connection) RegisterUdpSession(ctx context.Context, sessionID uuid.UUID, dstIP net.IP, dstPort uint16, closeAfterIdleHint time.Duration, traceContext string) (*tunnelpogs.RegisterUdpSessionResponse, error) {
115115
traceCtx := tracing.NewTracedContext(ctx, traceContext, q.logger)
116116
ctx, registerSpan := traceCtx.Tracer().Start(traceCtx, "register-session", trace.WithAttributes(
117117
attribute.String("session-id", sessionID.String()),
@@ -123,7 +123,7 @@ func (q *datagramV2Connection) RegisterUdpSession(ctx context.Context, sessionID
123123
if err := q.flowLimiter.Acquire(management.UDP.String()); err != nil {
124124
log.Warn().Msgf("Too many concurrent sessions being handled, rejecting udp proxy to %s:%d", dstIP, dstPort)
125125

126-
err := errors.Wrap(err, "failed to start udp session due to rate limiting")
126+
err := pkgerrors.Wrap(err, "failed to start udp session due to rate limiting")
127127
tracing.EndWithErrorStatus(registerSpan, err)
128128
return nil, err
129129
}
@@ -180,7 +180,7 @@ func (q *datagramV2Connection) RegisterUdpSession(ctx context.Context, sessionID
180180
Msgf("Registered session")
181181
tracing.End(registerSpan)
182182

183-
resp := pogs.RegisterUdpSessionResponse{
183+
resp := tunnelpogs.RegisterUdpSessionResponse{
184184
Spans: traceCtx.GetProtoSpans(),
185185
}
186186

‎connection/quic_datagram_v2_test.go‎

Lines changed: 62 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,13 @@
11
package connection
22

33
import (
4+
"context"
45
"net"
56
"testing"
67
"time"
78

89
"github.com/google/uuid"
10+
"github.com/quic-go/quic-go"
911
"github.com/rs/zerolog"
1012
"github.com/stretchr/testify/require"
1113
"go.uber.org/mock/gomock"
@@ -14,15 +16,73 @@ import (
1416
"github.com/cloudflare/cloudflared/mocks"
1517
)
1618

19+
type mockQuicConnection struct{}
20+
21+
func (m *mockQuicConnection) AcceptStream(_ context.Context) (quic.Stream, error) {
22+
return nil, nil
23+
}
24+
25+
func (m *mockQuicConnection) AcceptUniStream(_ context.Context) (quic.ReceiveStream, error) {
26+
return nil, nil
27+
}
28+
29+
func (m *mockQuicConnection) OpenStream() (quic.Stream, error) {
30+
return nil, nil
31+
}
32+
33+
func (m *mockQuicConnection) OpenStreamSync(_ context.Context) (quic.Stream, error) {
34+
return nil, nil
35+
}
36+
37+
func (m *mockQuicConnection) OpenUniStream() (quic.SendStream, error) {
38+
return nil, nil
39+
}
40+
41+
func (m *mockQuicConnection) OpenUniStreamSync(_ context.Context) (quic.SendStream, error) {
42+
return nil, nil
43+
}
44+
45+
func (m *mockQuicConnection) LocalAddr() net.Addr {
46+
return nil
47+
}
48+
49+
func (m *mockQuicConnection) RemoteAddr() net.Addr {
50+
return nil
51+
}
52+
53+
func (m *mockQuicConnection) CloseWithError(_ quic.ApplicationErrorCode, s string) error {
54+
return nil
55+
}
56+
57+
func (m *mockQuicConnection) Context() context.Context {
58+
return nil
59+
}
60+
61+
func (m *mockQuicConnection) ConnectionState() quic.ConnectionState {
62+
panic("not meant to be called")
63+
}
64+
65+
func (m *mockQuicConnection) SendDatagram(_ []byte) error {
66+
return nil
67+
}
68+
69+
func (m *mockQuicConnection) ReceiveDatagram(_ context.Context) ([]byte, error) {
70+
return nil, nil
71+
}
72+
73+
func (m *mockQuicConnection) AddPath(*quic.Transport) (*quic.Path, error) {
74+
return nil, nil
75+
}
76+
1777
func TestRateLimitOnNewDatagramV2UDPSession(t *testing.T) {
1878
log := zerolog.Nop()
79+
conn := &mockQuicConnection{}
1980
ctrl := gomock.NewController(t)
2081
flowLimiterMock := mocks.NewMockLimiter(ctrl)
21-
connMock := mocks.NewMockQUICConnection(ctrl)
2282

2383
datagramConn := NewDatagramV2Connection(
2484
t.Context(),
25-
connMock,
85+
conn,
2686
nil,
2787
nil,
2888
0,

‎connection/quic_datagram_v3.go‎

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ import (
1212
"github.com/cloudflare/cloudflared/ingress"
1313
"github.com/cloudflare/cloudflared/management"
1414
cfdquic "github.com/cloudflare/cloudflared/quic"
15-
v3 "github.com/cloudflare/cloudflared/quic/v3"
15+
cfdquicv3 "github.com/cloudflare/cloudflared/quic/v3"
1616
"github.com/cloudflare/cloudflared/tunnelrpc/pogs"
1717
)
1818

@@ -25,25 +25,25 @@ type datagramV3Connection struct {
2525
conn cfdquic.QUICConnection
2626
index uint8
2727
// datagramMuxer mux/demux datagrams from quic connection
28-
datagramMuxer v3.DatagramConn
29-
metrics v3.Metrics
28+
datagramMuxer cfdquicv3.DatagramConn
29+
metrics cfdquicv3.Metrics
3030
logger *zerolog.Logger
3131
}
3232

3333
func NewDatagramV3Connection(ctx context.Context,
3434
conn cfdquic.QUICConnection,
35-
sessionManager v3.SessionManager,
35+
sessionManager cfdquicv3.SessionManager,
3636
icmpRouter ingress.ICMPRouter,
3737
index uint8,
38-
metrics v3.Metrics,
38+
metrics cfdquicv3.Metrics,
3939
logger *zerolog.Logger,
4040
) DatagramSessionHandler {
4141
log := logger.
4242
With().
4343
Int(management.EventTypeKey, int(management.UDP)).
4444
Uint8(LogFieldConnIndex, index).
4545
Logger()
46-
datagramMuxer := v3.NewDatagramConn(conn, sessionManager, icmpRouter, index, metrics, &log)
46+
datagramMuxer := cfdquicv3.NewDatagramConn(conn, sessionManager, icmpRouter, index, metrics, &log)
4747

4848
return &datagramV3Connection{
4949
conn,

‎go.mod‎

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@ require (
2323
github.com/pkg/errors v0.9.1
2424
github.com/prometheus/client_golang v1.22.0
2525
github.com/prometheus/client_model v0.6.2
26-
github.com/quic-go/quic-go v0.59.1
26+
github.com/quic-go/quic-go v0.52.0
2727
github.com/rs/zerolog v1.20.0
2828
github.com/shirou/gopsutil/v4 v4.26.3
2929
github.com/stretchr/testify v1.11.1
@@ -35,7 +35,7 @@ require (
3535
go.opentelemetry.io/otel/trace v1.43.0
3636
go.opentelemetry.io/proto/otlp v1.10.0
3737
go.uber.org/automaxprocs v1.6.0
38-
go.uber.org/mock v0.5.2
38+
go.uber.org/mock v0.5.1
3939
golang.org/x/crypto v0.52.0
4040
golang.org/x/net v0.55.0
4141
golang.org/x/sync v0.20.0
@@ -65,8 +65,10 @@ require (
6565
github.com/go-logr/stdr v1.2.2 // indirect
6666
github.com/go-ole/go-ole v1.2.6 // indirect
6767
github.com/go-playground/validator/v10 v10.15.1 // indirect
68+
github.com/go-task/slim-sprig/v3 v3.0.0 // indirect
6869
github.com/gobwas/httphead v0.1.0 // indirect
6970
github.com/gobwas/pool v0.2.1 // indirect
71+
github.com/google/pprof v0.0.0-20250418163039-24c5476c6587 // indirect
7072
github.com/grpc-ecosystem/grpc-gateway/v2 v2.28.0 // indirect
7173
github.com/klauspost/compress v1.18.0 // indirect
7274
github.com/klauspost/cpuid/v2 v2.2.5 // indirect
@@ -75,6 +77,7 @@ require (
7577
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
7678
github.com/modern-go/reflect2 v1.0.2 // indirect
7779
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
80+
github.com/onsi/ginkgo/v2 v2.23.4 // indirect
7881
github.com/pelletier/go-toml/v2 v2.0.9 // indirect
7982
github.com/pmezard/go-difflib v1.0.1-0.20181226105442-5d4384ee4fb2 // indirect
8083
github.com/power-devops/perfstat v0.0.0-20240221224432-82ca36839d55 // indirect
@@ -105,4 +108,5 @@ replace github.com/prometheus/golang_client => github.com/prometheus/golang_clie
105108

106109
replace gopkg.in/yaml.v3 => gopkg.in/yaml.v3 v3.0.1
107110

108-
replace github.com/quic-go/quic-go => github.com/chungthuang/quic-go v0.45.1-0.20260529212404-a9fddf436fc4 // This fork is based on quic-go v0.59.1
111+
// This fork is based on quic-go v0.45
112+
replace github.com/quic-go/quic-go => github.com/chungthuang/quic-go v0.45.1-0.20250428085412-43229ad201fd

‎go.sum‎

Lines changed: 12 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,8 +9,8 @@ github.com/bytedance/sonic/loader v0.2.0 h1:zNprn+lsIP06C/IqCHs3gPQIvnvpKbbxyXQP
99
github.com/bytedance/sonic/loader v0.2.0/go.mod h1:ncP89zfokxS5LZrJxl5z0UJcsk4M4yY2JpfqGeCtNLU=
1010
github.com/cespare/xxhash/v2 v2.3.0 h1:UL815xU9SqsFlibzuggzjXhog7bL6oX9BbNZnL2UFvs=
1111
github.com/cespare/xxhash/v2 v2.3.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=
12-
github.com/chungthuang/quic-go v0.45.1-0.20260529212404-a9fddf436fc4 h1:ZaFGQi6lUEnMyl0DvRy2mEp9u7FP+FrUBr7q+c4U68o=
13-
github.com/chungthuang/quic-go v0.45.1-0.20260529212404-a9fddf436fc4/go.mod h1:upnsH4Ju1YkqpLXC305eW3yDZ4NfnNbmQRCMWS58IKU=
12+
github.com/chungthuang/quic-go v0.45.1-0.20250428085412-43229ad201fd h1:VdYI5zFQ2h1/qzoC6rhyPx479bkF8i177Qpg4Q2n1vk=
13+
github.com/chungthuang/quic-go v0.45.1-0.20250428085412-43229ad201fd/go.mod h1:MFlGGpcpJqRAfmYi6NC2cptDPSxRWTOGNuP4wqrWmzQ=
1414
github.com/cloudflare/backoff v0.0.0-20240920015135-e46b80a3a7d0 h1:pRcxfaAlK0vR6nOeQs7eAEvjJzdGXl8+KaBlcvpQTyQ=
1515
github.com/cloudflare/backoff v0.0.0-20240920015135-e46b80a3a7d0/go.mod h1:rzgs2ZOiguV6/NpiDgADjRLPNyZlApIWxKpkT+X8SdY=
1616
github.com/cloudwego/base64x v0.1.4 h1:jwCgWpFanWmN8xoIUHa2rtzmkd5J2plF/dnLS6Xd/0Y=
@@ -79,6 +79,8 @@ github.com/go-playground/universal-translator v0.18.1/go.mod h1:xekY+UJKNuX9WP91
7979
github.com/go-playground/validator/v10 v10.2.0/go.mod h1:uOYAAleCW8F/7oMFd6aG0GOhaH6EGOAJShg8Id5JGkI=
8080
github.com/go-playground/validator/v10 v10.15.1 h1:BSe8uhN+xQ4r5guV/ywQI4gO59C2raYcGffYWZEjZzM=
8181
github.com/go-playground/validator/v10 v10.15.1/go.mod h1:9iXMNT7sEkjXb0I+enO7QXmzG6QCsPWY4zveKFVRSyU=
82+
github.com/go-task/slim-sprig/v3 v3.0.0 h1:sUs3vkvUymDpBKi3qH1YSqBQk9+9D/8M2mN1vB6EwHI=
83+
github.com/go-task/slim-sprig/v3 v3.0.0/go.mod h1:W848ghGpv3Qj3dhTPRyJypKRiqCdHZiAzKg9hl15HA8=
8284
github.com/gobwas/httphead v0.0.0-20180130184737-2c6c146eadee/go.mod h1:L0fX3K22YWvt/FAX9NnzrNzcI4wNYi9Yku4O0LKYflo=
8385
github.com/gobwas/httphead v0.1.0 h1:exrUm0f4YX0L7EBwZHuCF4GDp8aJfVeBrlLQrs6NqWU=
8486
github.com/gobwas/httphead v0.1.0/go.mod h1:O/RXo79gxV8G+RqlR/otEwx4Q36zl9rqC5u12GKvMCM=
@@ -102,6 +104,8 @@ github.com/google/go-cmp v0.7.0/go.mod h1:pXiqmnSA92OHEEa9HXL2W4E7lf9JzCmGVUdgjX
102104
github.com/google/gofuzz v1.0.0/go.mod h1:dBl0BpW6vV/+mYPU4Po3pmUjxk6FQPldtuIdl/M65Eg=
103105
github.com/google/gopacket v1.1.19 h1:ves8RnFZPGiFnTS0uPQStjwru6uO6h+nlr9j6fL7kF8=
104106
github.com/google/gopacket v1.1.19/go.mod h1:iJ8V8n6KS+z2U1A8pUwu8bW5SyEMkXJB8Yo/Vo+TKTo=
107+
github.com/google/pprof v0.0.0-20250418163039-24c5476c6587 h1:b/8HpQhvKLSNzH5oTXN2WkNcMl6YB5K3FRbb+i+Ml34=
108+
github.com/google/pprof v0.0.0-20250418163039-24c5476c6587/go.mod h1:boTsfXsheKC2y+lKOCMpSfarhxDeIzfZG1jqGcPl3cA=
105109
github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=
106110
github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
107111
github.com/gorilla/websocket v1.4.1/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=
@@ -146,6 +150,10 @@ github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9G
146150
github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
147151
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 h1:C3w9PqII01/Oq1c1nUAm88MOHcQC9l5mIlSMApZMrHA=
148152
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822/go.mod h1:+n7T8mK8HuQTcFwEeznm/DIxMOiR9yIdICNftLE1DvQ=
153+
github.com/onsi/ginkgo/v2 v2.23.4 h1:ktYTpKJAVZnDT4VjxSbiBenUjmlL/5QkBEocaWXiQus=
154+
github.com/onsi/ginkgo/v2 v2.23.4/go.mod h1:Bt66ApGPBFzHyR+JO10Zbt0Gsp4uWxu5mIOTusL46e8=
155+
github.com/onsi/gomega v1.36.3 h1:hID7cr8t3Wp26+cYnfcjR6HpJ00fdogN6dqZ1t6IylU=
156+
github.com/onsi/gomega v1.36.3/go.mod h1:8D9+Txp43QWKhM24yyOBEdpkzN8FvJyAwecBgsU4KU0=
149157
github.com/pelletier/go-toml/v2 v2.0.9 h1:uH2qQXheeefCCkuBBSLi7jCiSmj3VRh2+Goq2N7Xxu0=
150158
github.com/pelletier/go-toml/v2 v2.0.9/go.mod h1:tJU2Z3ZkXwnxa4DPO899bsyIoywizdUvyaeZurnPPDc=
151159
github.com/philhofer/fwd v1.2.0 h1:e6DnBTl7vGY+Gz322/ASL4Gyp1FspeMvx1RNDoToZuM=
@@ -231,8 +239,8 @@ go.uber.org/automaxprocs v1.6.0 h1:O3y2/QNTOdbF+e/dpXNNW7Rx2hZ4sTIPyybbxyNqTUs=
231239
go.uber.org/automaxprocs v1.6.0/go.mod h1:ifeIMSnPZuznNm6jmdzmU3/bfk01Fe2fotchwEFJ8r8=
232240
go.uber.org/goleak v1.3.0 h1:2K3zAYmnTNqV73imy9J1T3WC+gmCePx2hEGkimedGto=
233241
go.uber.org/goleak v1.3.0/go.mod h1:CoHD4mav9JJNrW/WLlf7HGZPjdw8EucARQHekz1X6bE=
234-
go.uber.org/mock v0.5.2 h1:LbtPTcP8A5k9WPXj54PPPbjcI4Y6lhyOZXn+VS7wNko=
235-
go.uber.org/mock v0.5.2/go.mod h1:wLlUxC2vVTPTaE3UD51E0BGOAElKrILxhVSDYQLld5o=
242+
go.uber.org/mock v0.5.1 h1:ASgazW/qBmR+A32MYFDB6E2POoTgOwT509VP0CT/fjs=
243+
go.uber.org/mock v0.5.1/go.mod h1:ge71pBPLYDk7QIi1LupWxdAykm7KIEFchiOqd6z7qMM=
236244
golang.org/x/arch v0.4.0 h1:A8WCeEWhLwPBKNbFi5Wv5UTCBx5zzubnXDlMOFAzFMc=
237245
golang.org/x/arch v0.4.0/go.mod h1:5om86z9Hs0C8fWVUuoMHwpExlXzs5Tkyp9hOrfG7pp8=
238246
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=

0 commit comments

Comments
 (0)