t

Author: oleg-jukovec

connection_pool/connection_pool_test.go

@@ -238,6 +238,7 @@ type testListener struct {
 	added, closed int
 	errs          []error
 	mutex         sync.Mutex
+	seq           []string
 }
 
 func (tl *testListener) addErr(err error) {
@@ -249,6 +250,7 @@ func (tl *testListener) Add(conn *tarantool.Connection, role connection_pool.Rol
 	defer tl.mutex.Unlock()
 
 	tl.added++
+	tl.seq = append(tl.seq, fmt.Sprintf("add %s", conn.Addr()))
 
 	if conn == nil {
 		tl.addErr(fmt.Errorf("added conn == nil"))
@@ -277,6 +279,7 @@ func (tl *testListener) Removed(conn *tarantool.Connection, role connection_pool
 	defer tl.mutex.Unlock()
 
 	tl.closed++
+	tl.seq = append(tl.seq, fmt.Sprintf("closed %s", conn.Addr()))
 
 	if conn == nil {
 		tl.addErr(fmt.Errorf("removed conn == nil"))
@@ -349,8 +352,8 @@ func TestConnectionListener(t *testing.T) {
 	for _, err := range tl.errs {
 		t.Errorf("Unexpected error: %s", err)
 	}
-	require.Equalf(t, tl.added, len(poolServers)+1, "unexpected added count")
-	require.Equalf(t, tl.closed, len(poolServers)+1, "unexpected closed count")
+	require.Equalf(t, tl.added, len(poolServers)+1, "unexpected added count %v", tl.seq)
+	require.Equalf(t, tl.closed, len(poolServers)+1, "unexpected closed count %v", tl.seq)
 }
 
 type testAddErrorListener struct {