- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 271 for statx (0.06 sec)
-
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) -
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) -
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) -
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) -
pkg/kubelet/kubelet_test.go
State: kubecontainer.ContainerStateExited, ExitCode: 2, }, { Name: "without-reason", State: kubecontainer.ContainerStateExited, ExitCode: 3, }, { Name: "with-reason", State: kubecontainer.ContainerStateExited, ExitCode: 4, }, { Name: "succeed",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
src/crypto/tls/bogo_shim_test.go
log.Fatal("expected ECH to be accepted, but connection state shows it was not") } else if i == 0 && *onInitialExpectECHAccepted && !cs.ECHAccepted { log.Fatal("expected ECH to be accepted, but connection state shows it was not") } else if i > 0 && *onResumeExpectECHAccepted && !cs.ECHAccepted { log.Fatal("expected ECH to be accepted on resumption, but connection state shows it was not")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 11 17:25:39 UTC 2024 - 12.6K bytes - Viewed (0) -
cmd/storage-datatypes.go
} // RawFileInfo - represents raw file stat information as byte array. // The above means that any added/deleted fields are incompatible. // Make sure to bump the internode version at storage-rest-common.go type RawFileInfo struct { // Content of entire xl.meta (may contain data depending on what was requested by the caller. Buf []byte `msg:"b,allownil"` } // FileInfo - represents file stat information.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 15.7K bytes - Viewed (0) -
pkg/test/kube/dump.go
out, err := yaml.Marshal(&pod) if err != nil { scopes.Framework.Warnf("Error marshaling pod state for output: %v", err) continue } outPath := podOutputPath(workDir, c, pod, "pod-state.yaml") if err := os.WriteFile(outPath, out, os.ModePerm); err != nil { scopes.Framework.Infof("Error writing out pod state to file: %v", err) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 22.2K bytes - Viewed (0) -
pkg/kubelet/cm/qos_container_manager_linux.go
} m.getNodeAllocatable = getNodeAllocatable m.activePods = activePods // update qos cgroup tiers on startup and in periodic intervals // to ensure desired state is in sync with actual state. go wait.Until(func() { err := m.UpdateCgroups() if err != nil { klog.InfoS("Failed to reserve QoS requests", "err", err) } }, periodicQOSCgroupUpdateInterval, wait.NeverStop)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 20:42:59 UTC 2024 - 13.3K bytes - Viewed (0) -
internal/grid/grid_test.go
runtime.Gosched() stats := c.Stats() if stats.IncomingStreams != 0 { if i > 0 { time.Sleep(100 * time.Millisecond) continue } var found []uint64 c.inStream.Range(func(key uint64, value *muxServer) bool { found = append(found, key) return true }) t.Errorf("expected no active streams, got %d incoming: %v", stats.IncomingStreams, found) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0)