Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 106 for uploadIds (0.31 sec)

  1. cmd/object-api-multipart_test.go

    			Uploads: []MultipartInfo{
    				{
    					Object:   objectNames[0],
    					UploadID: uploadIDs[4],
    				},
    				{
    					Object:   objectNames[1],
    					UploadID: uploadIDs[5],
    				},
    				{
    					Object:   objectNames[2],
    					UploadID: uploadIDs[6],
    				},
    				{
    					Object:   objectNames[3],
    					UploadID: uploadIDs[7],
    				},
    				{
    					Object:   objectNames[4],
    					UploadID: uploadIDs[8],
    				},
    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/object-handlers_test.go

    			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)
  3. cmd/erasure-multipart.go

    		break
    	}
    
    	for i := range uploadIDs {
    		uploadIDs[i] = strings.TrimSuffix(uploadIDs[i], SlashSeparator)
    	}
    
    	// S3 spec says uploadIDs should be sorted based on initiated time, we need
    	// to read the metadata entry.
    	var uploads []MultipartInfo
    
    	populatedUploadIDs := set.NewStringSet()
    
    	for _, uploadID := range uploadIDs {
    		if populatedUploadIDs.Contains(uploadID) {
    			continue
    		}
    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/post-policy_test.go

    	credentials := globalActiveCred
    
    	curTime := UTCNow()
    	curTimePlus5Min := curTime.Add(time.Minute * 5)
    
    	// bucketnames[0].
    	// objectNames[0].
    	// uploadIds [0].
    	// Create bucket before initiating NewMultipartUpload.
    	err := obj.MakeBucket(context.Background(), bucketName, MakeBucketOptions{})
    	if err != nil {
    		// Failed to create newbucket, abort.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  5. cmd/object-api-datatypes.go

    	ChecksumAlgorithm string
    }
    
    // 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)
  6. cmd/server_test.go

    	err = decoder.Decode(newResponse)
    	c.Assert(err, nil)
    	c.Assert(len(newResponse.UploadID) > 0, true)
    	// uploadID to be used for rest of the multipart operations on the object.
    	uploadID := newResponse.UploadID
    
    	// content for the part to be uploaded.
    	buffer1 := bytes.NewReader([]byte("hello world"))
    	// HTTP request for the part to be uploaded.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 15 16:28:02 UTC 2024
    - 116.3K bytes
    - Viewed (0)
  7. 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)
  8. cmd/api-resources.go

    	}
    	return
    }
    
    // Parse bucket url queries for ?uploads
    func getBucketMultipartResources(values url.Values) (prefix, keyMarker, uploadIDMarker, delimiter string, maxUploads int, encodingType string, errCode APIErrorCode) {
    	errCode = ErrNone
    
    	if values.Get("max-uploads") != "" {
    		var err error
    		if maxUploads, err = strconv.Atoi(values.Get("max-uploads")); err != nil {
    			errCode = ErrInvalidMaxUploads
    			return
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 07 18:25:26 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  9. 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)
  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