- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 416 for statx (0.05 sec)
-
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) -
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) -
pkg/kubelet/runonce_test.go
kb.mounter, kb.hostutil, kb.getPodsDir(), kb.recorder, volumetest.NewBlockVolumePathHandler()) // TODO: Factor out "stats.Provider" from Kubelet so we don't have a cyclic dependency volumeStatsAggPeriod := time.Second * 10 kb.resourceAnalyzer = stats.NewResourceAnalyzer(kb, volumeStatsAggPeriod, kb.recorder) nodeRef := &v1.ObjectReference{ Kind: "Node", Name: string(kb.nodeName),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 06:59:54 UTC 2024 - 6.5K bytes - Viewed (0) -
cmd/consolelogger.go
} // String - stringer function for interface compatibility func (sys *HTTPConsoleLoggerSys) String() string { return logger.ConsoleLoggerTgt } // Stats returns the target statistics. func (sys *HTTPConsoleLoggerSys) Stats() types.TargetStats { return types.TargetStats{ TotalMessages: atomic.LoadInt64(&sys.totalMessages), FailedMessages: atomic.LoadInt64(&sys.failedMessages), QueueLength: 0,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/internal/upload/run.go
uploader, err := newUploader(config) if err != nil { return err } defer uploader.Close() return uploader.Run() } // uploader encapsulates a single upload operation, carrying parameters and // shared state. type uploader struct { // config is used to select counters to upload. config *telemetry.UploadConfig // configVersion string // version of the config
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 21:12:15 UTC 2024 - 5.5K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/test/kotlin/org/gradle/internal/cc/impl/InputTrackingStateTest.kt
assertFalse(state.isEnabledForCurrentThread()) state.restoreForCurrentThread() // Revert call at <1>, restore to "enabled" state assertTrue(state.isEnabledForCurrentThread()) } @Test fun `disable and restore calls can be mixed non-trivially`() { val state = InputTrackingState() state.disableForCurrentThread() // <1>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 3.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/CachedMetadataProviderTest.groovy
given: cachedResult.state >> state provider = new CachedMetadataProvider(cachedResult) expect: !provider.usable !provider.componentMetadata where:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 17:38:42 UTC 2024 - 2.8K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/registry/ModelNodeInternal.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 12:51:08 UTC 2024 - 8.7K bytes - Viewed (0) -
platforms/core-configuration/flow-services/src/main/kotlin/org/gradle/internal/flow/services/BuildFlowScope.kt
} override fun store(): Pair<Any, State> { return actions to Stored(actions) } } class Stored(override val pendingActions: List<RegisteredFlowAction>) : State() class Loaded(override val pendingActions: List<RegisteredFlowAction>) : State() { override fun load(memento: Any): State = illegalState() } } private
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:59:39 UTC 2024 - 5.5K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/LegacyDaemon.groovy
} if (lastLogState == state) { return } throw new AssertionError("""Timeout waiting for daemon with pid ${context.pid} to reach state ${state}. Current state is ${lastLogState}.""") } @Override protected void assertHasState(State state) { assert logFileProbe.currentState == state } @Override void changeTokenVisibleToClient() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 2.3K bytes - Viewed (0)