Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 117 for uploadID (0.07 sec)

  1. cmd/object-api-multipart_test.go

    		// Test Case - 10.
    		// Case with valid UploadID, existing bucket name.
    		// But using the bucket name from which NewMultipartUpload is not constructed from.
    		{bucketName: "unused-bucket", objName: object, uploadID: uploadID, PartID: 1, expectedError: fmt.Errorf("%s", "Invalid upload id "+uploadID)},
    		// Test Case - 11.
    		// Case with valid UploadID, existing bucket name.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 09:42:21 UTC 2024
    - 88.8K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		for uploadIndex < len(uploads) {
    			if uploads[uploadIndex].UploadID != uploadIDMarker {
    				uploadIndex++
    				continue
    			}
    			if uploads[uploadIndex].UploadID == uploadIDMarker {
    				uploadIndex++
    				break
    			}
    			uploadIndex++
    		}
    	}
    	for uploadIndex < len(uploads) {
    		result.Uploads = append(result.Uploads, uploads[uploadIndex])
    		result.NextUploadIDMarker = uploads[uploadIndex].UploadID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  3. cmd/object-api-datatypes.go

    }
    
    // Lookup - returns if uploadID is valid
    func (lm ListMultipartsInfo) Lookup(uploadID string) bool {
    	for _, upload := range lm.Uploads {
    		if upload.UploadID == uploadID {
    			return true
    		}
    	}
    	return false
    }
    
    // ListMultipartsInfo - represents bucket resources for incomplete multipart uploads.
    type ListMultipartsInfo struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  4. cmd/api-response.go

    		}
    	}
    	listMultipartUploadsResponse.Uploads = make([]Upload, len(multipartsInfo.Uploads))
    	for index, upload := range multipartsInfo.Uploads {
    		newUpload := Upload{}
    		newUpload.UploadID = upload.UploadID
    		newUpload.Key = s3EncodeName(upload.Object, encodingType)
    		newUpload.Initiated = amztime.ISO8601Format(upload.Initiated.UTC())
    		listMultipartUploadsResponse.Uploads[index] = newUpload
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 19:27:06 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  5. cmd/object-handlers_test.go

    				return
    			}
    			// push the obtained upload ID from the response into the array.
    			testUploads.Lock()
    			testUploads.uploads = append(testUploads.uploads, multipartResponse.UploadID)
    			testUploads.Unlock()
    		}()
    	}
    	// Wait till all go routines finishes execution.
    	wg.Wait()
    	// Validate the upload ID by an attempt to list parts using it.
    	for _, uploadID := range testUploads.uploads {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    		Object:   object,
    		UploadID: uploadID,
    	}
    }
    
    func (z *erasureServerPools) GetMultipartInfo(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) (MultipartInfo, error) {
    	if err := checkListPartsArgs(ctx, bucket, object, uploadID); err != nil {
    		return MultipartInfo{}, err
    	}
    
    	uploadIDLock := z.NewNSLock(bucket, pathJoin(object, uploadID))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  7. cmd/api-router.go

    			Queries("uploadId", "{uploadId:.*}")
    		// CompleteMultipartUpload
    		router.Methods(http.MethodPost).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.CompleteMultipartUploadHandler)).
    			Queries("uploadId", "{uploadId:.*}")
    		// NewMultipartUpload
    		router.Methods(http.MethodPost).Path("/{object:.+}").
    			HandlerFunc(s3APIMiddleware(api.NewMultipartUploadHandler)).
    			Queries("uploads", "")
    		// AbortMultipartUpload
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 15:25:16 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  8. cmd/object_api_suite_test.go

    	if err != nil {
    		t.Fatalf("%s: <ERROR> %s", instanceType, err)
    	}
    	if bytesBuffer.String() != "The specified multipart upload does not exist. The upload ID might be invalid, or the multipart upload might have been aborted or completed." {
    		t.Errorf("%s: Invalid upload ID error mismatch.", instanceType)
    	}
    }
    
    // Wrapper for calling testNonExistentBucketOperations for both Erasure and FS.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jul 02 15:13:05 UTC 2024
    - 33.3K bytes
    - Viewed (0)
  9. cmd/warm-backend-gcs.go

    		err = BucketNotFound{
    			Bucket: bucket,
    		}
    		return err
    	case "storage: object doesn't exist":
    		if uploadID != "" {
    			err = InvalidUploadID{
    				UploadID: uploadID,
    			}
    		} else {
    			err = ObjectNotFound{
    				Bucket: bucket,
    				Object: object,
    			}
    		}
    		return err
    	}
    
    	googleAPIErr, ok := err.(*googleapi.Error)
    	if !ok {
    		// We don't interpret non MinIO errors. As minio errors will
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  10. cmd/erasure-sets.go

    	set := s.getHashedSet(object)
    	return set.PutObjectPart(ctx, bucket, object, uploadID, partID, data, opts)
    }
    
    // GetMultipartInfo - return multipart metadata info uploaded at hashedSet.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
Back to top