Skip to content
Snippets Groups Projects
Unverified Commit 30c41ad0 authored by fagongzi's avatar fagongzi Committed by GitHub
Browse files

morpc: fix unstable test (#4531)

parent f5ebc6dc
No related branches found
No related tags found
No related merge requests found
......@@ -481,6 +481,7 @@ func TestTCPProxyExample(t *testing.T) {
defer func() {
assert.NoError(t, p.Stop())
}()
p.AddUpStream(testAddr, time.Second*10)
testBackendSendWithAddr(t,
testProxyAddr,
......@@ -488,8 +489,6 @@ func TestTCPProxyExample(t *testing.T) {
return conn.Write(msg, goetty.WriteOptions{Flush: true})
},
func(b *remoteBackend) {
p.AddUpStream(testAddr, b.options.connectTimeout)
ctx, cancel := context.WithTimeout(context.Background(), time.Second*10)
defer cancel()
req := newTestMessage(1)
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment