Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 643 for setEnd (0.08 sec)

  1. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       * second" (commonly referred to as <i>QPS</i>, queries per second).
       *
       * <p>The returned {@code RateLimiter} ensures that on average no more than {@code
       * permitsPerSecond} are issued during any given second, with sustained requests being smoothly
       * spread over each second. When the incoming request rate exceeds {@code permitsPerSecond} the
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  2. cmd/callhome.go

    			// 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)
  3. guava-tests/test/com/google/common/collect/TreeMultimapExplicitTest.java

        public int compare(@Nullable String first, @Nullable String second) {
          if (first == second) {
            return 0;
          } else if (first == null) {
            return -1;
          } else if (second == null) {
            return 1;
          } else if (first.length() != second.length()) {
            return first.length() - second.length();
          } else {
            return first.compareTo(second);
          }
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  4. internal/s3select/sql/timestampfuncs.go

    // timestamp as used in S3 Select
    func FormatSQLTimestamp(t time.Time) string {
    	_, zoneOffset := t.Zone()
    	hasZone := zoneOffset != 0
    	hasFracSecond := t.Nanosecond() != 0
    	hasSecond := t.Second() != 0
    	hasTime := t.Hour() != 0 || t.Minute() != 0
    	hasDay := t.Day() != 1
    	hasMonth := t.Month() != 1
    
    	switch {
    	case hasFracSecond:
    		return t.Format(layoutNanosecond)
    	case hasSecond:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.8K bytes
    - Viewed (0)
  5. internal/http/transports.go

    		WriteBufferSize:       WriteBufferSize,
    		ReadBufferSize:        ReadBufferSize,
    		IdleConnTimeout:       15 * time.Second,
    		ResponseHeaderTimeout: 15 * time.Minute, // Conservative timeout is the default (for MinIO internode)
    		TLSHandshakeTimeout:   10 * time.Second,
    		TLSClientConfig:       &tlsClientConfig,
    		ForceAttemptHTTP2:     s.EnableHTTP2,
    		// Go net/http automatically unzip if content-type is
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6K bytes
    - Viewed (0)
  6. internal/config/dns/operator_dns.go

    		Transport: &http.Transport{
    			Proxy: http.ProxyFromEnvironment,
    			DialContext: (&net.Dialer{
    				Timeout:   3 * time.Second,
    				KeepAlive: 5 * time.Second,
    			}).DialContext,
    			ResponseHeaderTimeout: 3 * time.Second,
    			TLSHandshakeTimeout:   3 * time.Second,
    			ExpectContinueTimeout: 3 * time.Second,
    			TLSClientConfig: &tls.Config{
    				RootCAs: args.rootCAs,
    			},
    			// Go net/http automatically unzip if content-type is
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Mar 06 16:56:10 UTC 2023
    - 6.6K bytes
    - Viewed (0)
  7. internal/s3select/select_test.go

    	input := `{"id": 0,"title": "Test Record","desc": "Some text","synonyms": ["foo", "bar", "whatever"]}
    	{"id": 1,"title": "Second Record","desc": "another text","synonyms": ["some", "synonym", "value"]}
    	{"id": 2,"title": "Second Record","desc": "another text","numbers": [2, 3.0, 4]}
    	{"id": 3,"title": "Second Record","desc": "another text","nested": [[2, 3.0, 4], [7, 8.5, 9]]}`
    
    	testTable := []struct {
    		name       string
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 23 07:19:11 UTC 2023
    - 76.2K bytes
    - Viewed (0)
  8. utils/tests/utils.go

    		isEqual := func() {
    			if curTime, ok := got.(time.Time); ok {
    				format := "2006-01-02T15:04:05Z07:00"
    
    				if curTime.Round(time.Second).UTC().Format(format) != expect.(time.Time).Round(time.Second).UTC().Format(format) && curTime.Truncate(time.Second).UTC().Format(format) != expect.(time.Time).Truncate(time.Second).UTC().Format(format) {
    					t.Errorf("%v: expect: %v, got %v after time round", utils.FileWithLineNum(), expect.(time.Time), curTime)
    				}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Mar 10 09:21:56 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  9. internal/config/subnet/config.go

    func (c *Config) ApplyEnv() {
    	configLock.RLock()
    	defer configLock.RUnlock()
    
    	if c.License != "" {
    		os.Setenv("CONSOLE_SUBNET_LICENSE", c.License)
    	}
    	if c.APIKey != "" {
    		os.Setenv("CONSOLE_SUBNET_API_KEY", c.APIKey)
    	}
    	if c.Proxy != "" {
    		os.Setenv("CONSOLE_SUBNET_PROXY", c.Proxy)
    	}
    	os.Setenv("CONSOLE_SUBNET_URL", c.BaseURL)
    }
    
    // Update - in-place update with new license and registration information.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        lock2 = factory2.newReentrantLock(MyOrder.SECOND);
        lock3 = factory2.newReentrantLock(MyOrder.THIRD);
    
        CycleDetectingLockFactory.WithExplicitOrdering<OtherOrder> factory3 =
            newInstanceWithExplicitOrdering(OtherOrder.class, Policies.THROW);
        lock01 = factory3.newReentrantLock(OtherOrder.FIRST);
        lock02 = factory3.newReentrantLock(OtherOrder.SECOND);
        lock03 = factory3.newReentrantLock(OtherOrder.THIRD);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.1K bytes
    - Viewed (0)
Back to top