Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for cleanupFns (0.1 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)
Back to top