- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 164 for atomic (0.16 sec)
-
cni/pkg/nodeagent/server.go
Stop() } type Server struct { ctx context.Context kubeClient kube.Client handlers K8sHandlers dataplane MeshDataplane isReady *atomic.Value cniServerStopFunc func() } func NewServer(ctx context.Context, ready *atomic.Value, pluginSocket string, args AmbientArgs) (*Server, error) { client, err := buildKubeClient(args.KubeConfig) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
internal/grid/muxserver.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K 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 May 07 11:14:38 GMT 2024 - Last Modified: Mon Mar 04 15:54:42 GMT 2024 - 26.6K bytes - Viewed (0) -
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 May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
internal/event/targetlist.go
} // TargetList - holds list of targets indexed by target ID. type TargetList struct { // The number of concurrent async Send calls to all targets currentSendCalls atomic.Int64 totalEvents atomic.Int64 eventsSkipped atomic.Int64 eventsErrorsTotal atomic.Int64 sync.RWMutex targets map[TargetID]Target queue chan asyncEvent ctx context.Context statLock sync.RWMutex
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.2K bytes - Viewed (0) -
common-protos/k8s.io/api/certificates/v1beta1/generated.proto
repeated CertificateSigningRequest items = 2; } // CertificateSigningRequestSpec contains the certificate request. message CertificateSigningRequestSpec { // Base64-encoded PKCS#10 CSR data // +listType=atomic optional bytes request = 1; // Requested signer for the request. It is a qualified name in the form: // `scope-hostname.io/name`. // If empty, it will be defaulted:
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 6.7K 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 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 4.4K bytes - Viewed (0) -
cmd/grid.go
package cmd import ( "context" "crypto/tls" "sync/atomic" "github.com/minio/minio/internal/fips" "github.com/minio/minio/internal/grid" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/rest" ) // globalGrid is the global grid manager. var globalGrid atomic.Pointer[grid.Manager]
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Mar 26 15:00:38 GMT 2024 - 2K bytes - Viewed (0) -
internal/grid/muxclient.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package grid import ( "context" "encoding/binary" "errors" "fmt" "sync" "sync/atomic" "time" xioutil "github.com/minio/minio/internal/ioutil" "github.com/zeebo/xxh3" ) // muxClient is a stateful connection to a remote. type muxClient struct { MuxID uint64
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0)