- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 178 for mock (0.13 sec)
-
cmd/test-utils_test.go
} // sets globalObjectAPI to `nil`. func resetGlobalObjectAPI() { globalObjLayerMutex.Lock() globalObjectAPI = nil globalObjLayerMutex.Unlock() } // reset the value of the Global server config. // set it to `nil`. func resetGlobalConfig() { // hold the mutex lock before a new config is assigned. globalServerConfigMu.Lock() // Save the loaded config globally. globalServerConfig = nil
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/iam-etcd-store.go
} } func (ies *IAMEtcdStore) rlock() *iamCache { ies.RLock() return ies.iamCache } func (ies *IAMEtcdStore) runlock() { ies.RUnlock() } func (ies *IAMEtcdStore) lock() *iamCache { ies.Lock() return ies.iamCache } func (ies *IAMEtcdStore) unlock() { ies.Unlock() } func (ies *IAMEtcdStore) getUsersSysType() UsersSysType { return ies.usersSysType }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.6K bytes - Viewed (0) -
internal/config/storageclass/storage-class.go
Value: "", HiddenIfEmpty: true, }, } ) // StorageClass - holds storage class information type StorageClass struct { Parity int } // ConfigLock is a global lock for storage-class config var ConfigLock sync.RWMutex // Config storage class configuration type Config struct { Standard StorageClass `json:"standard"` RRS StorageClass `json:"rrs"`
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/bucket-versioning-handler.go
if rcfg, _ := globalBucketObjectLockSys.Get(bucket); rcfg.LockEnabled && (v.Suspended() || v.PrefixesExcluded()) { writeErrorResponse(ctx, w, APIError{ Code: "InvalidBucketState", Description: "An Object Lock configuration is present on this bucket, versioning cannot be suspended.", HTTPStatusCode: http.StatusBadRequest, }, r.URL) return } if rc, _ := getReplicationConfig(ctx, bucket); rc != nil && v.Suspended() {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 5K bytes - Viewed (0) -
internal/config/subnet/config.go
} os.Setenv("CONSOLE_SUBNET_URL", c.BaseURL) } // Update - in-place update with new license and registration information. func (c *Config) Update(ncfg Config, isDevEnv bool) { configLock.Lock() defer configLock.Unlock() c.License = ncfg.License c.APIKey = ncfg.APIKey c.Proxy = ncfg.Proxy c.transport = ncfg.transport c.BaseURL = baseURL if isDevEnv {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Nov 24 17:59:35 GMT 2023 - 3.8K bytes - Viewed (0) -
internal/config/heal/heal.go
func (opts Config) GetWorkers() int { configMutex.RLock() defer configMutex.RUnlock() return opts.DriveWorkers } // Update updates opts with nopts func (opts *Config) Update(nopts Config) { configMutex.Lock() defer configMutex.Unlock() opts.Bitrot = nopts.Bitrot opts.IOCount = nopts.IOCount opts.Sleep = nopts.Sleep opts.DriveWorkers = nopts.DriveWorkers
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 4.9K bytes - Viewed (0) -
cmd/consolelogger.go
lg = log.Info{Entry: e, NodeName: sys.nodeName} case string: lg = log.Info{ConsoleMsg: e, NodeName: sys.nodeName} } atomic.AddInt64(&sys.totalMessages, 1) sys.pubsub.Publish(lg) sys.Lock() // add log to ring buffer sys.logBuf.Value = lg sys.logBuf = sys.logBuf.Next() sys.Unlock() err := sys.console.Send(entry) if err != nil { atomic.AddInt64(&sys.failedMessages, 1) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 17:57:52 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/config/cache/cache.go
configLock.RLock() defer configLock.RUnlock() return c.Enable && c.BlockSize > 0 && size <= c.BlockSize } // Update updates new cache frequency func (c *Config) Update(ncfg Config) { configLock.Lock() defer configLock.Unlock() c.Enable = ncfg.Enable c.Endpoint = ncfg.Endpoint c.BlockSize = ncfg.BlockSize c.clnt = ncfg.clnt } // cache related errors var (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.6K bytes - Viewed (0) -
chainable_api.go
// advanced techniques like specifying lock strength and optimizer hints. See the // [docs] for more depth. // // // add a simple limit clause // db.Clauses(clause.Limit{Limit: 1}).Find(&User{}) // // tell the optimizer to use the `idx_user_name` index // db.Clauses(hints.UseIndex("idx_user_name")).Find(&User{}) // // specify the lock strength to UPDATE // db.Clauses(clause.Locking{Strength: "UPDATE"}).Find(&users)
Go - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Wed Apr 17 03:38:55 GMT 2024 - 14.3K bytes - Viewed (1) -
cmd/site-replication.go
} func (c *SiteReplicationSys) loadFromDisk(ctx context.Context, objAPI ObjectLayer) error { buf, err := readConfig(ctx, objAPI, getSRStateFilePath()) if err != nil { if errors.Is(err, errConfigNotFound) { c.Lock() defer c.Unlock() c.state = srState{} c.enabled = false } return err } // attempt to read just the version key in the state file to ensure we // are reading a compatible version.
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)