- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 938 for rwmutex (0.12 sec)
-
prepare_stmt.go
} type PreparedStmtDB struct { Stmts map[string]*Stmt PreparedSQL []string Mux *sync.RWMutex ConnPool } func NewPreparedStmtDB(connPool ConnPool) *PreparedStmtDB { return &PreparedStmtDB{ ConnPool: connPool, Stmts: make(map[string]*Stmt), Mux: &sync.RWMutex{}, PreparedSQL: make([]string, 0, 100), } } func (db *PreparedStmtDB) GetDBConn() (*sql.DB, error) {
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Thu Mar 28 08:47:39 UTC 2024 - 6.4K bytes - Viewed (0) -
internal/config/drive/drive.go
EnvMaxDiskTimeoutLegacy = "_MINIO_DISK_MAX_TIMEOUT" ) // DefaultKVS - default KVS for drive var DefaultKVS = config.KVS{ config.KV{ Key: MaxTimeout, Value: "30s", }, } var configLk sync.RWMutex // Config represents the subnet related configuration type Config struct { // MaxTimeout - maximum timeout for a drive operation MaxTimeout time.Duration `json:"maxTimeout"` }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3K bytes - Viewed (0) -
pkg/kubelet/cm/dra/claiminfo_test.go
return func() error { if cache.RWMutex.TryLock() { return errors.New("Lock succeeded") } return nil } }, }, { description: "cache is Rlocked inside a function", funcGen: func(cache *claimInfoCache) func() error { return func() error { if cache.RWMutex.TryRLock() { return errors.New("RLock succeeded") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 13:30:31 UTC 2024 - 21K bytes - Viewed (0) -
src/cmd/compile/internal/test/inl_test.go
// the inlining budget. Move back to the main table once that // problem is solved. want["sync"] = []string{ "(*Mutex).Lock", "(*Mutex).Unlock", "(*RWMutex).RLock", "(*RWMutex).RUnlock", "(*Once).Do", } } // Functions that must actually be inlined; they must have actual callers. must := map[string]bool{
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 09 04:07:57 UTC 2024 - 10.7K bytes - Viewed (0) -
pkg/kubelet/config/mux.go
// pushed via channels and sent to the merge function. type mux struct { // Invoked when an update is sent to a source. merger merger // Sources and their lock. sourceLock sync.RWMutex // Maps source names to channels sources map[string]chan interface{} } // newMux creates a new mux that can merge changes from multiple sources. func newMux(merger merger) *mux { mux := &mux{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 20:02:23 UTC 2024 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/routes/flags.go
package routes import ( "fmt" "html/template" "io/ioutil" "net/http" "path" "sync" "k8s.io/klog/v2" "k8s.io/apiserver/pkg/server/mux" ) var ( lock = &sync.RWMutex{} registeredFlags = map[string]debugFlag{} ) // DebugFlags adds handlers for flags under /debug/flags. type DebugFlags struct { } // Install registers the APIServer's flags handler.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 16 11:54:27 UTC 2020 - 3.2K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/state/state_mem.go
limitations under the License. */ package state import ( "sync" "k8s.io/klog/v2" "k8s.io/utils/cpuset" ) type stateMemory struct { sync.RWMutex assignments ContainerCPUAssignments defaultCPUSet cpuset.CPUSet } var _ State = &stateMemory{} // NewMemoryState creates new State for keeping track of cpu/pod assignment func NewMemoryState() State {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 03 16:26:09 UTC 2023 - 2.9K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
} h.disk = disk h.ID = diskID h.mu = &sync.RWMutex{} return &h, nil } // newHealingTracker will create a new healing tracker for the disk. func newHealingTracker() *healingTracker { return &healingTracker{ mu: &sync.RWMutex{}, } } func initHealingTracker(disk StorageAPI, healID string) *healingTracker { h := newHealingTracker()
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 04 15:12:32 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/kube/rpc_creds.go
) type tokenSupplier struct { // The token itself. (These are public in case we need to serialize) Token string Expires time.Time // regenerate tokens using this mu sync.RWMutex tokenNamespace string tokenServiceAccount string audiences []string expirationSeconds int64 kubeClient Client
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 4K bytes - Viewed (0) -
tools/bug-report/pkg/kubectlcmd/kubectlcmd.go
// Used to limit the number of concurrent tasks. taskSem chan struct{} // runningTasks tracks the in-flight fetch operations for user feedback. runningTasks sets.String runningTasksMu sync.RWMutex // runningTasksTicker is the report interval for running tasks. runningTasksTicker *time.Ticker } func NewRunner(activeRqLimit int) *Runner { if activeRqLimit <= 0 {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Nov 16 01:18:03 UTC 2023 - 7.2K bytes - Viewed (0)