Skip to content

Commit

Permalink
Rename the test and update comments
Browse files Browse the repository at this point in the history
Signed-off-by: Jin Dong <[email protected]>
  • Loading branch information
greenmoon55 committed Nov 28, 2023
1 parent f2d718e commit 4c85377
Showing 1 changed file with 9 additions and 6 deletions.
15 changes: 9 additions & 6 deletions tests/integration/clientv3/watch_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -350,9 +350,9 @@ func putAndWatch(t *testing.T, wctx *watchctx, key, val string) {
}
}

// TestWatchResumeInitRev tests watch resume with disconnect before the first event.
// It ensures that correct events are returned corresponding to the start revision.
func TestWatchResumeInitRev(t *testing.T) {
// TestWatchResumeAfterDisconnect tests watch resume after member disconnects then connects.
// It ensures that correct events are returned corresponding to the start revision.
func TestWatchResumeAfterDisconnect(t *testing.T) {
integration2.BeforeTest(t)
clus := integration2.NewCluster(t, &integration2.ClusterConfig{Size: 1, UseBridge: true})
defer clus.Terminate(t)
Expand Down Expand Up @@ -394,13 +394,16 @@ func TestWatchResumeInitRev(t *testing.T) {
if !ok {
t.Fatal("unexpected watch close")
}
if len(resp.Events) == 0 {
t.Fatal("expected event on watch")
}
// Events should be put(a, 3) and put(a, 4)
if len(resp.Events) != 2 {
t.Fatal("expected two events on watch")
}
if string(resp.Events[0].Kv.Value) != "3" {
t.Fatalf("expected value=3, got event %+v", resp.Events[0])
}
if string(resp.Events[1].Kv.Value) != "4" {
t.Fatalf("expected value=4, got event %+v", resp.Events[1])
}
case <-time.After(5 * time.Second):
t.Fatal("watch timed out")
}
Expand Down

0 comments on commit 4c85377

Please sign in to comment.