Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for attempts (0.05 seconds)

  1. cmd/bucket-replication.go

    	var uploadID string
    	attempts := 1
    	for attempts <= 3 {
    		nctx, cancel := context.WithTimeout(ctx, time.Minute)
    		uploadID, err = c.NewMultipartUpload(nctx, bucket, object, opts)
    		cancel()
    		if err == nil {
    			break
    		}
    		if minio.ToErrorResponse(err).Code == "PreconditionFailed" {
    			return nil
    		}
    		attempts++
    		time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  2. cmd/admin-handlers.go

    	}
    	file := r.Form.Get("file")
    	if len(file) == 0 {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrInvalidRequest), r.URL)
    		return
    	}
    
    	file = filepath.ToSlash(file)
    	// Reject attempts to traverse parent or absolute paths.
    	if hasBadPathComponent(volume) || hasBadPathComponent(file) {
    		writeErrorResponse(r.Context(), w, errorCodes.ToAPIErr(ErrInvalidResourceName), r.URL)
    		return
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  3. cmd/server_test.go

    	response, err = s.client.Do(request)
    	c.Assert(err, nil)
    	// Assert the response status code.
    	c.Assert(response.StatusCode, http.StatusNoContent)
    }
    
    // TestDeleteBucketNotEmpty - Validates the operation during an attempt to delete a non-empty bucket.
    func (s *TestSuiteCommon) TestDeleteBucketNotEmpty(c *check) {
    	// generate a random bucket name.
    	bucketName := getRandomBucketName()
    
    	// HTTP request to create the bucket.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 118.1K bytes
    - Click Count (0)
  4. cmd/object-handlers_test.go

    // First register the HTTP handler for NewMultipartUpload, then a HTTP request for NewMultipart upload is made.
    // The UploadID from the response body is parsed and its existence is asserted with an attempt to ListParts using it.
    func TestAPINewMultipartHandler(t *testing.T) {
    	defer DetectTestLeak(t)()
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
  5. cmd/site-replication.go

    	if err != nil {
    		if errors.Is(err, errConfigNotFound) {
    			c.Lock()
    			defer c.Unlock()
    			c.state = srState{}
    			c.enabled = false
    		}
    		return err
    	}
    
    	// attempt to read just the version key in the state file to ensure we
    	// are reading a compatible version.
    	var ver struct {
    		Version int `json:"version"`
    	}
    	err = json.Unmarshal(buf, &ver)
    	if err != nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
Back to Top