client: added error logging for Put request

Signed-off-by: AngstyDuck <[email protected]>
etcd-io · Sep 7, 2023 · d0ac5df · d0ac5df
1 parent 357f70d
commit d0ac5df
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/tests/integration/clientv3/concurrency/session_test.go b/tests/integration/clientv3/concurrency/session_test.go
@@ -171,9 +171,12 @@ func TestTimeoutDoesntAffectSubsequentConnections(t *testing.T) {
 	clus.Members[0].Terminate(t)
 
 	donec := make(chan struct{})
+	errorc := make(chan error)
 	go func() {
 		defer close(donec)
-		_, _ = cli.Put(s.Ctx(), "sample_key", "sample_value", clientv3.WithLease(s.Lease()))
+		if _, err := cli.Put(s.Ctx(), "sample_key", "sample_value", clientv3.WithLease(s.Lease())); err != nil {
+			errorc <- err
+		}
 	}()
 
 	select {
@@ -188,6 +191,8 @@ func TestTimeoutDoesntAffectSubsequentConnections(t *testing.T) {
 	clus.Members[0].Restart(t)
 	select {
 	case <-donec:
+	case err := <-errorc:
+		t.Errorf("Put failed: %v", err)
 	case <-time.After(1 * time.Second):
 		t.Fatal("Put function hung even after restarting cluster")
 	}