- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for atomics (0.24 sec)
-
src/sync/mutex.go
// better done via channels and communication. // // Values containing the types defined in this package should not be copied. package sync import ( "internal/race" "sync/atomic" "unsafe" ) // Provided by runtime via linkname. func throw(string) func fatal(string) // A Mutex is a mutual exclusion lock. // The zero value for a Mutex is an unlocked mutex. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 8.4K bytes - Viewed (0) -
src/sync/pool.go
func runtime_procUnpin() // The below are implemented in internal/runtime/atomic and the // compiler also knows to intrinsify the symbol we linkname into this // package. //go:linkname runtime_LoadAcquintptr internal/runtime/atomic.LoadAcquintptr func runtime_LoadAcquintptr(ptr *uintptr) uintptr //go:linkname runtime_StoreReluintptr internal/runtime/atomic.StoreReluintptr
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 9.4K bytes - Viewed (0) -
security/pkg/nodeagent/sds/server.go
grpcWorkloadListener net.Listener grpcWorkloadServer *grpc.Server stopped *atomic.Bool } // NewServer creates and starts the Grpc server for SDS. func NewServer(options *security.Options, workloadSecretCache security.SecretManager, pkpConf *mesh.PrivateKeyProvider) *Server { s := &Server{stopped: atomic.NewBool(false)} s.workloadSds = newSDSService(workloadSecretCache, options, pkpConf) s.initWorkloadSdsService()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 07 17:44:41 UTC 2024 - 3.3K bytes - Viewed (0) -
src/syscall/rlimit.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. //go:build unix package syscall import ( "sync/atomic" ) // origRlimitNofile, if non-nil, is the original soft RLIMIT_NOFILE. var origRlimitNofile atomic.Pointer[Rlimit] // Some systems set an artificially low soft limit on open file count, for compatibility
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:57 UTC 2024 - 1.6K bytes - Viewed (0) -
pkg/ctrlz/ctrlz.go
"istio.io/istio/pkg/ctrlz/assets" "istio.io/istio/pkg/ctrlz/fw" "istio.io/istio/pkg/ctrlz/topics" "istio.io/istio/pkg/log" ) var coreTopics = []fw.Topic{ topics.ScopeTopic(), topics.MemTopic(), topics.EnvTopic(), topics.ProcTopic(), topics.ArgsTopic(), topics.VersionTopic(), topics.SignalsTopic(), } var ( allTopics []fw.Topic topicMutex sync.Mutex
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 11 21:22:53 UTC 2024 - 5.9K bytes - Viewed (0) -
internal/grid/muxserver.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 9.7K bytes - Viewed (0) -
src/sync/rwmutex.go
writerSem uint32 // semaphore for writers to wait for completing readers readerSem uint32 // semaphore for readers to wait for completing writers readerCount atomic.Int32 // number of pending readers readerWait atomic.Int32 // number of departing readers } const rwmutexMaxReaders = 1 << 30 // Happens-before relationships are indicated to the race detector via: // - Unlock -> Lock: readerSem
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 7.2K bytes - Viewed (0) -
src/sync/once.go
// Copyright 2009 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package sync import ( "sync/atomic" ) // Once is an object that will perform exactly one action. // // A Once must not be copied after first use. // // In the terminology of [the Go memory model], // the return from f “synchronizes before”
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 2.5K bytes - Viewed (0) -
src/sync/cond.go
// Copyright 2011 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package sync import ( "sync/atomic" "unsafe" ) // Cond implements a condition variable, a rendezvous point // for goroutines waiting for or announcing the occurrence // of an event. // // Each Cond has an associated Locker L (often a [*Mutex] or [*RWMutex]),
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4.1K bytes - Viewed (0) -
src/runtime/coro.go
// The cas will also sync c.gp's // memory enough that the next iteration of the racy load // should see the correct value. // We are avoiding the atomic load to keep this path // as lightweight as absolutely possible. // (The atomic load is free on x86 but not free elsewhere.) next := c.gp if next.ptr() == nil { throw("coroswitch on exited coro") } var self guintptr self.set(gp)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:18 UTC 2024 - 7.4K bytes - Viewed (0)