Skip to content

Commit 814e695

Browse files
committed
bugfix: flaky TestAdd_Close<Graceful>_concurrent
We need to add non-added endpoint to avoid `endpoint exist` error.
1 parent 3296360 commit 814e695

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

connection_pool/connection_pool_test.go

+4-4
Original file line numberDiff line numberDiff line change
@@ -345,9 +345,9 @@ func TestAdd_Close_concurrent(t *testing.T) {
345345
go func() {
346346
defer wg.Done()
347347

348-
err = connPool.Add(servers[0])
348+
err = connPool.Add(servers[1])
349349
if err != nil {
350-
assert.Equal(t, err, connection_pool.ErrClosed)
350+
assert.Equal(t, connection_pool.ErrClosed, err)
351351
}
352352
}()
353353

@@ -366,9 +366,9 @@ func TestAdd_CloseGraceful_concurrent(t *testing.T) {
366366
go func() {
367367
defer wg.Done()
368368

369-
err = connPool.Add(servers[0])
369+
err = connPool.Add(servers[1])
370370
if err != nil {
371-
assert.Equal(t, err, connection_pool.ErrClosed)
371+
assert.Equal(t, connection_pool.ErrClosed, err)
372372
}
373373
}()
374374

0 commit comments

Comments
 (0)