- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 348 for timediv (0.21 sec)
-
src/runtime/sys_linux_arm.s
SWI $0 RET TEXT runtime·timer_create(SB),NOSPLIT,$0-16 MOVW clockid+0(FP), R0 MOVW sevp+4(FP), R1 MOVW timerid+8(FP), R2 MOVW $SYS_timer_create, R7 SWI $0 MOVW R0, ret+12(FP) RET TEXT runtime·timer_settime(SB),NOSPLIT,$0-20 MOVW timerid+0(FP), R0 MOVW flags+4(FP), R1 MOVW new+8(FP), R2 MOVW old+12(FP), R3 MOVW $SYS_timer_settime, R7 SWI $0 MOVW R0, ret+16(FP)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 24 18:53:44 UTC 2023 - 13.5K bytes - Viewed (0) -
pkg/kubelet/clustertrustbundle/clustertrustbundle_manager_test.go
ctbManager, _ := NewInformerManager(ctbInformer, 256, 5*time.Minute) informerFactory.Start(ctx.Done()) if !cache.WaitForCacheSync(ctx.Done(), ctbInformer.Informer().HasSynced) { t.Fatalf("Timed out waiting for informer to sync") } gotBundle, err := ctbManager.GetTrustAnchorsByName("ctb1", false) if err != nil { t.Fatalf("Error while calling GetTrustAnchorsByName: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Nov 03 18:40:48 UTC 2023 - 15.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractService.java
// timed out. e.g. if we weren't event able to grab the lock within the timeout we would never // even check the guard. I don't think we care too much about this use case but it could lead // to a confusing error message. throw new TimeoutException("Timed out waiting for " + this + " to reach the RUNNING state."); } } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.4K bytes - Viewed (0) -
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) -
guava/src/com/google/common/util/concurrent/AbstractService.java
// timed out. e.g. if we weren't event able to grab the lock within the timeout we would never // even check the guard. I don't think we care too much about this use case but it could lead // to a confusing error message. throw new TimeoutException("Timed out waiting for " + this + " to reach the RUNNING state."); } } @Override
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptibleFutureTest.java
throws TimeoutException, ExecutionException { SettableFuture<String> future = SettableFuture.create(); future.set(RESULT); /* * getUninterruptibly should call the timed get method once with a * wait of 0 seconds (and it should succeed, since the result is already * available). */ assertEquals(RESULT, getUninterruptibly(future, 0, SECONDS)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 9.1K 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) -
pkg/bootstrap/platform/discovery.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 2.6K 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) -
internal/http/server.go
tmp, err := os.CreateTemp("", "minio-goroutines-*.txt") if err == nil { _ = pprof.Lookup("goroutine").WriteTo(tmp, 1) tmp.Close() return errors.New("timed out. some connections are still active. goroutines written to " + tmp.Name()) } return errors.New("timed out. some connections are still active") case <-timer.C: if atomic.LoadInt32(&srv.requestCount) <= 0 { return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Feb 09 21:25:16 UTC 2024 - 7.7K bytes - Viewed (0)