Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 251 for make (0.23 sec)

  1. cmd/peer-s3-client.go

    			return nil
    		}, idx)
    	}
    
    	errs := g.Wait()
    
    	// The list of buckets in a map to avoid duplication
    	resultMap := make(map[string]BucketInfo)
    
    	for poolIdx := 0; poolIdx < sys.poolsCount; poolIdx++ {
    		perPoolErrs := make([]error, 0, len(sys.peerClients))
    		for i, client := range sys.peerClients {
    			if slices.Contains(client.GetPools(), poolIdx) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.8K bytes
    - Viewed (0)
  2. callbacks/query.go

    				clauseSelect.Columns = make([]clause.Column, len(db.Statement.Schema.DBNames))
    				for idx, dbName := range db.Statement.Schema.DBNames {
    					clauseSelect.Columns[idx] = clause.Column{Table: db.Statement.Table, Name: dbName}
    				}
    			}
    
    			specifiedRelationsName := make(map[string]interface{})
    			for _, join := range db.Statement.Joins {
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Mon Jan 29 03:34:57 GMT 2024
    - 9.9K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    			Summary:      healNotStartedStatus,
    			HealSettings: hs,
    		},
    		traverseAndHealDoneCh: make(chan error),
    		cancelCtx:             cancel,
    		ctx:                   ctx,
    		scannedItemsMap:       make(map[madmin.HealItemType]int64),
    		healedItemsMap:        make(map[madmin.HealItemType]int64),
    		healFailedItemsMap:    make(map[string]int64),
    	}
    }
    
    // getScannedItemsCount - returns a count of all scanned items
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  4. 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()
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 13.4K bytes
    - Viewed (0)
  5. src/cmd/asm/internal/arch/arch.go

    	return false
    }
    
    func jumpWasm(word string) bool {
    	return word == "JMP" || word == "CALL" || word == "Call" || word == "Br" || word == "BrIf"
    }
    
    func archX86(linkArch *obj.LinkArch) *Arch {
    	register := make(map[string]int16)
    	// Create maps for easy lookup of instruction names etc.
    	for i, s := range x86.Register {
    		register[s] = int16(i + x86.REG_AL)
    	}
    	// Pseudo-registers.
    	register["SB"] = RSB
    Go
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Tue Mar 21 06:51:28 GMT 2023
    - 21.3K bytes
    - Viewed (0)
  6. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 21.1K bytes
    - Viewed (1)
  7. callbacks/associations.go

    								}
    							}
    						}
    					}
    				}
    
    				switch db.Statement.ReflectValue.Kind() {
    				case reflect.Slice, reflect.Array:
    					var (
    						rValLen   = db.Statement.ReflectValue.Len()
    						objs      = make([]reflect.Value, 0, rValLen)
    						fieldType = rel.Field.FieldType
    						isPtr     = fieldType.Kind() == reflect.Ptr
    					)
    
    					if !isPtr {
    						fieldType = reflect.PtrTo(fieldType)
    					}
    
    Go
    - Registered: Sun May 05 09:35:13 GMT 2024
    - Last Modified: Tue Apr 11 03:06:13 GMT 2023
    - 14.3K bytes
    - Viewed (0)
  8. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.9K bytes
    - Viewed (0)
  9. cmd/peer-rest-client.go

    	if !globalIsDistErasure {
    		// Only useful in distributed setups
    		return nil, nil
    	}
    
    	hosts := endpoints.hostsSorted()
    	remote = make([]*peerRESTClient, 0, len(hosts))
    	all = make([]*peerRESTClient, len(hosts))
    	for i, host := range hosts {
    		if host == nil {
    			continue
    		}
    		all[i] = newPeerRESTClient(host, endpoints.FindGridHostsFromPeer(host))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  10. 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 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
Back to top