Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 54 for unloads (0.14 sec)

  1. cmd/object-api-datatypes.go

    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 {
    	// Together with upload-id-marker, this parameter specifies the multipart upload
    	// after which listing should begin.
    	KeyMarker string
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    	if uploadIDMarker != "" {
    		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])
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 44.8K bytes
    - Viewed (0)
  3. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 33.5K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    	queryValue.Set("uploads", "")
    	return makeTestTargetURL(endPoint, bucketName, "", queryValue)
    }
    
    // return URL for listing pending multipart uploads with parameters.
    func getListMultipartUploadsURLWithParams(endPoint, bucketName, prefix, keyMarker, uploadIDMarker, delimiter, maxUploads string) string {
    	queryValue := url.Values{}
    	queryValue.Set("uploads", "")
    	queryValue.Set("prefix", prefix)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  5. cmd/bucket-handlers_test.go

    	ExecObjectLayerAPITest(ExecObjectLayerAPITestArgs{t: t, objAPITest: testListMultipartUploadsHandler, endpoints: []string{"ListMultipartUploads"}})
    }
    
    // testListMultipartUploadsHandler - Tests validate listing of multipart uploads.
    func testListMultipartUploadsHandler(obj ObjectLayer, instanceType, bucketName string, apiRouter http.Handler,
    	credentials auth.Credentials, t *testing.T,
    ) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 39.8K bytes
    - Viewed (0)
  6. 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.
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 161.9K bytes
    - Viewed (0)
  7. cmd/object-multipart-handlers.go

    	}
    	encodedSuccessResponse := encodeResponse(response)
    
    	// Write success response.
    	writeSuccessResponseXML(w, encodedSuccessResponse)
    }
    
    // CopyObjectPartHandler - uploads a part by copying data from an existing object as data source.
    func (api objectAPIHandlers) CopyObjectPartHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := newContext(r, w, "CopyObjectPart")
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri Jun 14 13:28:35 UTC 2024
    - 38.8K bytes
    - Viewed (0)
  8. cmd/object-api-datatypes_gen.go

    				return
    			}
    		case "Uploads":
    			var zb0002 uint32
    			zb0002, bts, err = msgp.ReadArrayHeaderBytes(bts)
    			if err != nil {
    				err = msgp.WrapError(err, "Uploads")
    				return
    			}
    			if cap(z.Uploads) >= int(zb0002) {
    				z.Uploads = (z.Uploads)[:zb0002]
    			} else {
    				z.Uploads = make([]MultipartInfo, zb0002)
    			}
    			for za0001 := range z.Uploads {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 70.1K bytes
    - Viewed (0)
  9. 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 Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 33.4K bytes
    - Viewed (0)
  10. src/sync/cond.go

    	L Locker
    
    	notify  notifyList
    	checker copyChecker
    }
    
    // NewCond returns a new Cond with Locker l.
    func NewCond(l Locker) *Cond {
    	return &Cond{L: l}
    }
    
    // Wait atomically unlocks c.L and suspends execution
    // of the calling goroutine. After later resuming execution,
    // Wait locks c.L before returning. Unlike in other systems,
    // Wait cannot return unless awoken by [Cond.Broadcast] or [Cond.Signal].
    //
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 4.1K bytes
    - Viewed (0)
Back to top