- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 636 for waits (0.12 sec)
-
guava/src/com/google/common/cache/LoadingCache.java
* necessary. No observable state associated with this cache is modified until loading completes. * * <p>If another call to {@link #get} or {@link #getUnchecked} is currently loading the value for * {@code key}, simply waits for that thread to finish and returns its loaded value. Note that * multiple threads can concurrently load values for distinct keys. *
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sat Aug 06 17:12:03 UTC 2022 - 8.3K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate_server.go
func NewEtcdMigrateServer(cfg *EtcdMigrateCfg, client EtcdMigrateClient) *EtcdMigrateServer { return &EtcdMigrateServer{cfg: cfg, client: client} } // Start starts an etcd server as a separate process, waits until it has started, and returns a exec.Cmd. // TODO: Add support for listening to client via TLS. func (r *EtcdMigrateServer) Start(version *EtcdVersion) error { etcdCmd := exec.Command(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 30 16:29:59 UTC 2022 - 3.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
slowChannel.exitClose.countDown(); // release the interrupter // We need to wait for the runner to exit. To make sure that the interrupting thread wakes it // back up. runner.join(TimeUnit.SECONDS.toMillis(10)); } // waits for the given thread to be blocked on the given object private static void awaitBlockedOnInstanceOf(Thread t, Class<?> blocker)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
slowChannel.exitClose.countDown(); // release the interrupter // We need to wait for the runner to exit. To make sure that the interrupting thread wakes it // back up. runner.join(TimeUnit.SECONDS.toMillis(10)); } // waits for the given thread to be blocked on the given object private static void awaitBlockedOnInstanceOf(Thread t, Class<?> blocker)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_termination_order_test.go
time.Sleep(1 * time.Second) to.containerTerminated("main") wg.Done() }() wg.Wait() if sidecarWaitDelay != 1 { t.Errorf("expected sidecar to wait for main container to exit, got delay of %d", sidecarWaitDelay) } if mainWaitDelay != 0 { t.Errorf("expected main container to not wait to exit, got delay of %d", mainWaitDelay) } } func TestTerminationOrderingSidecarsInReverseOrder(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 00:07:21 UTC 2023 - 6.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/value/encrypt/envelope/testing/v1beta1/kms_plugin_mock.go
t.Fatalf("failed to start KMS plugin: err: %v", err) } return result } // waitForBase64PluginToBeUp waits until the plugin is ready to serve requests. func waitForBase64PluginToBeUp(plugin *Base64Plugin) error { var gRPCErr error pollErr := wait.PollImmediate(1*time.Second, wait.ForeverTestTimeout, func() (bool, error) { _, gRPCErr = plugin.Encrypt(context.Background(), &kmsapi.EncryptRequest{Plain: []byte("foo")})
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 29 05:36:41 UTC 2023 - 5.2K bytes - Viewed (0) -
src/net/fd_unix.go
} // Start the "interrupter" goroutine, if this context might be canceled. // // The interrupter goroutine waits for the context to be done and // interrupts the dial (by altering the fd's write deadline, which // wakes up waitWrite). ctxDone := ctx.Done() if ctxDone != nil { // Wait for the interrupter goroutine to exit before returning // from connect. done := make(chan struct{})
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 24 20:19:46 UTC 2023 - 5.4K bytes - Viewed (0) -
src/net/http/main_test.go
// shutting down, so give it some time. time.Sleep(1 * time.Millisecond) } t.Errorf("Test appears to have leaked %s:\n%s", bad, stacks) } // waitCondition waits for fn to return true, // checking immediately and then at exponentially increasing intervals. func waitCondition(t testing.TB, delay time.Duration, fn func(time.Duration) bool) { t.Helper() start := time.Now()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 03 22:49:46 UTC 2024 - 4.9K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
Context string // DryRun performs all steps except actually applying the manifests or creating output dirs/files. DryRun bool // Maximum amount of time to wait for resources to be ready after install when Wait=true. WaitTimeout time.Duration } func applyManifest(kubeClient kube.Client, client client.Client, manifestStr string,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/workload_manager.go
// Run the pod controller. go m.podController.Run(m.stopCh) // Wait for the cache to sync. if !m.podController.WaitForSync(m.stopCh) { return fmt.Errorf( "failed syncing cache for echo %s/%s: controller stopping", m.cfg.Namespace.Name(), m.cfg.Service) } // Wait until all pods are ready. _, err := m.WaitForReadyWorkloads() return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0)