Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 76 for IsZero (0.31 sec)

  1. cmd/bucket-targets.go

    					sys.hMutex.RLock()
    					prev, ok := sys.hc[result.Endpoint.Host]
    					sys.hMutex.RUnlock()
    					if ok {
    						if prev.Online != result.Online || !result.Online {
    							if !prev.lastHCAt.IsZero() {
    								offline = time.Since(prev.lastHCAt) + prev.offlineDuration
    							} else {
    								offline = prev.offlineDuration
    							}
    						} else if result.Online {
    							offline = prev.offlineDuration
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 20.9K bytes
    - Viewed (0)
  2. cmd/object-api-datatypes.go

    	DataBlocks   int
    	ParityBlocks int
    }
    
    // ExpiresStr returns a stringified version of Expires header in http.TimeFormat
    func (o ObjectInfo) ExpiresStr() string {
    	var expires string
    	if !o.Expires.IsZero() {
    		expires = o.Expires.UTC().Format(http.TimeFormat)
    	}
    	return expires
    }
    
    // ArchiveInfo returns any saved zip archive meta information.
    // It will be decrypted if needed.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.2K bytes
    - Viewed (0)
  3. cmd/handler-utils.go

    		bucket, _ := path2BucketObject(resource)
    
    		meta, err := globalBucketMetadataSys.Get(bucket) // check if this bucket exists.
    		countBktStat := bucket != "" && bucket != minioReservedBucket && err == nil && !meta.Created.IsZero()
    		if countBktStat {
    			globalBucketHTTPStats.updateHTTPStats(bucket, api, nil)
    		}
    
    		globalHTTPStats.currentS3Requests.Inc(api)
    		f.ServeHTTP(w, r)
    		globalHTTPStats.currentS3Requests.Dec(api)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 16.3K bytes
    - Viewed (1)
  4. cmd/erasure-object.go

    	// in all other cases mtime is latest.
    
    	fi.VersionID = versionID // set any new versionID we might have created
    	fi.ModTime = modTime     // set modTime for the new versionID
    	if !dstOpts.MTime.IsZero() {
    		modTime = dstOpts.MTime
    		fi.ModTime = dstOpts.MTime
    	}
    	// check inline before overwriting metadata.
    	inlineData := fi.InlineData()
    
    	fi.Metadata = srcInfo.UserDefined
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  5. cmd/bucket-replication-metrics.go

    	// Calculate aggregate avg bandwidth and exp window avg
    	m.lock.Lock()
    	defer func() {
    		m.startTime = endTime
    		m.lock.Unlock()
    	}()
    
    	if m.startTime.IsZero() {
    		return
    	}
    
    	if endTime.Before(m.startTime) {
    		return
    	}
    
    	duration := endTime.Sub(m.startTime)
    
    	bytesSinceLastWindow := atomic.SwapUint64(&m.bytesSinceLastWindow, 0)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  6. cmd/admin-handlers.go

    	if objectAPI == nil {
    		return
    	}
    
    	if globalInplaceUpdateDisabled {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrMethodNotAllowed), r.URL)
    		return
    	}
    
    	if currentReleaseTime.IsZero() || currentReleaseTime.Equal(timeSentinel) {
    		apiErr := errorCodes.ToAPIErr(ErrMethodNotAllowed)
    		apiErr.Description = fmt.Sprintf("unable to perform in-place update, release time is unrecognized: %s", currentReleaseTime)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  7. cmd/admin-handlers-users.go

    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	var expiration *time.Time
    	if !svcAccount.Expiration.IsZero() && !svcAccount.Expiration.Equal(timeSentinel) {
    		expiration = &svcAccount.Expiration
    	}
    
    	infoResp := madmin.InfoServiceAccountResp{
    		ParentUser:    svcAccount.ParentUser,
    		Name:          svcAccount.Name,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 90.6K bytes
    - Viewed (0)
  8. cmd/erasure-healing-common_test.go

    	var count int
    	var latestFileInfo FileInfo
    
    	// Reduce list of UUIDs to a single common value - i.e. the last updated Time
    	modTime := commonTime(modTimes, expectedRQuorum)
    
    	if modTime.IsZero() || modTime.Equal(timeSentinel) {
    		return FileInfo{}, errErasureReadQuorum
    	}
    
    	// Iterate through all the modTimes and count the FileInfo(s) with latest time.
    	for index, t := range modTimes {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  9. cmd/bucket-replication-utils.go

    			// return REPLICA status if replica received timestamp is later than replication timestamp
    			// provided object replication completed for all targets.
    			if rs.ReplicaTimeStamp.Equal(timeSentinel) || rs.ReplicaTimeStamp.IsZero() {
    				return replStatus
    			}
    			if replStatus == replication.Completed && rs.ReplicaTimeStamp.After(rs.ReplicationTimeStamp) {
    				return rs.ReplicaStatus
    			}
    			return replStatus
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26K bytes
    - Viewed (0)
  10. cmd/erasure-metadata.go

    		if props, ok := otherPropsMap.GetValueWithQuorum(quorum); ok {
    			candidate.SuccessorModTime = props.succModTime
    			candidate.IsLatest = props.succModTime.IsZero()
    			candidate.NumVersions = props.numVersions
    		}
    		return candidate, nil
    	}
    	return FileInfo{}, InsufficientReadQuorum{Err: errErasureReadQuorum, Type: RQInconsistentMeta}
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 21.3K bytes
    - Viewed (0)
Back to top