- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 237 for withCancel (5.27 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
return handler } func TestApfSkipLongRunningRequest(t *testing.T) { server := newApfServerWithSingleRequest(t, decisionSkipFilter) defer server.Close() ctx, cancel := context.WithCancel(context.Background()) defer cancel() StartPriorityAndFairnessWatermarkMaintenance(ctx.Done()) // send a watch request to test skipping long running request
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/volumebinding/binder_test.go
nodeLabelKey: "node1", }, }, } run := func(t *testing.T, scenario scenarioType, csiDriver *storagev1.CSIDriver) { logger, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() // Setup testEnv := newTestBinder(t, ctx) testEnv.initVolumes(scenario.pvs, scenario.pvs) if csiDriver != nil { testEnv.addCSIDriver(csiDriver) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 09:46:58 UTC 2024 - 82.8K bytes - Viewed (0) -
cmd/server-main_test.go
t.Error("expected hash", testcase.hash, "got", sctx.Layout.pools[0].cmdline) } } }) } } // Tests initializing new object layer. func TestNewObjectLayer(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() // Tests for ErasureSD object layer. nDisks := 1 disks, err := getRandomDisks(nDisks) if err != nil { t.Fatal("Failed to create drives for the backend") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Dec 07 09:33:56 UTC 2023 - 3.1K bytes - Viewed (0) -
pilot/pkg/status/resource.go
return &IstioGenerationProvider{ret}, nil } return nil, fmt.Errorf("cannot cast %T: %v to GenerationProvider", in, in) } func NewIstioContext(stop <-chan struct{}) context.Context { ctx, cancel := context.WithCancel(context.Background()) go func() { <-stop cancel() }() return ctx
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 30 16:13:59 UTC 2023 - 3.2K bytes - Viewed (0) -
cmd/auth-handler_test.go
} return req } // Tests is requested authenticated function, tests replies for s3 errors. func TestIsReqAuthenticated(t *testing.T) { ctx, cancel := context.WithCancel(GlobalContext) defer cancel() objLayer, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err) } defer os.RemoveAll(fsDir)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.4K bytes - Viewed (0) -
cmd/lock-rest-server-common_test.go
t.Fatal(err) } return fsDir, locker, token } // Test function to remove lock entries from map based on name & uid combination func TestLockRpcServerRemoveEntry(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() testPath, locker, _ := createLockTestServer(ctx, t) defer os.RemoveAll(testPath) lockRequesterInfo1 := lockRequesterInfo{ Owner: "owner",
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Mar 23 17:26:21 UTC 2023 - 3.1K bytes - Viewed (0) -
cmd/namespace-lock.go
func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) { lockSource := getSource(2) start := UTCNow() newCtx, cancel := context.WithCancel(ctx) if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{ Timeout: timeout.Timeout(), RetryInterval: timeout.RetryInterval(), }) { timeout.LogFailure() defer cancel()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 05 23:56:35 UTC 2023 - 9.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/registry/generic/registry/decorated_watcher_test.go
w := watch.NewFake() decorator := func(obj runtime.Object) { if pod, ok := obj.(*example.Pod); ok { pod.Annotations = map[string]string{"decorated": "true"} } } ctx, cancel := context.WithCancel(context.Background()) dw := newDecoratedWatcher(ctx, w, decorator) defer dw.Stop() go func() { w.Error(&metav1.Status{Status: "Failure"}) w.Add(&example.Pod{ObjectMeta: metav1.ObjectMeta{Name: "foo"}})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 02 19:25:31 UTC 2021 - 3.4K bytes - Viewed (0) -
cmd/admin-handlers_test.go
// prepareAdminErasureTestBed - helper function that setups a single-node // Erasure backend for admin-handler tests. func prepareAdminErasureTestBed(ctx context.Context) (*adminErasureTestBed, error) { ctx, cancel := context.WithCancel(ctx) // reset global variables to start afresh. resetTestGlobals() // Set globalIsErasure to indicate that the setup uses an erasure // code backend. globalIsErasure = true
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Feb 22 06:26:06 UTC 2024 - 13.8K bytes - Viewed (0) -
src/database/sql/sql_test.go
db := newTestDB(t, "people") defer closeDB(t, db) // This WithCancel is important; Rows contains an optimization to avoid // spawning a goroutine when the query/transaction context cannot be // canceled, but this test tests a bug which is caused by said goroutine. ctx, cancel := context.WithCancel(context.Background()) defer cancel() r, err := db.QueryContext(ctx, "SELECT|people|name|")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 18:42:28 UTC 2024 - 111.6K bytes - Viewed (0)