Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 808 for pool (0.15 sec)

  1. cmd/bucket-lifecycle_test.go

    		}
    	}
    }
    
    // TestRestoreObjOnDisk tests restoreObjStatus' OnDisk method
    func TestRestoreObjOnDisk(t *testing.T) {
    	testCases := []struct {
    		restoreStatus restoreObjStatus
    		ondisk        bool
    	}{
    		{
    			// restore in progress
    			restoreStatus: ongoingRestoreObj(),
    			ondisk:        false,
    		},
    		{
    			// restore completed but expired
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 31 09:57:57 UTC 2022
    - 7K bytes
    - Viewed (0)
  2. callbacks/callbacks.go

    	deleteClauses = []string{"DELETE", "FROM", "WHERE"}
    )
    
    type Config struct {
    	LastInsertIDReversed bool
    	CreateClauses        []string
    	QueryClauses         []string
    	UpdateClauses        []string
    	DeleteClauses        []string
    }
    
    func RegisterDefaultCallbacks(db *gorm.DB, config *Config) {
    	enableTransaction := func(db *gorm.DB) bool {
    		return !db.SkipDefaultTransaction
    	}
    
    	if len(config.CreateClauses) == 0 {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Wed Oct 27 23:56:55 UTC 2021
    - 3.3K bytes
    - Viewed (0)
  3. cmd/generic-handlers.go

    }
    
    // Check to allow access to the reserved "bucket" `/minio` for Admin
    // API requests.
    func isAdminReq(r *http.Request) bool {
    	return strings.HasPrefix(r.URL.Path, adminPathPrefix)
    }
    
    // Check to allow access to the reserved "bucket" `/minio` for KMS
    // API requests.
    func isKMSReq(r *http.Request) bool {
    	return strings.HasPrefix(r.URL.Path, kmsPathPrefix)
    }
    
    // Supported Amz date headers.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.7K bytes
    - Viewed (1)
  4. src/bufio/scan.go

    	end          int       // End of data in buf.
    	err          error     // Sticky error.
    	empties      int       // Count of successive empty tokens.
    	scanCalled   bool      // Scan has been called; buffer is in use.
    	done         bool      // Scan has finished.
    }
    
    // SplitFunc is the signature of the split function used to tokenize the
    // input. The arguments are an initial substring of the remaining unprocessed
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Wed May 21 18:05:26 UTC 2025
    - 14.2K bytes
    - Viewed (0)
  5. cmd/net_test.go

    		case testCase.expectedErr.Error() != err.Error():
    			t.Fatalf("error: expected = %v, got = %v", testCase.expectedErr, err)
    		}
    
    		if testCase.expectedIPList != nil {
    			var found bool
    			for _, ip := range ipList.ToSlice() {
    				if testCase.expectedIPList.Contains(ip) {
    					found = true
    				}
    			}
    			if !found {
    				t.Fatalf("host: expected = %v, got = %v", testCase.expectedIPList, ipList)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  6. cmd/object-handlers-common_test.go

    	testCases := []struct {
    		name              string
    		ifMatch           string
    		ifNoneMatch       string
    		ifModifiedSince   string
    		ifUnmodifiedSince string
    		objInfo           ObjectInfo
    		expectedFlag      bool
    		expectedCode      int
    	}{
    		// If-None-Match(false) and If-Modified-Since(true)
    		{
    			name:            "If-None-Match1",
    			ifNoneMatch:     "aa",
    			ifModifiedSince: "Sun, 26 Aug 2024 02:01:00 GMT",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/ForwardingBlockingDeque.java

      }
    
      @Override
      public E take() throws InterruptedException {
        return delegate().take();
      }
    
      @Override
      public @Nullable E poll(long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().poll(timeout, unit);
      }
    
      @Override
      public int drainTo(Collection<? super E> c) {
        return delegate().drainTo(c);
      }
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. cmd/bucket-lifecycle-handlers_test.go

    		accessKey  string
    		secretKey  string
    		// Sent body
    		body []byte
    		// Expected response
    		expectedRespStatus int
    		lifecycleResponse  []byte
    		errorResponse      APIErrorResponse
    		shouldPass         bool
    	}{
    		// GET empty credentials
    		{
    			method: http.MethodGet, bucketName: bucketName,
    			accessKey:          "",
    			secretKey:          "",
    			expectedRespStatus: http.StatusForbidden,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 11.3K bytes
    - Viewed (0)
  9. cmd/object-api-utils_test.go

    		}
    	}
    }
    
    // Tests isCompressed method
    func TestIsCompressed(t *testing.T) {
    	testCases := []struct {
    		objInfo ObjectInfo
    		result  bool
    		err     bool
    	}{
    		0: {
    			objInfo: ObjectInfo{
    				UserDefined: map[string]string{
    					"X-Minio-Internal-compression": compressionAlgorithmV1,
    					"content-type":                 "application/octet-stream",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 24.1K bytes
    - Viewed (0)
  10. src/cmd/api/testdata/src/pkg/p3/golden.txt

    pkg p3, func BadHop(int, int, int) (bool, bool, *ThirdBase, *ThirdBase, error)
    pkg p3, method (*ThirdBase) GoodPlayer() (int, int, int)
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jan 29 00:45:45 UTC 2013
    - 166 bytes
    - Viewed (0)
Back to top