Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 1,948 for waits (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. istioctl/pkg/wait/wait.go

    const pollInterval = time.Second
    
    // Cmd represents the wait command
    func Cmd(cliCtx cli.Context) *cobra.Command {
    	namespace := cliCtx.Namespace()
    	var opts clioptions.ControlPlaneOptions
    	cmd := &cobra.Command{
    		Use:   "wait [flags] <type> <name>[.<namespace>]",
    		Short: "Wait for an Istio resource",
    		Long:  `Waits for the specified condition to be true of an Istio resource.`,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat Feb 17 12:24:17 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiextensions-apiserver/test/integration/storage/objectreader.go

    	return &EtcdObjectReader{etcdClient, restOptions.StorageConfig.Prefix, crd}
    }
    
    // WaitForStorageVersion calls the updateObjFn periodically and waits for the version of the custom resource stored in etcd to be set to the provided version.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 15 13:53:06 UTC 2021
    - 4.7K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. pkg/kube/client.go

    	ObjectFilter() kubetypes.DynamicObjectFilter
    
    	// RunAndWait starts all informers and waits for their caches to sync.
    	// Warning: this must be called AFTER .Informer() is called, which will register the informer.
    	// "false" is returned if this prematurely exited without syncing.
    	RunAndWait(stop <-chan struct{}) bool
    
    	// WaitForCacheSync waits for all cache functions to sync, as well as all informers started by the *fake* client.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 14:44:17 UTC 2024
    - 39K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

        }
        return this;
      }
    
      /**
       * Waits for the all the services to reach a terminal state. After this method returns all
       * services will either be {@linkplain Service.State#TERMINATED terminated} or {@linkplain
       * Service.State#FAILED failed}.
       */
      public void awaitStopped() {
        state.awaitStopped();
      }
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue May 07 12:41:16 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  10. 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)
Back to top