- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 119 for Unlock (1.13 sec)
-
internal/config/browser/browser.go
// GetCSPolicy - Get the Content security Policy func (browseCfg *Config) GetCSPolicy() string { configLock.RLock() defer configLock.RUnlock() return browseCfg.CSPPolicy } // GetHSTSSeconds - Get the Content security Policy func (browseCfg *Config) GetHSTSSeconds() int { configLock.RLock() defer configLock.RUnlock() return browseCfg.HSTSSeconds }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.8K bytes - Viewed (0) -
cmd/bucket-metadata-sys.go
buckets = buckets[count:] } sys.Lock() sys.initialized = true sys.Unlock() if globalIsDistErasure { go sys.refreshBucketsMetadataLoop(ctx, failedBuckets) } } // Reset the state of the BucketMetadataSys. func (sys *BucketMetadataSys) Reset() { sys.Lock() for k := range sys.metadataMap { delete(sys.metadataMap, k) } sys.Unlock() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
prepare_stmt.go
} return nil, ErrInvalidDB } func (db *PreparedStmtDB) Close() { db.Mux.Lock() defer db.Mux.Unlock() for _, query := range db.PreparedSQL { if stmt, ok := db.Stmts[query]; ok { delete(db.Stmts, query) go stmt.Close() } } } func (sdb *PreparedStmtDB) Reset() { sdb.Mux.Lock() defer sdb.Mux.Unlock() for _, stmt := range sdb.Stmts { go stmt.Close() }
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Thu Mar 28 08:47:39 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/erasure-common.go
// // - Do not consume disks which are being healed // // - Future: skip busy disks return } mu.Lock() newDisks = append(newDisks, disks[i]) mu.Unlock() }() } wg.Wait() return newDisks } func (er erasureObjects) getOnlineLocalDisks() (newDisks []StorageAPI) { disks := er.getOnlineDisks()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 4.6K bytes - Viewed (0) -
cmd/perf-tests.go
activeConnections uint64 sync.RWMutex } func (n *netPerfRX) Connect() { n.Lock() defer n.Unlock() n.activeConnections++ atomic.StoreUint64(&n.RX, 0) n.lastToConnect = time.Now() } func (n *netPerfRX) Disconnect() { n.Lock() defer n.Unlock() n.activeConnections-- if n.firstToDisconnect.IsZero() { n.RXSample = atomic.LoadUint64(&n.RX)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cmd/local-locker.go
} func (l *localLocker) RUnlock(_ context.Context, args dsync.LockArgs) (reply bool, err error) { if len(args.Resources) > 1 { return false, fmt.Errorf("internal error: localLocker.RUnlock called with more than one resource") } l.mutex.Lock() defer l.mutex.Unlock() var lri []lockRequesterInfo resource := args.Resources[0] if lri, reply = l.lockMap[resource]; !reply { // No lock is held on the given name
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 19 22:54:46 GMT 2024 - 10.6K bytes - Viewed (0) -
cmd/batch-rotate.go
lock := api.NewNSLock(r.Bucket, objInfo.Name) lkctx, err := lock.GetLock(ctx, globalOperationTimeout) if err != nil { return err } ctx = lkctx.Context() defer lock.Unlock(lkctx) opts := ObjectOptions{ VersionID: objInfo.VersionID, Versioned: versioned, VersionSuspended: versionSuspended, NoLock: true, }
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) -
internal/config/storageclass/storage-class.go
func (sCfg *Config) AvailabilityOptimized() bool { ConfigLock.RLock() defer ConfigLock.RUnlock() if !sCfg.initialized { return true } return sCfg.Optimize == "availability" || sCfg.Optimize == "" } // Update update storage-class with new config func (sCfg *Config) Update(newCfg Config) { ConfigLock.Lock() defer ConfigLock.Unlock() sCfg.RRS = newCfg.RRS sCfg.Standard = newCfg.Standard
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 11.8K bytes - Viewed (0) -
cmd/http-stats.go
if stats == nil { return } stats.Lock() defer stats.Unlock() if stats.apiStats == nil { stats.apiStats = make(map[string]int) } stats.apiStats[api]++ } // Dec increments the api stats counter. func (stats *HTTPAPIStats) Dec(api string) { if stats == nil { return } stats.Lock() defer stats.Unlock() if val, ok := stats.apiStats[api]; ok && val > 0 {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 10 09:15:15 GMT 2024 - 11.4K bytes - Viewed (0) -
cmd/site-replication.go
nil, ) resultsMu.Lock() results.NodeResults = append(results.NodeResults, result) resultsMu.Unlock() return }() } wg.Wait() return } // GetClusterInfo - returns site replication information. func (c *SiteReplicationSys) GetClusterInfo(ctx context.Context) (info madmin.SiteReplicationInfo, err error) { c.RLock() defer c.RUnlock() if !c.enabled { return info, nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 184.2K bytes - Viewed (1)