Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for cleanupFns (0.08 sec)

  1. cmd/object-api-utils.go

    	if opts.CheckPrecondFn != nil && opts.CheckPrecondFn(oi) {
    		// Call the cleanup funcs
    		for i := len(cleanupFns) - 1; i >= 0; i-- {
    			cleanupFns[i]()
    		}
    		return nil, PreConditionFailed{}
    	}
    	return &GetObjectReader{
    		ObjInfo:    oi,
    		Reader:     r,
    		cleanUpFns: cleanupFns,
    	}, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

       * either it has exceeded the keep alive limit or the idle connections limit.
       *
       * Returns the duration in nanoseconds to sleep until the next scheduled call to this method.
       * Returns -1 if no further cleanups are required.
       */
      fun closeConnections(now: Long): Long {
        // Compute the concurrent call capacity for each address. We won't close a connection if doing
        // so would violate a policy, unless it's OLD.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. cmd/erasure-multipart.go

    			return nil
    		}, index)
    	}
    	g.Wait()
    }
    
    // Clean-up the old multipart uploads. Should be run in a Go routine.
    func (er erasureObjects) cleanupStaleUploads(ctx context.Context) {
    	// run multiple cleanup's local to this server.
    	var wg sync.WaitGroup
    	for _, disk := range er.getLocalDisks() {
    		if disk != nil {
    			wg.Add(1)
    			go func(disk StorageAPI) {
    				defer wg.Done()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  4. cmd/batch-handlers.go

    		jobCancelers: make(map[string]context.CancelFunc),
    	}
    	jpool.ResizeWorkers(workers)
    
    	randomWait := func() time.Duration {
    		// randomWait depends on the number of nodes to avoid triggering resume and cleanups at the same time.
    		return time.Duration(rand.Float64() * float64(time.Duration(globalEndpoints.NEndpoints())*time.Hour))
    	}
    
    	go func() {
    		jpool.resume(randomWait)
    		jpool.cleanupReports(randomWait)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    	var uploadedParts []minio.CompletePart
    	// new multipart must not set mtime as it may lead to erroneous cleanups at various intervals.
    	opts.Internal.SourceMTime = time.Time{} // this value is saved properly in CompleteMultipartUpload()
    	var uploadID string
    	attempts := 1
    	for attempts <= 3 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  6. CHANGELOG/CHANGELOG-1.27.md

    - Fixed clearing of rate-limiter for the queue of checks for cleaning stale pod disruption conditions. The bug could result in the PDB synchronization updates firing too often or the pod disruption cleanups taking too long to happen. ([#114770](https://github.com/kubernetes/kubernetes/pull/114770), [@mimowo](https://github.com/mimowo))
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Wed Jul 17 07:48:22 UTC 2024
    - 466.3K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.26.md

    - Fix clearing of rate-limiter for the queue of checks for cleaning stale pod disruption conditions. 
      The bug could result in the PDB synchronization updates firing too often or the pod disruption cleanups taking too long to happen. ([#114780](https://github.com/kubernetes/kubernetes/pull/114780), [@mimowo](https://github.com/mimowo)) [SIG Apps]
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Thu Mar 14 16:24:51 UTC 2024
    - 425.7K bytes
    - Viewed (0)
Back to top