- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for LK (0.14 sec)
-
internal/dsync/locked_rand.go
) // lockedRandSource provides protected rand source, implements rand.Source interface. type lockedRandSource struct { lk sync.Mutex src rand.Source } // Int63 returns a non-negative pseudo-random 63-bit integer as an int64. func (r *lockedRandSource) Int63() (n int64) { r.lk.Lock() n = r.src.Int63() r.lk.Unlock() return } // Seed uses the provided seed value to initialize the generator to a // deterministic state.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Oct 18 15:39:59 GMT 2021 - 1.3K bytes - Viewed (0) -
cmd/erasure-object.go
if !srcInfo.metadataOnly { return oi, NotImplemented{} } if !dstOpts.NoLock { lk := er.NewNSLock(dstBucket, dstObject) lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { return oi, err } ctx = lkctx.Context() defer lk.Unlock(lkctx) } // Read metadata associated with the object from all disks. storageDisks := er.getDisks()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun May 05 16:56:21 GMT 2024 - 77.2K bytes - Viewed (2) -
cmd/erasure-server-pool.go
} if !opts.NoLock { // Lock the bucket name before creating. lk := z.NewNSLock(minioMetaTmpBucket, bucket+".lck") lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { return err } ctx = lkctx.Context() defer lk.Unlock(lkctx) } } if err := z.s3Peer.MakeBucket(ctx, bucket, opts); err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/erasure-multipart.go
if opts.CheckPrecondFn != nil { // Lock the object before reading. lk := er.NewNSLock(bucket, object) lkctx, err := lk.GetRLock(ctx, globalOperationTimeout) if err != nil { return nil, err } rctx := lkctx.Context() obj, err := er.getObjectInfo(rctx, bucket, object, opts) lk.RUnlock(lkctx) if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) { return nil, err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 43K bytes - Viewed (0) -
cmd/erasure-healing.go
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) -
cmd/erasure-sets.go
erasureLockers[endpoint.Host] = newLockAPI(endpoint) } } var wg sync.WaitGroup var lk sync.Mutex for i := 0; i < setCount; i++ { lockerEpSet := set.NewStringSet() for j := 0; j < setDriveCount; j++ { wg.Add(1) go func(i int, endpoint Endpoint) { defer wg.Done() lk.Lock() // Only add lockers only one per endpoint and per erasure set.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
cmd/bucket-replication.go
}) return } // Lock the object name before starting replication operation. // Use separate lock that doesn't collide with regular objects. lk := objectAPI.NewNSLock(bucket, "/[replicate]/"+dobj.ObjectName) lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { globalReplicationPool.queueMRFSave(dobj.ToMRFEntry()) sendEvent(eventArgs{ BucketName: bucket, Object: ObjectInfo{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 112.2K bytes - Viewed (1) -
cmd/testdata/xl-meta-merge.zip
[_xÜæ}¨Sï8Œlr]K_A,0FwZR]Æ÷>k`¼Àjq>poSz>mqyjeìw²@[ f|VtŒ™£ Š¿,–¬Œ´™®£ š¦¢EXHªîww¨in®Åktb¸ÎøcÀrñkB„oÖiruRDqK~Õº¾-[EªyKpˆMKs<ˆ¬5² /ÙsGr¾@ ¸WÖKiZqº|UyuIÜÁ ®]BhWKø [@lskÜSªºC`tªnÌ}}Ku:zfE„c{ò }n W`„prK†—wl?‘€qq^pi~ À«{CŒwGl¼y~IY†ù¥¦ôéå ª Me@sª ZËÄ?“© k}Lk^Stjs†ˆ¥÷ò2 G}fŽãu¾xPï¢ }x=7 j_ï>N„jYgx¸C¥£3Qòd~wpE¸tñ+f®òkïEø' ï}LªßueVA ¥ÛÒ»‘ˆ ôc}Ttª|÷i~ 8·@iKF¥C[ûtw«kqtSc©yRçï P7E{‘„êQN¢_}HKºûvroPaEÜSax Ql„wÕ @é¨VtmŠx_ýà’{[÷ma@ìhqxg toñ~®¢ i\ aVV~]CãteñZ°fïzqPYÌ»‚Ó2XÕEcŽP¬ BtÕž¯—_]òœiY¡ì[i{1}gp i»|ûâ Bµ~mFïp...
ZIP Archive - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Mar 08 17:50:48 GMT 2024 - 30.2K bytes - Viewed (0)