Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 76 for IsZero (0.04 sec)

  1. utils/utils.go

    		case []byte:
    			results[idx] = string(v)
    		case uint:
    			results[idx] = strconv.FormatUint(uint64(v), 10)
    		default:
    			results[idx] = "nil"
    			vv := reflect.ValueOf(v)
    			if vv.IsValid() && !vv.IsZero() {
    				results[idx] = fmt.Sprint(reflect.Indirect(vv).Interface())
    			}
    		}
    	}
    
    	return strings.Join(results, "_")
    }
    
    func Contains(elems []string, elem string) bool {
    	for _, e := range elems {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Aug 22 11:03:42 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    	healBuckets := make([]string, len(buckets))
    	copy(healBuckets, buckets)
    
    	objAPI := newObjectLayerFn()
    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    	started := tracker.Started
    	if started.IsZero() || started.Equal(timeSentinel) {
    		healingLogIf(ctx, fmt.Errorf("unexpected tracker healing start time found: %v", started))
    		started = time.Time{}
    	}
    
    	// Final tracer update before quitting
    	defer func() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  3. cmd/metrics.go

    	bgSeq, exists := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    	if !exists {
    		return
    	}
    
    	var dur time.Duration
    	if !bgSeq.lastHealActivity.IsZero() {
    		dur = time.Since(bgSeq.lastHealActivity)
    	}
    
    	ch <- prometheus.MustNewConstMetric(
    		prometheus.NewDesc(
    			prometheus.BuildFQName(healMetricsNamespace, "time", "since_last_activity"),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  4. docs/debugging/s3-check-md5/main.go

    		for object := range s3Client.ListObjects(context.Background(), bucket, opts) {
    			if object.Err != nil {
    				log.Println("FAILED: LIST with error:", object.Err)
    				continue
    			}
    			if !minModTime.IsZero() && object.LastModified.Before(minModTime) {
    				continue
    			}
    			if object.IsDeleteMarker {
    				log.Println("SKIPPED: DELETE marker object:", objFullPath(object))
    				continue
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Feb 17 01:15:57 UTC 2024
    - 6.3K bytes
    - Viewed (0)
  5. cmd/event-notification.go

    }
    
    // ToEvent - converts to notification event.
    func (args eventArgs) ToEvent(escape bool) event.Event {
    	eventTime := UTCNow()
    	uniqueID := fmt.Sprintf("%X", eventTime.UnixNano())
    	if !args.Object.ModTime.IsZero() {
    		uniqueID = fmt.Sprintf("%X", args.Object.ModTime.UnixNano())
    	}
    
    	respElements := map[string]string{
    		"x-amz-request-id": args.RespElements["requestId"],
    		"x-amz-id-2":       args.RespElements["nodeId"],
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 21 22:22:24 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  6. cmd/batch-rotate.go

    			return false
    		}
    
    		if !r.Flags.Filter.CreatedAfter.IsZero() && r.Flags.Filter.CreatedAfter.Before(info.ModTime) {
    			// skip all objects that are created before the specified time.
    			return false
    		}
    
    		if !r.Flags.Filter.CreatedBefore.IsZero() && r.Flags.Filter.CreatedBefore.After(info.ModTime) {
    			// skip all objects that are created after the specified time.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  7. cmd/erasure-server-pool-rebalance.go

    	_ = z.loadRebalanceMeta(ctx)
    	z.rebalMu.RLock()
    	defer z.rebalMu.RUnlock()
    
    	r := z.rebalMeta
    	if r == nil {
    		return false
    	}
    	if !r.StoppedAt.IsZero() {
    		return false
    	}
    	for _, ps := range r.PoolStats {
    		if ps.Participating && ps.Info.Status != rebalCompleted {
    			return true
    		}
    	}
    	return false
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  8. cmd/metrics-v3-system-process.go

    func loadProcessMetrics(ctx context.Context, m MetricValues, c *metricsCache) error {
    	m.Set(processGoRoutineTotal, float64(runtime.NumGoroutine()))
    
    	if !globalBootTime.IsZero() {
    		m.Set(processUptimeSeconds, time.Since(globalBootTime).Seconds())
    	}
    
    	if runtime.GOOS != globalWindowsOSName && runtime.GOOS != globalMacOSName {
    		p, err := procfs.Self()
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Jun 20 17:55:03 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  9. cmd/metacache.go

    	fileNotFound bool       `msg:"fnf"`
    	status       scanStatus `msg:"stat"`
    	recursive    bool       `msg:"rec"`
    	dataVersion  uint8      `msg:"v"`
    }
    
    func (m *metacache) finished() bool {
    	return !m.ended.IsZero()
    }
    
    // worthKeeping indicates if the cache by itself is worth keeping.
    func (m *metacache) worthKeeping() bool {
    	if m == nil {
    		return false
    	}
    	cache := m
    	switch {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 6K bytes
    - Viewed (0)
  10. src/archive/tar/writer.go

    	var spd sparseDatas
    	var spb []byte
    	blk := tw.templateV7Plus(hdr, f.formatString, f.formatNumeric)
    	if !hdr.AccessTime.IsZero() {
    		f.formatNumeric(blk.toGNU().accessTime(), hdr.AccessTime.Unix())
    	}
    	if !hdr.ChangeTime.IsZero() {
    		f.formatNumeric(blk.toGNU().changeTime(), hdr.ChangeTime.Unix())
    	}
    	// TODO(dsnet): Re-enable this when adding sparse support.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Mon Feb 03 16:38:43 UTC 2025
    - 19.7K bytes
    - Viewed (0)
Back to top