github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-22 11:21:47 +00:00
Code Issues Projects Releases Wiki Activity

etcd3/store: call a generic cancelled watch test

Browse Source 
Signed-off-by: Steve Kuznetsov <skuznets@redhat.com>
This commit is contained in:
Steve Kuznetsov 2022-05-09 08:23:03 -07:00
parent 774870611c
commit c0fc817255
No known key found for this signature in database
GPG Key ID: 8821C29EC988D9B4
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
View File

@ -137,6 +137,10 @@ func TestWatchError(t *testing.T) {
func TestWatchContextCancel(t *testing.T) { func TestWatchContextCancel(t *testing.T) {
ctx, store, _ := testSetup(t) ctx, store, _ := testSetup(t)
RunTestWatchContextCancel(ctx, t, store)
}
func RunTestWatchContextCancel(ctx context.Context, t *testing.T, store storage.Interface) {
canceledCtx, cancel := context.WithCancel(ctx) canceledCtx, cancel := context.WithCancel(ctx)
cancel() cancel()
// When we watch with a canceled context, we should detect that it's context canceled. // When we watch with a canceled context, we should detect that it's context canceled.