- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 2,363 for statx (0.04 sec)
-
src/net/internal/socktest/switch.go
smu sync.RWMutex sotab Sockets stats stats } func (sw *Switch) init() { sw.fltab = make(map[FilterType]Filter) sw.sotab = make(Sockets) sw.stats = make(stats) } // Stats returns a list of per-cookie socket statistics. func (sw *Switch) Stats() []Stat { var st []Stat sw.smu.RLock() for _, s := range sw.stats { ns := *s st = append(st, ns) } sw.smu.RUnlock()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 4.8K bytes - Viewed (0) -
internal/disk/stat_linux.go
} // refer https://www.kernel.org/doc/Documentation/block/stat.txt iostats = IOStats{ ReadIOs: stats[0], ReadMerges: stats[1], ReadSectors: stats[2], ReadTicks: stats[3], WriteIOs: stats[4], WriteMerges: stats[5], WriteSectors: stats[6], WriteTicks: stats[7], CurrentIOs: stats[8], TotalTicks: stats[9], ReqTicks: stats[10], }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 26 19:34:50 UTC 2024 - 4.8K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/DaemonRegistryStateProbe.groovy
def stat = NativeServicesTestFixture.instance.get(Stat) assert stat.getUnixMode(registryFile) == 0600 // user read-write assert stat.getUnixMode(registryFile.parentFile) == 0700 // user read-write-execute } } @Override State getCurrentState() { def daemonInfo = registry.all.find { it.context.pid == context.pid }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.4K bytes - Viewed (0) -
cmd/metrics-v3-bucket-replication.go
if s, ok := bucketReplStats[bucket]; ok { stats := s.ReplicationStats if stats.hasReplicationUsage() { for arn, stat := range stats.Stats { m.Set(bucketReplLastHrFailedBytes, float64(stat.Failed.LastHour.Bytes), labels...) m.Set(bucketReplLastHrFailedCount, float64(stat.Failed.LastHour.Count), labels...) m.Set(bucketReplLastMinFailedBytes, float64(stat.Failed.LastMinute.Bytes), labels...)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 23 07:41:18 UTC 2024 - 8.1K bytes - Viewed (0) -
pilot/pkg/networking/core/networkfilter.go
func buildRedisFilter(statPrefix, clusterName string) *listener.Filter { redisProxy := &redis.RedisProxy{ LatencyInMicros: true, // redis latency stats are captured in micro seconds which is typically the case. StatPrefix: statPrefix, // redis stats are prefixed with redis.<statPrefix> by Envoy Settings: &redis.RedisProxy_ConnPoolSettings{ OpTimeout: durationpb.New(redisOpTimeout), },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.7K bytes - Viewed (0) -
src/internal/trace/summary.go
// Necessarily overlaps with other stats. TotalTime time.Duration // Total time the goroutine spent in certain ranges; may overlap // with other stats. RangeTime map[string]time.Duration } func (s GoroutineExecStats) NonOverlappingStats() map[string]time.Duration { stats := map[string]time.Duration{ "Execution time": s.ExecTime,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 20.7K bytes - Viewed (0) -
pkg/envoy/agent.go
activeConnectionsURL := fmt.Sprintf("http://%s/stats?usedonly&filter=downstream_cx_active$", adminHost) stats, err := http.DoHTTPGetWithTimeout(activeConnectionsURL, 2*time.Second) if err != nil { return -1, fmt.Errorf("unable to get listener stats from Envoy : %v", err) } if stats.Len() == 0 { return -1, nil } activeConnections := 0 for stats.Len() > 0 { line, _ := stats.ReadString('\n')
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/ready/probe.go
state, ws, err := util.GetReadinessStats(host, port) if err != nil { return fmt.Errorf("failed to get readiness stats: %v", err) } if state != nil && ServerInfoState(*state) != Live { return fmt.Errorf("server is not live, current state is: %v", StateString(ServerInfoState(*state))) } if !ws { return fmt.Errorf("workers have not yet started") } return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 00:35:05 UTC 2024 - 4.5K bytes - Viewed (0) -
src/runtime/mgcsweep.go
if sl.sweepGen != mheap_.sweepgen { throw("sweeper left outstanding across sweep generations") } for { state := a.state.Load() if (state&^sweepDrainedMask)-1 >= sweepDrainedMask { throw("mismatched begin/end of activeSweep") } if a.state.CompareAndSwap(state, state-1) { if state != sweepDrainedMask { return } if debug.gcpacertrace > 0 { live := gcController.heapLive.Load()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:52:18 UTC 2024 - 32.9K bytes - Viewed (0) -
pkg/kubelet/stats/cri_stats_provider_windows_test.go
eps := hcsshim.HNSEndpointStats{} for _, c := range s.containers { for _, stat := range c.hcsStats { if endpointName == stat.InstanceId { eps = hcsshim.HNSEndpointStats{ EndpointID: stat.EndpointId, BytesSent: stat.BytesSent, BytesReceived: stat.BytesReceived, PacketsReceived: stat.PacketsReceived, PacketsSent: stat.PacketsSent, } } } } return &eps, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Feb 17 00:02:10 UTC 2024 - 13.8K bytes - Viewed (0)