- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 465 for atomic (0.25 sec)
-
cmd/erasure-decode.go
n, err := rr.ReadAt(p.buf[bufIdx], p.offset) if err != nil { switch { case errors.Is(err, errFileNotFound): atomic.StoreInt32(&missingPartsHeal, 1) case errors.Is(err, errFileCorrupt): atomic.StoreInt32(&bitrotHeal, 1) case errors.Is(err, errDiskNotFound): atomic.AddInt32(&disksNotFound, 1) } // This will be communicated upstream. p.orgReaders[bufIdx] = nil
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/os-instrumented.go
startTime := time.Now() return func() { duration := time.Since(startTime) atomic.AddUint64(&o.operations[s], 1) o.latency[s].add(duration) } } // incTime will increment time on metric s with a specific duration. func (o *osMetrics) incTime(s osMetric, d time.Duration) { atomic.AddUint64(&o.operations[s], 1) o.latency[s].add(d) }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Feb 15 01:09:38 GMT 2024 - 6.3K bytes - Viewed (0) -
doc/go_mem.html
twice. </p> <h3 id="atomic">Atomic Values</h3> <p> The APIs in the <a href="/pkg/sync/atomic/"><code>sync/atomic</code></a> package are collectively “atomic operations” that can be used to synchronize the execution of different goroutines. If the effect of an atomic operation <i>A</i> is observed by atomic operation <i>B</i>, then <i>A</i> is synchronized before <i>B</i>.
HTML - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Mon Mar 04 15:54:42 GMT 2024 - 26.6K bytes - Viewed (0) -
common-protos/k8s.io/api/discovery/v1/generated.proto
message EndpointHints { // forZones indicates the zone(s) this endpoint should be consumed by to // enable topology aware routing. // +listType=atomic repeated ForZone forZones = 1; } // EndpointPort represents a Port used by an EndpointSlice // +structType=atomic message EndpointPort { // name represents the name of this port. All ports in an EndpointSlice must have a unique name.
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/cache/LongAdder.java
import com.google.common.annotations.GwtCompatible; import java.io.IOException; import java.io.ObjectInputStream; import java.io.ObjectOutputStream; import java.io.Serializable; import java.util.concurrent.atomic.AtomicLong; /** * One or more variables that together maintain an initially zero {@code long} sum. When updates * (method {@link #add}) are contended across threads, the set of variables may grow dynamically to
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jun 15 18:00:07 GMT 2021 - 5.5K bytes - Viewed (0) -
android/guava-testlib/test/com/google/common/testing/ArbitraryInstancesTest.java
import java.util.concurrent.SynchronousQueue; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicReference; import java.util.regex.MatchResult; import java.util.regex.Pattern; import junit.framework.TestCase;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 21.7K bytes - Viewed (0) -
cni/pkg/install/install.go
type Installer struct { cfg *config.InstallConfig isReady *atomic.Value kubeconfigFilepath string cniConfigFilepath string } // NewInstaller returns an instance of Installer with the given config func NewInstaller(cfg *config.InstallConfig, isReady *atomic.Value) *Installer { return &Installer{ cfg: cfg,
Go - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/outside/OutsideEventBusTest.java
*/ package com.google.common.eventbus.outside; import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase; /** * Test cases for {@code EventBus} that must not be in the same package. * * @author Louis Wasserman */
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue May 15 20:25:06 GMT 2018 - 1.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
/** * Constructor for the TOMBSTONE, avoids use of ATOMIC_HELPER in case this class is loaded * before the ATOMIC_HELPER. Apparently this is possible on some android platforms. */ Waiter(boolean unused) {} Waiter() { // avoid volatile write, write is made visible by subsequent CAS on waiters field ATOMIC_HELPER.putThread(this, Thread.currentThread()); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 22 21:17:24 GMT 2024 - 63K bytes - Viewed (0) -
common-protos/k8s.io/api/node/v1/generated.proto
// be rejected in admission. // +optional // +mapType=atomic map<string, string> nodeSelector = 1; // tolerations are appended (excluding duplicates) to pods running with this // RuntimeClass during admission, effectively unioning the set of nodes // tolerated by the pod and the RuntimeClass. // +optional // +listType=atomic repeated k8s.io.api.core.v1.Toleration tolerations = 2;
Plain Text - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 4.4K bytes - Viewed (0)