Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 901 - 910 of 1,116 for was (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/batch-rotate.go

    	batchKeyRotateAPIVersion           = "v1"
    	batchKeyRotateJobDefaultRetries    = 3
    	batchKeyRotateJobDefaultRetryDelay = 25 * time.Millisecond
    )
    
    // Start the batch key rottion job, resumes if there was a pending job via "job.ID"
    func (r *BatchJobKeyRotateV1) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error {
    	ri := &batchJobInfo{
    		JobID:     job.ID,
    		JobType:   string(job.Type()),
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.7K bytes
    - Click Count (0)
  2. cmd/bucket-replication-metrics.go

    // rateMeasurement captures the transfer details for one bucket/target
    //msgp:ignore rateMeasurement
    
    type rateMeasurement struct {
    	lock                 sync.Mutex
    	bytesSinceLastWindow uint64    // Total bytes since last window was processed
    	startTime            time.Time // Start time for window
    	expMovingAvg         float64   // Previously calculated exponential moving average
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Aug 15 12:04:40 GMT 2024
    - 14.2K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        )
      }
    
      /**
       * We've had bugs where caching and cross-protocol redirects yield class cast exceptions internal
       * to the cache because we incorrectly assumed that HttpsURLConnection was always HTTPS and
       * HttpURLConnection was always HTTP; in practice redirects mean that each can do either.
       *
       * https://github.com/square/okhttp/issues/214
       */
      @Test
      fun secureResponseCachingAndProtocolRedirects() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 121K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/base/Suppliers.java

          return uncheckedCastNullableTToT(value);
        }
    
        @Override
        public String toString() {
          // This is a little strange if the unit the user provided was not NANOS,
          // but we don't want to store the unit just for toString
          return "Suppliers.memoizeWithExpiration(" + delegate + ", " + durationNanos + ", NANOS)";
        }
    
        @GwtIncompatible
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 31 21:24:28 GMT 2026
    - 16.1K bytes
    - Click Count (0)
  5. src/test/java/jcifs/dcerpc/rpcTest.java

                assertThrows(Exception.class, () -> {
                    unicodeString.encode(mockNdrBuffer);
                }, "Should encounter issue with deferred buffer access");
    
                // Verify that basic encoding was attempted
                verify(mockNdrBuffer).align(4);
                verify(mockNdrBuffer).enc_ndr_short((short) 6);
                verify(mockNdrBuffer).enc_ndr_short((short) 10);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  6. src/test/java/jcifs/internal/smb2/session/Smb2SessionSetupRequestTest.java

            byte[] buffer = new byte[512];
            int headerStart = 50;
    
            // Encode the full message to set headerStart
            request.encode(buffer, headerStart);
    
            // Then - verify the body was written correctly
            int bodyOffset = headerStart + Smb2Constants.SMB2_HEADER_LENGTH;
    
            // Verify structure size (25)
            assertEquals(25, SMBUtil.readInt2(buffer, bodyOffset));
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 21.2K bytes
    - Click Count (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

                } catch (ArtifactNotFoundException anfe) {
                    // These are cases where the artifact just isn't present in any of the remote repositories
                    // because it wasn't deployed, or it was deployed in the wrong place.
    
                    synchronized (result) {
                        result.addMissingArtifact(artifact);
                    }
                } catch (ArtifactResolutionException e) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 25K bytes
    - Click Count (0)
  8. cmd/admin-handlers-config-kv.go

    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    	globalNotificationSys.SignalConfigReload(subSys)
    	// Tell the client that dynamic config was applied.
    	w.Header().Set(madmin.ConfigAppliedHeader, madmin.ConfigAppliedTrue)
    }
    
    type badConfigErr struct {
    	Err error
    }
    
    // Error - return the error message
    func (bce badConfigErr) Error() string {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.8K bytes
    - Click Count (1)
  9. cmd/signature-v4-utils_test.go

    		expectedResult bool
    	}{
    		{"", "", true},
    		{globalMinioDefaultRegion, "", true},
    		{globalMinioDefaultRegion, "US", true},
    		{"us-west-1", "US", false},
    		{"us-west-1", "us-west-1", true},
    		// "US" was old naming convention for 'us-east-1'.
    		{"US", "US", true},
    	}
    
    	for i, testCase := range testCases {
    		actualResult := isValidRegion(testCase.inputReqRegion, testCase.inputConfRegion)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Apr 09 14:28:39 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  10. tensorflow/c/eager/c_api_cluster_test.cc

      int num_retvals = 0;
      TFE_Execute(op, nullptr, &num_retvals, status);
      ASSERT_EQ(TF_OK, TF_GetCode(status)) << TF_Message(status);
      TFE_DeleteOp(op);
    
      // The device of var_handle1 is remote device, which was replaced during
      // cluster update. Removing resource with invalid device should fail
      // gracefully (i.e., with error status) instead of crashing with segfaults.
      op = TFE_NewOp(ctx, "DestroyResourceOp", status);
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Thu Oct 09 05:56:18 GMT 2025
    - 19.2K bytes
    - Click Count (0)
Back to Top