Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 1,470 for statx (0.05 sec)

  1. pkg/bootstrap/instance_test.go

    	gsm := got.GetStatsConfig().GetStatsMatcher()
    
    	if stats.prefixes == "" {
    		stats.prefixes = v2Prefixes + requiredEnvoyStatsMatcherInclusionPrefixes + v2Suffix
    	} else {
    		stats.prefixes = v2Prefixes + stats.prefixes + "," + requiredEnvoyStatsMatcherInclusionPrefixes + v2Suffix
    	}
    	if stats.suffixes == "" {
    		stats.suffixes = rbacEnvoyStatsMatcherInclusionSuffix
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 17:05:28 UTC 2024
    - 19.5K bytes
    - Viewed (0)
  2. internal/grid/connection.go

    		}
    	}
    }
    
    // State returns the current connection status.
    func (c *Connection) State() State {
    	return State(atomic.LoadUint32((*uint32)(&c.state)))
    }
    
    // Stats returns the current connection stats.
    func (c *Connection) Stats() madmin.RPCMetrics {
    	conn := 0
    	if c.State() == StateConnected {
    		conn++
    	}
    	m := madmin.RPCMetrics{
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  3. src/runtime/mheap.go

    		gcController.heapReleased.add(-int64(scav))
    	}
    	// Update stats.
    	gcController.heapFree.add(-int64(nbytes - scav))
    	if typ == spanAllocHeap {
    		gcController.heapInUse.add(int64(nbytes))
    	}
    	// Update consistent stats.
    	stats := memstats.heapStats.acquire()
    	atomic.Xaddint64(&stats.committed, int64(scav))
    	atomic.Xaddint64(&stats.released, -int64(scav))
    	switch typ {
    	case spanAllocHeap:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 22:31:00 UTC 2024
    - 78K bytes
    - Viewed (0)
  4. cmd/metrics-v3-system-process.go

    )
    
    func loadProcStatMetrics(ctx context.Context, stat procfs.ProcStat, m MetricValues) {
    	if stat.CPUTime() > 0 {
    		m.Set(processCPUTotalSeconds, float64(stat.CPUTime()))
    	}
    
    	if stat.ResidentMemory() > 0 {
    		m.Set(processResidentMemoryBytes, float64(stat.ResidentMemory()))
    	}
    
    	if stat.VirtualMemory() > 0 {
    		m.Set(processVirtualMemoryBytes, float64(stat.VirtualMemory()))
    	}
    
    	startTime, err := stat.StartTime()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Apr 26 16:07:23 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  5. internal/event/targetlist.go

    	defer list.statLock.Unlock()
    
    	stats, ok := list.targetStats[id]
    	if !ok {
    		// should not happen
    		return
    	}
    
    	stats.currentSendCalls--
    	list.targetStats[id] = stats
    	return
    }
    
    func (list *TargetList) incFailedEvents(id TargetID) {
    	list.statLock.Lock()
    	defer list.statLock.Unlock()
    
    	stats, ok := list.targetStats[id]
    	if !ok {
    		stats = targetStat{}
    	}
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  6. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatalf("Expected object to be present but stat failed - %v", err)
    	}
    
    	// Check the state of the object in the first disk (should be missing)
    	if hr.Before.Drives[0].State != madmin.DriveStateMissing {
    		t.Fatalf("Unexpected drive state: %v", hr.Before.Drives[0].State)
    	}
    
    	// Check the state of all other disks (should be ok)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  7. cmd/metrics-v2.go

    						Value:       float64(s.ProxyStats.RmvTagFailedTotal),
    					})
    				}
    				if stats.hasReplicationUsage() {
    					for arn, stat := range stats.Stats {
    						metrics = append(metrics, MetricV2{
    							Description:    getRepFailedBytesLastMinuteMD(bucketMetricNamespace),
    							Value:          float64(stat.Failed.LastMinute.Bytes),
    							VariableLabels: map[string]string{"bucket": bucket, "targetArn": arn},
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:54 UTC 2024
    - 131.9K bytes
    - Viewed (0)
  8. pkg/kubelet/winstats/network_stats.go

    	}
    
    	return adapters
    }
    
    func (n *networkCounter) listInterfaceStats() []cadvisorapi.InterfaceStats {
    	stats := make([]cadvisorapi.InterfaceStats, 0, len(n.adapterStats))
    	for _, stat := range n.adapterStats {
    		stats = append(stats, stat)
    	}
    	return stats
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  9. pkg/kubelet/kubelet.go

    		const waitingReason = "Blocked"
    		for _, cs := range apiPodStatus.InitContainerStatuses {
    			if cs.State.Waiting != nil {
    				cs.State.Waiting.Reason = waitingReason
    			}
    		}
    		for _, cs := range apiPodStatus.ContainerStatuses {
    			if cs.State.Waiting != nil {
    				cs.State.Waiting.Reason = waitingReason
    			}
    		}
    	}
    
    	// Record the time it takes for the pod to become running
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
  10. cmd/metrics-v3-system-drive.go

    	driveRealtimeMetrics := collectLocalMetrics(types, collectMetricsOpts{
    		hosts: map[string]struct{}{
    			globalLocalNodeName: {},
    		},
    	})
    
    	stats := map[string]madmin.DiskIOStats{}
    	for d, m := range driveRealtimeMetrics.ByDisk {
    		stats[d] = m.IOStats
    	}
    	return stats
    }
    
    func (m *MetricValues) setDriveBasicMetrics(drive madmin.Disk, labels []string) {
    	m.Set(driveUsedBytes, float64(drive.UsedSpace), labels...)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun May 12 17:23:50 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top