Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for taboret (0.24 sec)

  1. cmd/post-policy_test.go

    	// uploadIds [0].
    	// Create bucket before initiating NewMultipartUpload.
    	err := obj.MakeBucket(context.Background(), bucketName, MakeBucketOptions{})
    	if err != nil {
    		// Failed to create newbucket, abort.
    		t.Fatalf("%s : %s", instanceType, err.Error())
    	}
    
    	// Test cases for signature-V2.
    	testCasesV2 := []struct {
    		expectedStatus int
    		accessKey      string
    		secretKey      string
    	}{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 29.6K bytes
    - Viewed (0)
  2. 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)
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  3. 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 May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  4. cmd/batch-handlers.go

    	var uploadedParts []CompletePart
    	res, err := api.NewMultipartUpload(context.Background(), tgtBucket, tgtObject, opts)
    	if err != nil {
    		return err
    	}
    
    	defer func() {
    		if err != nil {
    			// block and abort remote upload upon failure.
    			attempts := 1
    			for attempts <= 3 {
    				aerr := api.AbortMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, ObjectOptions{})
    				if aerr == nil {
    					return
    				}
    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)
  5. cmd/global-heal.go

    				bucket, humanize.Ordinal(er.setIndex+1))
    		}
    
    		disks, _, healing := er.getOnlineDisksWithHealingAndInfo(true)
    		if len(disks) == healing {
    			// All drives in this erasure set were reformatted for some reasons, abort healing and mark it as successful
    			healingLogIf(ctx, errors.New("all drives are in healing state, aborting.."))
    			return nil
    		}
    
    		disks = disks[:len(disks)-healing] // healing drives are always at the end of the list
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  6. cmd/object-handlers_test.go

    	}{
    		// Test case - 1.
    		// Abort existing upload ID.
    		{
    			bucket:             bucketName,
    			object:             objectName,
    			uploadID:           uploadIDs[0],
    			accessKey:          credentials.AccessKey,
    			secretKey:          credentials.SecretKey,
    			expectedRespStatus: http.StatusNoContent,
    		},
    		// Test case - 2.
    		// Abort non-existing upload ID.
    		{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top