Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 121 - 130 of 312 for margin (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. cmd/os-instrumented.go

    	atomic.AddUint64(&o.operations[s], 1)
    	o.latency[s].add(d)
    }
    
    func osTrace(s osMetric, startTime time.Time, duration time.Duration, path string, err error) madmin.TraceInfo {
    	var errStr string
    	if err != nil {
    		errStr = err.Error()
    	}
    	return madmin.TraceInfo{
    		TraceType: madmin.TraceOS,
    		Time:      startTime,
    		NodeName:  globalLocalNodeName,
    		FuncName:  "os." + s.String(),
    		Duration:  duration,
    		Path:      path,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 6.2K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/AtomicDouble.java

    /*
     * Written by Doug Lea and Martin Buchholz with assistance from
     * members of JCP JSR-166 Expert Group and released to the public
     * domain, as explained at
     * http://creativecommons.org/publicdomain/zero/1.0/
     */
    
    /*
     * Source:
     * http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/jsr166e/extra/AtomicDouble.java?revision=1.13
     * (Modified to adapt to guava coding conventions and
     * to use AtomicLong instead of sun.misc.Unsafe)
     */
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 7.2K bytes
    - Click Count (0)
  3. cmd/background-heal-ops.go

    // failure error occurred.
    func healDiskFormat(ctx context.Context, objAPI ObjectLayer, opts madmin.HealOpts) (madmin.HealResultItem, error) {
    	res, err := objAPI.HealFormat(ctx, opts.DryRun)
    
    	// return any error, ignore error returned when disks have
    	// already healed.
    	if err != nil && err != errNoHealRequired {
    		return madmin.HealResultItem{}, err
    	}
    
    	return res, nil
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  4. cmd/bucket-encryption-handlers.go

    	//
    	// We encode the xml bytes as base64 to ensure there are no encoding
    	// errors.
    	cfgStr := base64.StdEncoding.EncodeToString(configData)
    	replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{
    		Type:      madmin.SRBucketMetaTypeSSEConfig,
    		Bucket:    bucket,
    		SSEConfig: &cfgStr,
    		UpdatedAt: updatedAt,
    	}))
    
    	writeSuccessResponseHeadersOnly(w)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 6.4K bytes
    - Click Count (0)
  5. cmd/site-replication-metrics.go

    }
    
    func (rt *RTimedMetrics) toMetric() madmin.TimedErrStats {
    	if rt == nil {
    		return madmin.TimedErrStats{}
    	}
    	errCounts := make(map[string]int)
    	maps.Copy(errCounts, rt.ErrCounts)
    	minuteTotals := rt.LastMinute.getTotal()
    	hourTotals := rt.LastHour.getTotal()
    	return madmin.TimedErrStats{
    		LastMinute: madmin.RStat{
    			Count: float64(minuteTotals.N),
    			Bytes: minuteTotals.Size,
    		},
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  6. cmd/iam-store.go

    		matchedPolicies, _ := filterPolicies(cache, strings.Join(policies, ","), bucket)
    		if len(matchedPolicies) > 0 {
    			result[k] = madmin.UserInfo{
    				PolicyName: matchedPolicies,
    				Status: func() madmin.AccountStatus {
    					if c.IsValid() {
    						return madmin.AccountEnabled
    					}
    					return madmin.AccountDisabled
    				}(),
    				MemberOf: cache.iamUserGroupMemberships[k].ToSlice(),
    			}
    		}
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 87.1K bytes
    - Click Count (0)
  7. cmd/sts-handlers_test.go

    	}
    
    	// Validate that the client from sts creds can access the bucket.
    	c.mustListObjects(ctx, minioClient, bucket)
    
    	// Create an madmin client with user creds
    	userAdmClient, err := madmin.NewWithOptions(s.endpoint, &madmin.Options{
    		Creds:  cr.NewStaticV4(value.AccessKeyID, value.SecretAccessKey, value.SessionToken),
    		Secure: s.secure,
    	})
    	if err != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Oct 15 17:00:45 GMT 2025
    - 103.4K bytes
    - Click Count (1)
  8. cmd/object-api-interface.go

    	// Healing operations.
    	HealFormat(ctx context.Context, dryRun bool) (madmin.HealResultItem, error)
    	HealBucket(ctx context.Context, bucket string, opts madmin.HealOpts) (madmin.HealResultItem, error)
    	HealObject(ctx context.Context, bucket, object, versionID string, opts madmin.HealOpts) (madmin.HealResultItem, error)
    	HealObjects(ctx context.Context, bucket, prefix string, opts madmin.HealOpts, fn HealObjectFn) error
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 17.5K bytes
    - Click Count (0)
  9. doc/next/7-ports.md

    ## Ports {#ports}
    
    ### Darwin {#darwin}
    
    <!-- go.dev/issue/75836 -->
    As [announced](go1.26#darwin) in the Go 1.26 release notes,
    Go 1.27 requires macOS 13 Ventura or later;
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jan 26 21:07:04 GMT 2026
    - 226 bytes
    - Click Count (0)
  10. cmd/peer-s3-client.go

    			return madmin.HealResultItem{}, poolErr
    		}
    	}
    
    	if healBucketErr := reduceWriteQuorumErrs(ctx, errs, bucketOpIgnoredErrs, len(errs)/2+1); healBucketErr != nil {
    		return madmin.HealResultItem{}, toObjectErr(healBucketErr, bucket)
    	}
    
    	res := madmin.HealResultItem{
    		Type:     madmin.HealItemBucket,
    		Bucket:   bucket,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
Back to Top