Search Options

Results per page
Sort
Preferred Languages
Advance

Results 311 - 320 of 1,149 for Take (1.23 sec)

  1. cmd/format-erasure_test.go

    	formatHashes := make([]string, len(formats))
    	for i, format := range formats {
    		if format == nil {
    			continue
    		}
    		h := sha256.New()
    		for _, set := range format.Erasure.Sets {
    			for _, diskID := range set {
    				h.Write([]byte(diskID))
    			}
    		}
    		formatHashes[i] = hex.EncodeToString(h.Sum(nil))
    	}
    
    	formatCountMap := make(map[string]int)
    	for _, hash := range formatHashes {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  2. callbacks/preload.go

    		inlineConds      []interface{}
    	)
    
    	if rel.JoinTable != nil {
    		var (
    			joinForeignFields    = make([]*schema.Field, 0, len(rel.References))
    			joinRelForeignFields = make([]*schema.Field, 0, len(rel.References))
    			joinForeignKeys      = make([]string, 0, len(rel.References))
    		)
    
    		for _, ref := range rel.References {
    			if ref.OwnPrimaryKey {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun May 25 07:40:40 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  3. src/all.rc

    # Copyright 2012 The Go Authors. All rights reserved.
    # Use of this source code is governed by a BSD-style
    # license that can be found in the LICENSE file.
    
    rfork n
    
    if(! test -f make.rc){
    	echo 'all.rc must be run from $GOROOT/src' >[1=2]
    	exit wrongdir
    }
    
    . ./make.rc --no-banner $*
    bind -b $GOROOT/bin /bin
    ./run.rc --no-rebuild
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Tue Jun 10 13:00:41 UTC 2025
    - 391 bytes
    - Viewed (0)
  4. cmd/storage-rest-client.go

    		// transport is already down.
    		return "", errDiskNotFound
    	}
    
    	// This call should never be over the network, this is always
    	// a cached value - caller should make sure to use this
    	// function on a fresh disk or make sure to look at the error
    	// from a different networked call to validate the GetDiskID()
    	return *client.diskID.Load(), nil
    }
    
    func (client *storageRESTClient) SetDiskID(id string) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 08 02:38:41 UTC 2025
    - 30.4K bytes
    - Viewed (0)
  5. cmd/format-erasure.go

    	newFormats := make([][]*formatErasureV3, setCount)
    	for i := range refFormat.Erasure.Sets {
    		newFormats[i] = make([]*formatErasureV3, setDriveCount)
    	}
    	currentDisksInfo := make([][]DiskInfo, setCount)
    	for i := range refFormat.Erasure.Sets {
    		currentDisksInfo[i] = make([]DiskInfo, setDriveCount)
    	}
    	for i := range refFormat.Erasure.Sets {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 23.1K bytes
    - Viewed (0)
  6. cmd/bucket-replication-stats.go

    func (r *ReplicationStats) Get(bucket string) BucketReplicationStats {
    	if r == nil {
    		return BucketReplicationStats{Stats: make(map[string]*BucketReplicationStat)}
    	}
    
    	r.RLock()
    	defer r.RUnlock()
    
    	st, ok := r.Cache[bucket]
    	if !ok {
    		return BucketReplicationStats{Stats: make(map[string]*BucketReplicationStat)}
    	}
    	return st.Clone()
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  7. cmd/erasure-object.go

    	metadataArray := make([]*xlMetaV2, len(rawFileInfos))
    	metaFileInfos := make([]FileInfo, len(rawFileInfos))
    	metadataShallowVersions := make([][]xlMetaV2ShallowVersion, len(rawFileInfos))
    	var v2bufs [][]byte
    	if !readData {
    		v2bufs = make([][]byte, len(rawFileInfos))
    	}
    
    	// Read `xl.meta` in parallel across disks.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  8. cmd/grid.go

    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
    var globalLockGridStart = make(chan struct{})
    
    func initGlobalGrid(ctx context.Context, eps EndpointServerPools) error {
    	hosts, local := eps.GridHosts()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  9. cmd/erasure-decode_test.go

    	}
    
    	writers := make([]io.Writer, len(disks))
    	for i, disk := range disks {
    		if disk == nil {
    			continue
    		}
    		writers[i] = newBitrotWriter(disk, "", "testbucket", "object", erasure.ShardFileSize(size), DefaultBitrotAlgorithm, erasure.ShardSize())
    	}
    
    	content := make([]byte, size)
    	buffer := make([]byte, blockSizeV2, 2*blockSizeV2)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21K bytes
    - Viewed (0)
  10. scan.go

    				values[idx] = reflectValue.Addr().Interface()
    			} else {
    				values[idx] = reflectValue.Interface()
    			}
    		}
    	}
    
    	db.RowsAffected++
    	db.AddError(rows.Scan(values...))
    	joinedNestedSchemaMap := make(map[string]interface{})
    	for idx, field := range fields {
    		if field == nil {
    			continue
    		}
    
    		if len(joinFields) == 0 || len(joinFields[idx]) == 0 {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Sun May 25 07:40:40 UTC 2025
    - 10.4K bytes
    - Viewed (0)
Back to top