- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 166 for Unlock (0.52 sec)
-
cmd/erasure-healing.go
VersionID: versionID, DiskCount: len(storageDisks), } if !opts.NoLock { lk := er.NewNSLock(bucket, object) lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { return result, err } ctx = lkctx.Context() defer lk.Unlock(lkctx) } // Re-read when we have lock... partsMetadata, errs := readAllFileInfo(ctx, storageDisks, "", bucket, object, versionID, true, true)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 06:32:14 GMT 2024 - 33.1K bytes - Viewed (0) -
internal/kms/kes.go
func (c *kesClient) Metrics(ctx context.Context) (kes.Metric, error) { c.lock.RLock() defer c.lock.RUnlock() return c.client.Metrics(ctx) } // Version retrieves version information func (c *kesClient) Version(ctx context.Context) (string, error) { c.lock.RLock() defer c.lock.RUnlock() return c.client.Version(ctx) } // APIs retrieves a list of supported API endpoints
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 16 15:43:39 GMT 2024 - 14.9K bytes - Viewed (0) -
cmd/sftp-server-driver.go
wg *sync.WaitGroup buffer map[int64][]byte err error nextOffset int64 m sync.Mutex } func (w *writerAt) WriteAt(b []byte, offset int64) (n int, err error) { w.m.Lock() defer w.m.Unlock() if w.nextOffset == offset { n, err = w.w.Write(b) w.nextOffset += int64(n) } else { w.buffer[offset] = make([]byte, len(b)) copy(w.buffer[offset], b) n = len(b) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 12:23:42 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/bucket-policy-handlers_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 32.7K bytes - Viewed (0) -
cmd/admin-handlers_test.go
if err != nil { return nil, nil, err } // Make objLayer available to all internal services via globalObjectAPI. globalObjLayerMutex.Lock() globalObjectAPI = objLayer globalObjLayerMutex.Unlock() return objLayer, erasureDirs, nil } // cmdType - Represents different service subcomands like status, stop // and restart. type cmdType int const (
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.8K bytes - Viewed (0) -
internal/config/drive/drive.go
// Update - updates the config with latest values func (c *Config) Update(new Config) error { configLk.Lock() defer configLk.Unlock() c.MaxTimeout = getMaxTimeout(new.MaxTimeout) return nil } // GetMaxTimeout - returns the max timeout value. func (c *Config) GetMaxTimeout() time.Duration { configLk.RLock() defer configLk.RUnlock() return getMaxTimeout(c.MaxTimeout) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 2.5K bytes - Viewed (0) -
cmd/erasure-decode.go
var bytesWritten int64 var bufs [][]byte for block := startBlock; block <= endBlock; block++ { var blockOffset, blockLength int64 switch { case startBlock == endBlock: blockOffset = offset % e.blockSize blockLength = length case block == startBlock: blockOffset = offset % e.blockSize blockLength = e.blockSize - blockOffset case block == endBlock: blockOffset = 0
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
cmd/object-api-multipart_test.go
erasureDisks := er.getDisks() ridx := rand.Intn(len(erasureDisks)) z.serverPools[0].erasureDisksMu.Lock() er.getDisks = func() []StorageAPI { erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk) return erasureDisks } z.serverPools[0].erasureDisksMu.Unlock() uploadIDs = append(uploadIDs, res.UploadID) // Create multipart parts.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 77.1K bytes - Viewed (0) -
cmd/iam-object-store.go
usersSysType: usersSysType, } } func (iamOS *IAMObjectStore) rlock() *iamCache { iamOS.RLock() return iamOS.iamCache } func (iamOS *IAMObjectStore) runlock() { iamOS.RUnlock() } func (iamOS *IAMObjectStore) lock() *iamCache { iamOS.Lock() return iamOS.iamCache } func (iamOS *IAMObjectStore) unlock() { iamOS.Unlock() } func (iamOS *IAMObjectStore) getUsersSysType() UsersSysType {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 05 21:26:41 GMT 2024 - 19.9K bytes - Viewed (0) -
internal/dsync/lock-args_gen_test.go
Klaus Post <******@****.***> 1700528975 -0800
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Nov 21 01:09:35 GMT 2023 - 4.4K bytes - Viewed (0)