Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 34 for wait (0.3 seconds)

  1. CHANGELOG/CHANGELOG-1.4.md

    * Cherrypick [#34851](https://github.com/kubernetes/kubernetes/pull/34851) "Only wait for cache syncs once in NodeController" ([#34861](https://github.com/kubernetes/kubernetes/pull/34861), [@jessfraz](https://github.com/jessfraz))
    * NodeController waits for informer sync before doing anything ([#34809](https://github.com/kubernetes/kubernetes/pull/34809), [@gmarek](https://github.com/gmarek))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 133.5K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        CountDownLatch gotException = new CountDownLatch(1);
        AsyncCallable<String> combiner =
            () -> {
              inFunction.countDown();
              try {
                new CountDownLatch(1).await(); // wait for interrupt
              } catch (InterruptedException expected) {
                gotException.countDown();
                throw expected;
              }
              return immediateFuture("a");
            };
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        CountDownLatch gotException = new CountDownLatch(1);
        AsyncCallable<String> combiner =
            () -> {
              inFunction.countDown();
              try {
                new CountDownLatch(1).await(); // wait for interrupt
              } catch (InterruptedException expected) {
                gotException.countDown();
                throw expected;
              }
              return immediateFuture("a");
            };
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
  4. CHANGELOG/CHANGELOG-1.5.md

    * Only wait for cache syncs once in NodeController ([#34851](https://github.com/kubernetes/kubernetes/pull/34851), [@ncdc](https://github.com/ncdc))
    * NodeController waits for informer sync before doing anything ([#34809](https://github.com/kubernetes/kubernetes/pull/34809), [@gmarek](https://github.com/gmarek))
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Dec 24 02:28:26 GMT 2020
    - 136.4K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

         *
         * @param fromIndex        the source index name
         * @param toIndex          the destination index name
         * @param waitForCompletion whether to wait for the operation to complete
         * @return true if the copy operation was successful, false otherwise
         */
        public boolean copyDocIndex(final String fromIndex, final String toIndex, final boolean waitForCompletion) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 138.6K bytes
    - Click Count (1)
  6. CHANGELOG/CHANGELOG-1.36.md

    - Adding multiple conditions support to kubectl wait command. ([#136855](https://github.com/kubernetes/kubernetes/pull/136855), [@ardaguclu](https://github.com/ardaguclu)) [SIG CLI and Testing]
    - Adds metrics for constrained impersonation as described in https://kep.k8s.io/5284
      
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Mar 19 23:38:00 GMT 2026
    - 142.1K bytes
    - Click Count (0)
  7. cmd/admin-handlers.go

    // - madmin.TraceInfo type is asked by opts
    func shouldTrace(trcInfo madmin.TraceInfo, opts madmin.ServiceTraceOpts) (shouldTrace bool) {
    	// Reject all unwanted types.
    	want := opts.TraceTypes()
    	if !want.Contains(trcInfo.TraceType) {
    		return false
    	}
    
    	isHTTP := trcInfo.TraceType.Overlaps(madmin.TraceInternal|madmin.TraceS3) && trcInfo.HTTP != nil
    
    	// Check latency...
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb1/smb1/SmbFile.java

                    try {
                        for (;;) {
                            notify();
                            ready = true;
                            while (ready) {
                                wait();
                            }
                            if (n == -1) {
                                return;
                            }
                            if (useNTSmbs) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 112.2K bytes
    - Click Count (0)
  9. cmd/site-replication.go

    				adminPathPrefix+adminAPIVersionPrefix+adminAPISiteReplicationNetPerf,
    				nil,
    			)
    			resultsMu.Lock()
    			results.NodeResults = append(results.NodeResults, result)
    			resultsMu.Unlock()
    		}()
    	}
    	wg.Wait()
    	return results, err
    }
    
    // GetClusterInfo - returns site replication information.
    func (c *SiteReplicationSys) GetClusterInfo(ctx context.Context) (info madmin.SiteReplicationInfo, err error) {
    	c.RLock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  10. cmd/bucket-replication.go

    			defer wg.Done()
    			tgtInfo := replicateDeleteToTarget(ctx, dobj, tgt)
    
    			mu.Lock()
    			rinfos.Targets = append(rinfos.Targets, tgtInfo)
    			mu.Unlock()
    		}(tgtClnt)
    	}
    	wg.Wait()
    
    	replicationStatus = rinfos.ReplicationStatus()
    	prevStatus := dobj.DeleteMarkerReplicationStatus()
    
    	if dobj.VersionID != "" {
    		prevStatus = replication.StatusType(dobj.VersionPurgeStatus())
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
Back to Top