Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 16 of 16 for Nabors (0.17 sec)

  1. cmd/xl-storage.go

    		return err
    	}
    
    	// Delete all directories we expect to be there.
    	for _, dir := range wantDirs {
    		delete(foundDirs, dir)
    	}
    
    	// Delete excessive directories.
    	// Do not abort on context errors.
    	for dir := range foundDirs {
    		toRemove := pathJoin(volumeDir, path, dir+SlashSeparator)
    		err := s.deleteFile(volumeDir, toRemove, true, true)
    		diskHealthCheckOK(ctx, err)
    	}
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 11:26:59 GMT 2024
    - 82.4K bytes
    - Viewed (0)
  2. cmd/server_test.go

    	objectName := "test-multipart-object"
    
    	// 1. Initiate 2 uploads for the same object
    	// 2. Upload 2 parts for the second upload
    	// 3. Abort the second upload.
    	// 4. Abort the first upload.
    	// This will test abort upload when there are more than one upload IDs
    	// and the case where there is only one upload ID.
    
    	// construct HTTP request to initiate a NewMultipart upload.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  3. cmd/object-multipart-handlers.go

    		// Schedule object for immediate transition if eligible.
    		enqueueTransitionImmediate(objInfo, lcEventSrc_s3CompleteMultipartUpload)
    		os.Sweep()
    	}
    }
    
    // AbortMultipartUploadHandler - Abort multipart upload
    func (api objectAPIHandlers) AbortMultipartUploadHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "AbortMultipartUpload")
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    			continue
    		}
    		return ListPartsInfo{}, err
    	}
    	return ListPartsInfo{}, InvalidUploadID{
    		Bucket:   bucket,
    		Object:   object,
    		UploadID: uploadID,
    	}
    }
    
    // Aborts an in-progress multipart operation on hashedSet based on the object name.
    func (z *erasureServerPools) AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) error {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 77.8K bytes
    - Viewed (0)
  5. internal/dsync/locker.go

    	// Canceling the context will abort the remote call.
    	// In that case, the resource may or may not be unlocked.
    	RUnlock(ctx context.Context, args LockArgs) (bool, error)
    
    	// Do write unlock for given LockArgs. It should return
    	// * a boolean to indicate success/failure of the operation
    	// * an error on failure of unlock request operation.
    	// Canceling the context will abort the remote call.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Tue Jan 18 20:44:38 GMT 2022
    - 2.7K bytes
    - Viewed (0)
  6. cmd/bucket-replication.go

    			return err
    		}
    		attempts++
    		time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
    	}
    	if err != nil {
    		return err
    	}
    
    	defer func() {
    		if err != nil {
    			// block and abort remote upload upon failure.
    			attempts := 1
    			for attempts <= 3 {
    				actx, acancel := context.WithTimeout(ctx, time.Minute)
    				aerr := c.AbortMultipartUpload(actx, bucket, object, uploadID)
    				acancel()
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sat Apr 20 09:05:54 GMT 2024
    - 112K bytes
    - Viewed (1)
Back to top