Search Options

Results per page
Sort
Preferred Languages
Advance

Results 361 - 370 of 833 for Pool (0.11 sec)

  1. tests/update_test.go

    	sort.Slice(result.Pets, func(i, j int) bool {
    		return result.Pets[i].ID < result.Pets[j].ID
    	})
    	sort.Slice(result.Team, func(i, j int) bool {
    		return result.Team[i].ID < result.Team[j].ID
    	})
    	sort.Slice(result.Friends, func(i, j int) bool {
    		return result.Friends[i].ID < result.Friends[j].ID
    	})
    	sort.Slice(result2.Pets, func(i, j int) bool {
    		return result2.Pets[i].ID < result2.Pets[j].ID
    	})
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Mon Jul 21 02:46:58 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  2. cmd/namespace-lock.go

    type nsLockMap struct {
    	// Indicates if namespace is part of a distributed setup.
    	isDistErasure bool
    	lockMap       map[string]*nsLock
    	lockMapMutex  sync.Mutex
    }
    
    // Lock the namespace resource.
    func (n *nsLockMap) lock(ctx context.Context, volume string, path string, lockSource, opsID string, readLock bool, timeout time.Duration) (locked bool) {
    	resource := pathJoin(volume, path)
    
    	n.lockMapMutex.Lock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    	healLocalDisks map[Endpoint]bool
    	healStatus     map[string]healingTracker // Indexed by disk ID
    }
    
    // newHealState - initialize global heal state management
    func newHealState(ctx context.Context, cleanup bool) *allHealState {
    	hstate := &allHealState{
    		healSeqMap:     make(map[string]*healSequence),
    		healLocalDisks: make(map[Endpoint]bool),
    		healStatus:     make(map[string]healingTracker),
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  4. cmd/encryption-v1_test.go

    		},
    		metadata: map[string]string{
    			xhttp.AmzServerSideEncryptionCustomerKey: "XAm0dRrJsEsyPb1UuFNezv1bl9hxuYsgUVC/MUctE2k=",
    		},
    	},
    }
    
    func TestEncryptRequest(t *testing.T) {
    	defer func(flag bool) { globalIsTLS = flag }(globalIsTLS)
    	globalIsTLS = true
    	for i, test := range encryptRequestTests {
    		content := bytes.NewReader(make([]byte, 64))
    		req := &http.Request{Header: http.Header{}}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 19.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. src/cmd/addr2line/addr2line_test.go

    	os.Setenv("GO_ADDR2LINETEST_IS_ADDR2LINE", "1") // Set for subprocesses to inherit.
    	os.Exit(m.Run())
    }
    
    func loadSyms(t *testing.T, dbgExePath string) map[string]string {
    	cmd := testenv.Command(t, testenv.GoToolPath(t), "tool", "nm", dbgExePath)
    	out, err := cmd.CombinedOutput()
    	if err != nil {
    		t.Fatalf("%v: %v\n%s", cmd, err, string(out))
    	}
    	syms := make(map[string]string)
    	scanner := bufio.NewScanner(bytes.NewReader(out))
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Sep 06 13:23:48 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top