Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 146 for Append (4.02 sec)

  1. internal/hash/checksum.go

    	var tmp [binary.MaxVarintLen32]byte
    	n := binary.PutUvarint(tmp[:], uint64(c.Type))
    	crc := c.Raw
    	if len(crc) != c.Type.RawByteLen() {
    		return b
    	}
    	b = append(b, tmp[:n]...)
    	b = append(b, crc...)
    	if c.Type.Is(ChecksumMultipart) {
    		var checksums int
    		// Ensure we don't divide by 0:
    		if c.Type.RawByteLen() == 0 || len(parts)%c.Type.RawByteLen() != 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 11.9K bytes
    - Viewed (0)
  2. docs/debugging/xl-meta/main.go

    		var files []string
    
    		for _, pattern := range args {
    			if pattern == "-" {
    				files = append(files, pattern)
    				continue
    			}
    			found, err := filepathx.Glob(pattern)
    			if err != nil {
    				return err
    			}
    			if len(found) == 0 {
    				return fmt.Errorf("unable to find file %v", pattern)
    			}
    			files = append(files, found...)
    		}
    		if len(files) == 0 {
    			return fmt.Errorf("no files found")
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  3. cmd/erasure-server-pool.go

    	// Data blocks can vary per pool, but parity is same.
    	for i, setDriveCount := range z.SetDriveCounts() {
    		b.StandardSCData = append(b.StandardSCData, setDriveCount-scParity)
    		b.RRSCData = append(b.RRSCData, setDriveCount-rrSCParity)
    		b.DrivesPerSet = append(b.DrivesPerSet, setDriveCount)
    		b.TotalSets = append(b.TotalSets, z.serverPools[i].setCount)
    	}
    
    	b.StandardSCParity = scParity
    	b.RRSCParity = rrSCParity
    	return
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  4. cmd/bucket-targets.go

    	defer hcTimer.Stop()
    	for {
    		select {
    		case <-hcTimer.C:
    			sys.hMutex.RLock()
    			eps := make([]madmin.ServerProperties, 0, len(sys.hc))
    			for _, ep := range sys.hc {
    				eps = append(eps, madmin.ServerProperties{Endpoint: ep.Endpoint, Scheme: ep.Scheme})
    			}
    			sys.hMutex.RUnlock()
    
    			if len(eps) > 0 {
    				cctx, cancel := context.WithTimeout(ctx, 30*time.Second)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 20.9K bytes
    - Viewed (0)
  5. cmd/iam.go

    func (sys *IAMSys) printIAMRoles() {
    	if len(sys.rolesMap) == 0 {
    		return
    	}
    	var arns []string
    	for arn := range sys.rolesMap {
    		arns = append(arns, arn.String())
    	}
    	sort.Strings(arns)
    	msgs := make([]string, 0, len(arns))
    	for _, arn := range arns {
    		msgs = append(msgs, color.Bold(arn))
    	}
    
    	logger.Info(fmt.Sprintf("%s %s", color.Blue("IAM Roles:"), strings.Join(msgs, " ")))
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 21:28:16 GMT 2024
    - 71.1K bytes
    - Viewed (1)
  6. cmd/listen-notification-handlers.go

    		eventName, err := event.ParseName(s)
    		if err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    		mask.MergeMaskable(eventName)
    		eventNames = append(eventNames, eventName)
    	}
    
    	if bucketName != "" {
    		if _, err := objAPI.GetBucketInfo(ctx, bucketName, BucketOptions{}); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 6K bytes
    - Viewed (0)
  7. internal/logger/console.go

    		msg = ansiRE.ReplaceAllLiteralString(msg, "")
    		console.json(msg, args...)
    	case quietFlag:
    		if len(msg) != 0 && len(args) == 0 {
    			args = append(args, msg)
    			msg = "%s"
    		}
    		console.quiet(msg+"\n", args...)
    	default:
    		if len(msg) != 0 && len(args) == 0 {
    			args = append(args, msg)
    			msg = "%s"
    		}
    		console.pretty(msg+"\n", args...)
    	}
    }
    
    // Fatal prints only fatal error message with no stack trace
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:57:52 GMT 2024
    - 5.8K bytes
    - Viewed (0)
  8. internal/logger/config.go

    		for _, k := range envs {
    			target := strings.TrimPrefix(k, legacyEnvLoggerHTTPEndpoint+config.Default)
    			if target == legacyEnvLoggerHTTPEndpoint {
    				target = config.Default
    			}
    			loggerTargets = append(loggerTargets, target)
    		}
    
    		// Load HTTP logger from the environment if found
    		for _, target := range loggerTargets {
    			endpoint := getCfgVal(legacyEnvLoggerHTTPEndpoint, target, "")
    			if endpoint == "" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-rebalance.go

    	defer z.rebalMu.Unlock()
    
    	ps := z.rebalMeta.PoolStats[poolIdx]
    	if ps == nil {
    		return
    	}
    
    	for i, b := range ps.Buckets {
    		if b == bucket {
    			ps.Buckets = append(ps.Buckets[:i], ps.Buckets[i+1:]...)
    			ps.RebalancedBuckets = append(ps.RebalancedBuckets, bucket)
    			break
    		}
    	}
    }
    
    func (r *rebalanceMeta) load(ctx context.Context, store objectIO) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
  10. cmd/data-scanner_test.go

    	expired := make([]ObjectToDelete, 0, 5)
    	go func() {
    		defer wg.Done()
    		workers := globalExpiryState.workers.Load()
    		for t := range (*workers)[0] {
    			if t, ok := t.(newerNoncurrentTask); ok {
    				expired = append(expired, t.versions...)
    			}
    		}
    	}()
    	lc := lifecycle.Lifecycle{
    		Rules: []lifecycle.Rule{
    			{
    				ID:     "max-versions",
    				Status: "Enabled",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 6.9K bytes
    - Viewed (0)
Back to top