Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 398 for timers (0.06 sec)

  1. guava/src/com/google/common/collect/Multiset.java

       * e]}.
       */
      @Override
      String toString();
    
      // Refined Collection Methods
    
      /**
       * {@inheritDoc}
       *
       * <p>Elements that occur multiple times in the multiset will appear multiple times in this
       * iterator, though not necessarily sequentially.
       */
      @Override
      Iterator<E> iterator();
    
      /**
       * Determines whether this multiset contains the specified element.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Jun 17 14:40:53 UTC 2023
    - 21K bytes
    - Viewed (0)
  2. cmd/server-rlimit.go

    			humanize.IBytes(vssLimit))
    	}
    
    	if ctx.MemLimit > 0 {
    		debug.SetMemoryLimit(int64(ctx.MemLimit))
    	}
    
    	// Do not use RLIMIT_AS as that is not useful and at times on systems < 4Gi
    	// this can crash the Go runtime if the value is smaller refer
    	// - https://github.com/golang/go/issues/38010
    	// - https://github.com/golang/go/issues/43699
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:09:36 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  3. android/guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java

      }
    
      /** Tests that the {@link Future#get(long, TimeUnit)} method times out correctly. */
      public void testTimeoutOnGetWorksCorrectly() throws InterruptedException, ExecutionException {
    
        // The task thread waits for the latch, so we expect a timeout here.
        try {
          future.get(20, MILLISECONDS);
          fail("Should have timed out trying to get the value.");
        } catch (TimeoutException expected) {
        } finally {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 18:30:30 UTC 2023
    - 6K bytes
    - Viewed (0)
  4. cmd/callhome.go

    				return
    			}
    
    			// callhome running on a different node.
    			// sleep for some time and try again.
    			duration := time.Duration(r.Float64() * float64(globalCallhomeConfig.FrequencyDur()))
    			if duration < time.Second {
    				// Make sure to sleep at least a second to avoid high CPU ticks.
    				duration = time.Second
    			}
    			time.Sleep(duration)
    		}
    	}()
    }
    
    func runCallhome(ctx context.Context, objAPI ObjectLayer) bool {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 17 16:53:34 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/crawler/client/storage/StorageClient.java

    import org.codelibs.core.io.CopyUtil;
    import org.codelibs.core.io.FileUtil;
    import org.codelibs.core.io.InputStreamUtil;
    import org.codelibs.core.lang.StringUtil;
    import org.codelibs.core.timer.TimeoutManager;
    import org.codelibs.core.timer.TimeoutTask;
    import org.codelibs.fess.crawler.Constants;
    import org.codelibs.fess.crawler.builder.RequestDataBuilder;
    import org.codelibs.fess.crawler.client.AbstractCrawlerClient;
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  6. cmd/bucket-targets.go

    	}
    	// reload healthCheck endpoints map periodically to remove stale endpoints from the map.
    	go func() {
    		rTimer := time.NewTimer(defaultHealthCheckReloadDuration)
    		defer rTimer.Stop()
    		for {
    			select {
    			case <-rTimer.C:
    				sys.reloadHealthCheckers(ctx)
    				rTimer.Reset(defaultHealthCheckReloadDuration)
    			case <-ctx.Done():
    				return
    			}
    		}
    	}()
    	go sys.heartBeat(ctx)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  7. cmd/erasure-healing-common_test.go

    // time occurrence from a list of time.
    func TestCommonTime(t *testing.T) {
    	// List of test cases for common modTime.
    	testCases := []struct {
    		times  []time.Time
    		time   time.Time
    		quorum int
    	}{
    		{
    			// 1. Tests common times when slice has varying time elements.
    			[]time.Time{
    				time.Unix(0, 1).UTC(),
    				time.Unix(0, 2).UTC(),
    				time.Unix(0, 3).UTC(),
    				time.Unix(0, 3).UTC(),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. src/main/webapp/WEB-INF/view/header.jsp

    					<c:if test="${eoled}">
    						<li class="nav-item" data-toggle="tooltip" data-placement="left" title="<la:message key="labels.eol_error" />">
    							<a class="nav-link active" href="${eolLink}" target="_olh"><em class="fas fa-times-circle text-danger"></a>
    						</li>
    					</c:if>
    					<c:if test="${developmentMode}">
    						<li class="nav-item" data-toggle="tooltip" data-placement="left"
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 24 03:00:28 UTC 2020
    - 4.2K bytes
    - Viewed (0)
  9. src/main/webapp/WEB-INF/orig/view/header.jsp

    					<c:if test="${eoled}">
    						<li class="nav-item" data-toggle="tooltip" data-placement="left" title="<la:message key="labels.eol_error" />">
    							<a class="nav-link active" href="${eolLink}" target="_olh"><em class="fas fa-times-circle text-danger"></a>
    						</li>
    					</c:if>
    					<c:if test="${developmentMode}">
    						<li class="nav-item" data-toggle="tooltip" data-placement="left"
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 24 03:00:28 UTC 2020
    - 4.2K bytes
    - Viewed (0)
  10. docs/bucket/lifecycle/DESIGN.md

    Transition tiers can be added to MinIO using `mc admin tier add` command to associate a `gcs`, `s3` or `azure` bucket or prefix path on a bucket to the tier name.
    Lifecycle transition rules can be applied to buckets (both versioned and un-versioned) by specifying the tier name defined above as the transition storage class for the lifecycle rule.
    
    ## Implementation
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 4.3K bytes
    - Viewed (0)
Back to top