Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Live (0.15 sec)

  1. cmd/common-main.go

    // Cancellation/timeouts are removed, so parent cancellations/timeout will
    // not propagate from parent.
    // Context values are preserved.
    // This can be used for goroutines that live beyond the parent context.
    func bgContext(parent context.Context) context.Context {
    	return bgCtx{parent: parent}
    }
    
    type bgCtx struct {
    	parent context.Context
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  2. cmd/object-handlers.go

    		return
    	}
    	ctx = lkctx.Context()
    	defer lock.RUnlock(lkctx)
    
    	getObjectNInfo := objectAPI.GetObjectNInfo
    
    	gopts := opts
    	gopts.NoLock = true // We already have a lock, we can live with it.
    	objInfo, err := getObjectInfo(ctx, bucket, object, gopts)
    	if err != nil {
    		// Versioning enabled quite possibly object is deleted might be delete-marker
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool-decom.go

    			if ok {
    				globalNotificationSys.ReloadPoolMeta(ctx)
    			}
    			z.poolMetaMutex.Unlock()
    		}
    
    		wk.Take()
    		go func(setIdx int) {
    			defer wk.Give()
    			// We will perpetually retry listing if it fails, since we cannot
    			// possibly give up in this matter
    			for {
    				if contextCanceled(ctx) {
    					break
    				}
    
    				err := set.listObjectsToDecommission(ctx, bi,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  4. cmd/sts-handlers.go

    		return
    	}
    
    	// We set the expiry of the temp. credentials to the minimum of the
    	// configured expiry and the duration until the certificate itself
    	// expires.
    	// We must not issue credentials that out-live the certificate.
    	if validUntil := time.Until(certificate.NotAfter); validUntil < expiry {
    		expiry = validUntil
    	}
    
    	// Associate any service accounts to the certificate CN
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 34.7K bytes
    - Viewed (2)
  5. cmd/batch-handlers.go

    				skipReplicate = obj.IsDeleteMarker && s3Type
    			}
    			if skipReplicate {
    				continue
    			}
    
    			wk.Take()
    			go func() {
    				defer wk.Give()
    				stopFn := globalBatchJobsMetrics.trace(batchJobMetricReplication, job.ID, attempts)
    				success := true
    				if err := r.ReplicateFromSource(ctx, api, core, oi, retry); err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  6. cmd/metacache-set.go

    	// used when o.Versioned is false
    	if !o.Versioned {
    		resolver.requestedVersions = 1
    	}
    	var limit int
    	if o.Limit > 0 && o.StopDiskAtLimit {
    		// Over-read by 4 + 1 for every 16 in limit to give some space for resolver,
    		// allow for truncating the list and know if we have more results.
    		limit = o.Limit + 4 + (o.Limit / 16)
    	}
    	ctxDone := ctx.Done()
    	return listPathRaw(ctx, listPathRawOptions{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 17:59:08 GMT 2024
    - 30.4K bytes
    - Viewed (0)
Back to top