- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 241 for initialized (0.29 sec)
-
cmd/bucket-metadata-sys.go
wait() // wait to proceed to next entry. } } t.Reset(bucketMetadataRefresh) } } // Initialized indicates if bucket metadata sys is initialized atleast once. func (sys *BucketMetadataSys) Initialized() bool { sys.RLock() defer sys.RUnlock() return sys.initialized } // Loads bucket metadata for all buckets into BucketMetadataSys.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 19.8K bytes - Viewed (0) -
cmd/server-main.go
if globalIsDistErasure { logger.Info("Waiting for all MinIO sub-systems to be initialize...") } // Upon success migrating the config, initialize all sub-systems // if all sub-systems initialized successfully return right away err := initConfigSubsystem(ctx, newObject) if err == nil { // All successful return. if globalIsDistErasure {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 33K bytes - Viewed (1) -
cmd/sts-handlers.go
if err != nil { writeSTSErrorResponse(ctx, w, ErrSTSInvalidParameterValue, fmt.Errorf("Error processing %s parameter: %v", stsRoleArn, err)) return } } if !globalIAMSys.Initialized() { writeSTSErrorResponse(ctx, w, ErrSTSIAMNotInitialized, errIAMNotInitialized) return } // Validate JWT; check clientID in claims matches the one associated with the roleArn
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 18:36:18 GMT 2024 - 34.7K bytes - Viewed (2) -
cmd/healthcheck-handler.go
// if configured. func ReadinessCheckHandler(w http.ResponseWriter, r *http.Request) { if objLayer := newObjectLayerFn(); objLayer == nil { w.Header().Set(xhttp.MinIOServerStatus, unavailable) // Service not initialized yet } if r.Header.Get(xhttp.MinIOPeerCall) != "" { writeResponse(w, http.StatusOK, nil, mimeNone) return } if int(globalHTTPStats.loadRequestsInQueue()) > globalAPIConfig.getRequestsPoolCapacity() {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
internal/config/lambda/target/lazyinit.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package target import ( "sync" "sync/atomic" ) // Inspired from Golang sync.Once but it is only marked // initialized when the provided function returns nil. type lazyInit struct { done uint32 m sync.Mutex } func (l *lazyInit) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doSlow(f)
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 1.3K bytes - Viewed (0) -
internal/config/storageclass/storage-class_test.go
{STANDARD, 16, 10, 6}, {"", 16, 9, 7}, } for i, tt := range tests { scfg := Config{ Standard: StorageClass{ Parity: 8, }, RRS: StorageClass{ Parity: 2, }, initialized: true, } // Set env var for test case 4 if i+1 == 4 { scfg.RRS.Parity = 7 } // Set env var for test case 5 if i+1 == 5 { scfg.Standard.Parity = 6 }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Aug 15 23:04:20 GMT 2023 - 4.3K bytes - Viewed (0) -
cmd/dynamic-timeouts.go
dt := newDynamicTimeout(opts.timeout, opts.minimum) dt.retryInterval = opts.retryInterval return dt } // newDynamicTimeout returns a new dynamic timeout initialized with timeout value func newDynamicTimeout(timeout, minimum time.Duration) *dynamicTimeout { if timeout <= 0 || minimum <= 0 { panic("newDynamicTimeout: negative or zero timeout") } if minimum > timeout {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Fri Aug 19 23:21:05 GMT 2022 - 4.5K bytes - Viewed (0) -
cmd/iam.go
sys.store = &IAMStoreSys{newIAMObjectStore(objAPI, sys.usersSysType)} } else { sys.store = &IAMStoreSys{newIAMEtcdStore(etcdClient, sys.usersSysType)} } } // Initialized checks if IAM is initialized func (sys *IAMSys) Initialized() bool { if sys == nil { return false } sys.Lock() defer sys.Unlock() return sys.store != nil }
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1) -
internal/bucket/object/lock/lock.go
config := Config{} if err := xml.NewDecoder(io.LimitReader(reader, maxObjectLockConfigSize)).Decode(&config); err != nil { return nil, err } return &config, nil } // NewObjectLockConfig returns a initialized lock.Config struct func NewObjectLockConfig() *Config { return &Config{ ObjectLockEnabled: Enabled, } } // RetentionDate is a embedded type containing time.Time to unmarshal // Date in Retention
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 17.1K bytes - Viewed (0) -
cmd/prepare-storage.go
return nil, nil, err } // All disks report unformatted we should initialized everyone. if shouldInitErasureDisks(sErrs) && firstDisk { logger.Info("Formatting %s pool, %v set(s), %v drives per set.", humanize.Ordinal(poolCount), setCount, setDriveCount) // Initialize erasure code format on disks
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0)