mirrors/uquic
1
0
Fork 0
mirror of https://github.com/refraction-networking/uquic.git synced 2025-04-04 12:47:36 +03:00
Code Issues Projects Releases Packages Wiki Activity

fix flaky proxy test

Browse source
This commit is contained in:
Marten Seemann 2020-05-04 12:50:00 +07:00
parent c0b6d4e141
commit a9e5686cdf
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
integrationtests/tools/proxy/proxy_test.go
View file

@ -2,6 +2,7 @@ package quicproxy
import ( import (
"bytes" "bytes"
"fmt"
"net" "net"
"runtime/pprof" "runtime/pprof"
"strconv" "strconv"
@ -9,10 +10,9 @@ import (
"sync/atomic" "sync/atomic"
"time" "time"
"fmt"
"github.com/lucas-clemente/quic-go/internal/protocol" "github.com/lucas-clemente/quic-go/internal/protocol"
"github.com/lucas-clemente/quic-go/internal/wire" "github.com/lucas-clemente/quic-go/internal/wire"
. "github.com/onsi/ginkgo" . "github.com/onsi/ginkgo"
. "github.com/onsi/gomega" . "github.com/onsi/gomega"
) )
@ -160,8 +160,8 @@ var _ = Describe("QUIC Proxy", func() {
data := buf[0:n] data := buf[0:n]
serverReceivedPackets <- packetData(data) serverReceivedPackets <- packetData(data)
// echo the packet // echo the packet
serverConn.WriteToUDP(data, addr)
atomic.AddInt32(&serverNumPacketsSent, 1) atomic.AddInt32(&serverNumPacketsSent, 1)
serverConn.WriteToUDP(data, addr)
} }
}() }()
}) })