Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for srcEnd (0.04 sec)

  1. cmd/admin-handlers.go

    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.ServerInfoAdminAction)
    	if objectAPI == nil {
    		return
    	}
    	const defaultMetricsInterval = time.Second
    
    	interval, err := time.ParseDuration(r.Form.Get("interval"))
    	if err != nil || interval < time.Second {
    		interval = defaultMetricsInterval
    	}
    
    	n, err := strconv.Atoi(r.Form.Get("n"))
    	if err != nil || n <= 0 {
    		n = math.MaxInt32
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbFile.java

     * argument is used.
     *
     * <table border="1">
     * <caption>Examples Of SMB URLs When Augmented With A Second Constructor Parameter</caption>
     * <tr>
     * <td colspan="3">
     * <b>Examples Of SMB URLs When Augmented With A Second Constructor Parameter</b></td>
     * <tr><td >
     * <b>First Parameter</b></td><td><b>Second Parameter</b></td><td><b>Result</b></td></tr>
     *
     * <tr><td ><code>
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 112.2K bytes
    - Viewed (0)
  3. cmd/metrics-v2.go

    	mg := &MetricsGroupV2{
    		cacheInterval: 10 * time.Second,
    	}
    	mg.RegisterRead(func(ctx context.Context) []MetricV2 {
    		return getHistogramMetrics(bucketHTTPRequestsDuration,
    			getBucketTTFBDistributionMD(), true, true)
    	})
    	return mg
    }
    
    func getS3TTFBMetric() *MetricsGroupV2 {
    	mg := &MetricsGroupV2{
    		cacheInterval: 10 * time.Second,
    	}
    	mg.RegisterRead(func(ctx context.Context) []MetricV2 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  4. cmd/sts-handlers_test.go

    				runAllIAMSTSTests(testCase, &check{t, testCase.serverType})
    			},
    		)
    	}
    }
    
    func (s *TestSuiteIAM) TestSTSServiceAccountsWithUsername(c *check) {
    	ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    	defer cancel()
    
    	bucket := "dillon-bucket"
    	err := s.client.MakeBucket(ctx, bucket, minio.MakeBucketOptions{})
    	if err != nil {
    		c.Fatalf("bucket create error: %v", err)
    	}
    
    	// Create policy
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 100.2K bytes
    - Viewed (1)
  5. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       * ClosingFuture}s. Use {@link #whenAllSucceed(ClosingFuture, ClosingFuture)} to start this
       * combination.
       *
       * @param <V1> the type returned by the first future
       * @param <V2> the type returned by the second future
       */
      public static final class Combiner2<V1 extends @Nullable Object, V2 extends @Nullable Object>
          extends Combiner {
    
        /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ClosingFuture.java

       * ClosingFuture}s. Use {@link #whenAllSucceed(ClosingFuture, ClosingFuture)} to start this
       * combination.
       *
       * @param <V1> the type returned by the first future
       * @param <V2> the type returned by the second future
       */
      public static final class Combiner2<V1 extends @Nullable Object, V2 extends @Nullable Object>
          extends Combiner {
    
        /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  7. cmd/server_test.go

    	c.Assert(err, nil)
    	c.Assert(response.StatusCode, http.StatusOK)
    
    	objectName := "test-multipart-object"
    
    	// 1. Initiate 2 uploads for the same object
    	// 2. Upload 2 parts for the second upload
    	// 3. Abort the second upload.
    	// 4. Abort the first upload.
    	// This will test abort upload when there are more than one upload IDs
    	// and the case where there is only one upload ID.
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118.1K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb/SmbFile.java

     * argument is used.
     *
     * <table border="1">
     * <caption>Examples Of SMB URLs When Augmented With A Second Constructor Parameter</caption>
     * <tr >
     * <td colspan="3">
     * <b>Examples Of SMB URLs When Augmented With A Second Constructor Parameter</b></td>
     * <tr>
     * <td >
     * <b>First Parameter</b></td>
     * <td><b>Second Parameter</b></td>
     * <td><b>Result</b></td>
     * </tr>
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 103.2K bytes
    - Viewed (0)
  9. cmd/bucket-replication.go

    		if err := p.loadResync(ctx, buckets, objAPI); err == nil {
    			<-ctx.Done()
    			return
    		}
    		duration := max(time.Duration(r.Float64()*float64(time.Minute)),
    			// Make sure to sleep at least a second to avoid high CPU ticks.
    			time.Second)
    		time.Sleep(duration)
    	}
    }
    
    // Loads bucket replication resync statuses into memory.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

        // First CONNECT call needs a new connection.
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    
        // Second CONNECT call needs a new connection.
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
    
        // GET reuses the connection from the second connect.
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
      }
    
      @Test
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 146.6K bytes
    - Viewed (0)
Back to top