- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 320 for timeEnd (0.12 sec)
-
src/syscall/exec_linux_test.go
} } func TestCloneTimeNamespace(t *testing.T) { testenv.MustHaveExec(t) if os.Getenv("GO_WANT_HELPER_PROCESS") == "1" { timens, err := os.Readlink("/proc/self/ns/time") if err != nil { fmt.Fprintln(os.Stderr, err) os.Exit(2) } fmt.Print(string(timens)) os.Exit(0) } exe, err := os.Executable() if err != nil { t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 07:45:37 UTC 2024 - 20.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java
*/ private static TestCase generateGuardWithWrongMonitorTestCase( final Method method, final boolean fair1, final boolean fair2) { final boolean timed = isTimed(method); // Not going to bother with all timeouts, just 0ms. return new TestCase(method.getName() + (timed ? "(0ms)" : "()") + "/WrongMonitor->IMSE") { @Override protected void runTest() throws Throwable { Monitor monitor1 = new Monitor(fair1);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 29 16:29:37 UTC 2024 - 27.1K bytes - Viewed (0) -
src/crypto/tls/cache_test.go
} } timeoutRefCheck := func(t *testing.T, key string, count int64) { t.Helper() c := time.After(4 * time.Second) for { select { case <-c: t.Fatal("timed out waiting for expected ref count") default: e, ok := cc.Load(key) if !ok && count != 0 { t.Fatal("cache does not contain expected key") } else if count == 0 && !ok { return }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 07 19:46:27 UTC 2022 - 2.6K bytes - Viewed (0) -
platforms/software/dependency-management/src/integTest/groovy/org/gradle/integtests/resolve/DependencyUnresolvedModuleIntegrationTest.groovy
failure.assertHasCause("Could not GET '${mavenHttpRepo.uri.toString()}/${group}/${module}/maven-metadata.xml'.") failure.assertHasCause("Read timed out") } private void assertDependencyListingInternalServerError(String group, String module, String version) { failure.assertHasCause("Could not resolve ${group}:${module}:${version}.")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 29 11:51:18 UTC 2024 - 20.9K bytes - Viewed (0) -
pkg/kubelet/pluginmanager/pluginwatcher/plugin_watcher_test.go
time.Duration(500*time.Millisecond), func() (bool, error) { if dsw.PluginExists(socketPath) { return true, nil } return false, nil }, ) if err != nil { t.Fatalf("Timed out waiting for plugin to be added to desired state of world cache:\n%s.", socketPath) } } func waitForUnregistration( t *testing.T, socketPath string, dsw cache.DesiredStateOfWorld) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 04 06:56:50 UTC 2023 - 8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
case <-time.After(wait.ForeverTestTimeout): t.Errorf("Expected the server handler to panic for request: %q", firstRequestPathPanic) } if isClientTimeout(err) { t.Fatalf("the client has unexpectedly timed out - request: %q error: %s", firstRequestPathPanic, err.Error()) } expectResetStreamError(t, err) // the second request should be served successfully. response, err := requestGetter(secondRequestPathShouldWork)
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/revisions/default_watcher_test.go
select { case rev := <-revisionChan: if rev != expected { t.Fatalf("expected revision %q to be produced on chan, got %q", expected, rev) } case <-time.After(time.Second * 5): t.Fatalf("timed out waiting for value on default revision chan") } } func TestNoDefaultRevision(t *testing.T) { stop := make(chan struct{}) client := kube.NewFakeClient() w := NewDefaultWatcher(client, "default")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 23 17:46:59 UTC 2023 - 3.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go
) const ( // The executing request handler panicked after the request had // been timed out by the apiserver. PostTimeoutHandlerPanic = "panic" // The executing request handler has returned an error to the post-timeout // receiver after the request had been timed out by the apiserver. PostTimeoutHandlerError = "error"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 07:29:19 UTC 2023 - 35K bytes - Viewed (0) -
pkg/controlplane/controller/kubernetesservice/controller.go
// Start begins the core controller loops that must exist for bootstrapping // a cluster. func (c *Controller) Start(stopCh <-chan struct{}) { if !cache.WaitForCacheSync(stopCh, c.serviceSynced) { runtime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // Reconcile during first run removing itself until server is ready. endpointPorts := createEndpointPortSpec(c.PublicServicePort, "https")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 9.3K bytes - Viewed (0) -
src/vendor/golang.org/x/net/nettest/conntest.go
} checkForTimeoutError(t, err) if len(deadlineSet) == 0 { t.Error("Read timed out before deadline is set") } }() go func() { defer wg.Done() var err error for err == nil { _, err = c1.Write(make([]byte, 1024)) } checkForTimeoutError(t, err) if len(deadlineSet) == 0 { t.Error("Write timed out before deadline is set") } }() }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 12.2K bytes - Viewed (0)