- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 100 for timeEnd (0.84 sec)
-
pkg/proxy/config/api_test.go
svcHandler.lock.Lock() defer svcHandler.lock.Unlock() if reflect.DeepEqual(svcHandler.state, expectedSvcState) { return true, nil } return false, nil }) if err != nil { t.Fatal("Timed out waiting for the completion of handler `OnServiceAdd`") } err = wait.PollImmediate(time.Millisecond*10, wait.ForeverTestTimeout, func() (bool, error) { epsHandler.lock.Lock() defer epsHandler.lock.Unlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/controlplane/controller/systemnamespaces/system_namespaces_controller.go
defer klog.Infof("Shutting down system namespaces controller") klog.Infof("Starting system namespaces controller") if !cache.WaitForCacheSync(stopCh, c.namespaceSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } go wait.Until(c.sync, c.interval, stopCh) <-stopCh } func (c *Controller) sync() { // Loop the system namespace list, and create them if they do not exist
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 12:19:56 UTC 2024 - 2.9K bytes - Viewed (0) -
src/runtime/lock_sema.go
// // func semasleep(ns int64) int32 // If ns < 0, acquire m's semaphore and return 0. // If ns >= 0, try to acquire m's semaphore for at most ns nanoseconds. // Return 0 if the semaphore was acquired, -1 if interrupted or timed out. // // func semawakeup(mp *m) // Wake up mp, which is or will soon be sleeping on its semaphore. const ( locked uintptr = 1 active_spin = 4 active_spin_cnt = 30 passive_spin = 1 )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
platforms/core-runtime/wrapper-main/src/integTest/groovy/org/gradle/integtests/WrapperHttpIntegrationTest.groovy
then: failure.assertHasErrorOutput("Downloading from ${getDefaultBaseUrl()}/$TEST_DISTRIBUTION_URL failed: timeout (10000ms)") failure.assertHasErrorOutput('Read timed out') } @Issue('https://github.com/gradle/gradle-private/issues/3032') def "does not leak credentials when download times out"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:54:32 UTC 2024 - 10.7K bytes - Viewed (0) -
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/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) -
analysis/analysis-api-impl-base/tests/org/jetbrains/kotlin/analysis/api/impl/base/test/SymbolByFqName.kt
val testFileText = FileUtil.loadFile(File(filePath)) val fileTextWithoutSymbolsData = testFileText.substringBeforeLast(SYMBOLS_TAG).trimEnd() appendLine(fileTextWithoutSymbolsData) appendLine() appendLine(SYMBOLS_TAG) append(rendered) } private const val SYMBOLS_TAG = "// SYMBOLS:" }
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed May 29 17:43:55 UTC 2024 - 8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/MoreExecutors.java
ListeningExecutorService executorService, Collection<? extends Callable<T>> tasks, boolean timed, Duration timeout) throws InterruptedException, ExecutionException, TimeoutException { return invokeAnyImpl( executorService, tasks, timed, toNanosSaturated(timeout), TimeUnit.NANOSECONDS); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 15 10:40:05 UTC 2024 - 43.7K bytes - Viewed (0) -
src/runtime/sys_linux_ppc64x.s
MOVD sevp+8(FP), R4 MOVD timerid+16(FP), R5 SYSCALL $SYS_timer_create MOVW R3, ret+24(FP) RET TEXT runtime·timer_settime(SB),NOSPLIT,$0-28 MOVW timerid+0(FP), R3 MOVW flags+4(FP), R4 MOVD new+8(FP), R5 MOVD old+16(FP), R6 SYSCALL $SYS_timer_settime MOVW R3, ret+24(FP) RET TEXT runtime·timer_delete(SB),NOSPLIT,$0-12 MOVW timerid+0(FP), R3 SYSCALL $SYS_timer_delete
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 18:17:17 UTC 2024 - 18.1K bytes - Viewed (0)