- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,309 for ATOMIC (0.09 sec)
-
pkg/test/loadbalancersim/network/helper.go
import ( "time" "go.uber.org/atomic" "istio.io/istio/pkg/test/loadbalancersim/timeseries" ) type ConnectionHelper struct { name string hist timeseries.Instance active *atomic.Uint64 total *atomic.Uint64 } func NewConnectionHelper(name string) *ConnectionHelper { return &ConnectionHelper{ active: atomic.NewUint64(0), total: atomic.NewUint64(0), name: name, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 03 18:19:25 UTC 2022 - 1.7K bytes - Viewed (0) -
src/cmd/go/init_test.go
for pb.Next() { cmd := testenv.Command(b, gotool, "env", "GOARCH") if err := cmd.Run(); err != nil { b.Fatal(err) } atomic.AddInt64(&n, 1) atomic.AddInt64(&userTime, int64(cmd.ProcessState.UserTime())) atomic.AddInt64(&systemTime, int64(cmd.ProcessState.SystemTime())) } }) b.ReportMetric(float64(userTime)/float64(n), "user-ns/op")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 15 20:21:26 UTC 2022 - 1.1K bytes - Viewed (0) -
internal/grid/benchmark_test.go
} PutByteBuffer(resp) n++ } atomic.AddInt64(&ops, int64(n)) atomic.AddInt64(&lat, latency) }) spent := time.Since(t) if spent > 0 && n > 0 { // Since we are benchmarking n parallel servers we need to multiply by n. // This will give an estimate of the total ops/s. latency := float64(atomic.LoadInt64(&lat)) / float64(time.Millisecond)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 15.7K bytes - Viewed (0) -
src/internal/poll/fd_mutex.go
// It reports whether mu is available for reading or writing. func (mu *fdMutex) incref() bool { for { old := atomic.LoadUint64(&mu.state) if old&mutexClosed != 0 { return false } new := old + mutexRef if new&mutexRefMask == 0 { panic(overflowMsg) } if atomic.CompareAndSwapUint64(&mu.state, old, new) { return true } } } // increfAndClose sets the state of mu to closed.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 20 16:55:30 UTC 2018 - 6.4K bytes - Viewed (0) -
cmd/data-scanner-metric.go
duration := time.Since(startTime) atomic.AddUint64(&p.operations[s], 1) if s < scannerMetricLastRealtime { p.latency[s].addSize(duration, int64(sz)) } } } // incTime will increment time on metric s with a specific duration. // Use for s < scannerMetricLastRealtime func (p *scannerMetrics) incTime(s scannerMetric, d time.Duration) { atomic.AddUint64(&p.operations[s], 1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K bytes - Viewed (0) -
staging/src/k8s.io/api/rbac/v1/generated.proto
// +listType=atomic repeated string verbs = 1; // APIGroups is the name of the APIGroup that contains the resources. If multiple API groups are specified, any action requested against one of // the enumerated resources in any API group will be allowed. "" represents the core API group and "*" represents all API groups. // +optional // +listType=atomic repeated string apiGroups = 2;
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 28 15:34:11 UTC 2024 - 7.9K bytes - Viewed (0) -
src/cmd/cgo/internal/testcarchive/testdata/libgo8/a.go
package main import "C" import ( "os" "runtime" "sync/atomic" ) var started int32 // Start a goroutine that loops forever. func init() { runtime.GOMAXPROCS(1) go func() { for { atomic.StoreInt32(&started, 1) } }() } //export GoFunction8 func GoFunction8() { for atomic.LoadInt32(&started) == 0 { runtime.Gosched() } os.Exit(0) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 529 bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/tasks/testing/logging/TestLogEvent.java
public enum TestLogEvent { /** * A test has started. This event gets fired both for atomic and composite tests. */ STARTED, /** * A test has completed successfully. This event gets fired both for atomic and composite tests. */ PASSED, /** * A test has been skipped. This event gets fired both for atomic and composite tests. */ SKIPPED, /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 1.4K bytes - Viewed (0) -
src/runtime/vdso_freebsd.go
for { if timekeepSharedPage.enabled == 0 { return zeroBintime } curr := atomic.Load(&timekeepSharedPage.current) // atomic_load_acq_32 th := &timehands[curr] gen := atomic.Load(&th.gen) // atomic_load_acq_32 bt = th.offset if tc, ok := th.getTimecounter(); !ok { return zeroBintime } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/events/test/JvmTestKind.java
*/ package org.gradle.tooling.events.test; /** * Enumerates the different kinds of JVM tests. This allows to differentiate between test suites, atomic tests, etc. * * @since 2.4 */ public enum JvmTestKind { SUITE("Test suite"), ATOMIC("Atomic test"), UNKNOWN("Unknown test kind"); private final String label; JvmTestKind(String label) { this.label = label; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 1.2K bytes - Viewed (0)