- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 490 for Terminate (0.19 sec)
-
platforms/core-execution/snapshots/src/main/java/org/gradle/internal/snapshot/CompositeFileSystemSnapshot.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 2.9K bytes - Viewed (0) -
pkg/registry/core/replicationcontroller/storage/storage_test.go
func TestDelete(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.Controller.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Controller.Store) test.TestDelete(validNewController()) } func TestGenerationNumber(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.Controller.Store.DestroyFunc() modifiedSno := *validNewController()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 16 06:57:01 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/envoy/agent.go
log.Warnf("Error in invoking drain listeners endpoint: %v", err) } // If we drained now, skip draining + waiting later // When we terminate, we will instead exit immediately a.DisableDraining() } // terminate starts exiting the process. func (a *Agent) terminate() { log.Infof("Agent draining Proxy for termination") if a.skipDrain.Load() { log.Infof("Agent already drained, exiting immediately")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
pkg/registry/core/pod/storage/storage_test.go
} } func TestGet(t *testing.T) { storage, _, _, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store) test.TestGet(validNewPod()) } func TestList(t *testing.T) { storage, _, _, server := newStorage(t) defer server.Terminate(t) defer storage.Store.DestroyFunc() test := genericregistrytest.New(t, storage.Store)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 07:18:44 UTC 2024 - 38.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd_test.go
storage, server := newStorage(t) defer server.Terminate(t) defer storage.CustomResource.Store.DestroyFunc() test := registrytest.New(t, storage.CustomResource.Store) cr := validNewCustomResource() cr.SetNamespace("") test.TestCreate( cr, ) } func TestGet(t *testing.T) { storage, server := newStorage(t) defer server.Terminate(t) defer storage.CustomResource.Store.DestroyFunc()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 19:06:46 UTC 2024 - 25.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/testdata/tls.status.yaml.golden
status: "True" type: Programmed - lastTransitionTime: fake message: No errors found reason: ResolvedRefs status: "True" type: ResolvedRefs name: terminate supportedKinds: - group: gateway.networking.k8s.io kind: HTTPRoute - group: gateway.networking.k8s.io kind: GRPCRoute - attachedRoutes: 0 conditions: - lastTransitionTime: fake
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 01 20:54:36 UTC 2024 - 5.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
} finally { if (t.getState() != Thread.State.TERMINATED) { t.interrupt(); fail("Test timed out"); } } } /** * Waits for LONG_DELAY_MS milliseconds for the thread to terminate (using {@link * Thread#join(long)}), else interrupts the thread (in the hope that it may terminate later) and * fails. */ void awaitTermination(Thread t) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 10 19:21:11 UTC 2024 - 37.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
} finally { if (t.getState() != Thread.State.TERMINATED) { t.interrupt(); fail("Test timed out"); } } } /** * Waits for LONG_DELAY_MS milliseconds for the thread to terminate (using {@link * Thread#join(long)}), else interrupts the thread (in the hope that it may terminate later) and * fails. */ void awaitTermination(Thread t) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:15:24 UTC 2024 - 37.7K bytes - Viewed (0) -
src/text/tabwriter/tabwriter.go
// A cell represents a segment of text terminated by tabs or line breaks. // The text itself is stored in a separate buffer; cell only describes the // segment's size in bytes, its width in runes, and whether it's an htab // ('\t') terminated cell. type cell struct { size int // cell size in bytes width int // cell width in runes htab bool // true if the cell is terminated by an htab ('\t') }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Feb 29 16:46:34 UTC 2024 - 17.8K bytes - Viewed (0)