Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for storageLogIf (0.1 sec)

  1. cmd/erasure-server-pool.go

    		})
    		if err != nil {
    			if !configRetriableErrors(err) {
    				logger.Fatal(err, "Unable to initialize backend")
    			}
    			retry := time.Duration(r.Float64() * float64(5*time.Second))
    			storageLogIf(ctx, fmt.Errorf("Unable to initialize backend: %w, retrying in %s", err, retry))
    			time.Sleep(retry)
    			attempt++
    			continue
    		}
    		break
    	}
    
    	// initialize the incomplete uploads cache
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. cmd/xl-storage-format-v2.go

    		x.versions = make([]xlMetaV2ShallowVersion, 0, versions+1)
    	}
    	x.versions = x.versions[:versions]
    	x.data = data
    	x.metaV = metaV
    	if err = x.data.validate(); err != nil {
    		x.data.repair()
    		storageLogIf(GlobalContext, fmt.Errorf("xlMetaV2.loadIndexed: data validation failed: %v. %d entries after repair", err, x.data.entries()))
    	}
    	return decodeVersions(buf, versions, func(i int, hdr, meta []byte) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  3. cmd/storage-rest-client.go

    	values.Set(storageRESTTotalVersions, strconv.Itoa(len(versions)))
    
    	var buffer bytes.Buffer
    	encoder := msgp.NewWriter(&buffer)
    	for _, version := range versions {
    		version.EncodeMsg(encoder)
    	}
    	storageLogIf(ctx, encoder.Flush())
    
    	errs = make([]error, len(versions))
    
    	respBody, err := client.call(ctx, storageRESTMethodDeleteVersions, values, &buffer, -1)
    	defer xhttp.DrainBody(respBody)
    	if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom.go

    	// Saves on all pools to make sure decommissioning of first pool is allowed.
    	for i, eset := range pools {
    		if err = saveConfig(ctx, eset, poolMetaName, buf); err != nil {
    			if !errors.Is(err, context.Canceled) {
    				storageLogIf(ctx, fmt.Errorf("saving pool.bin for pool index %d failed with: %v", i, err))
    			}
    			return err
    		}
    	}
    	return nil
    }
    
    const (
    	poolMetaName      = "pool.bin"
    	poolMetaFormat    = 1
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    	if _, err := er.CopyObject(ctx, bucket, object, bucket, object, oi, ObjectOptions{
    		VersionID: oi.VersionID,
    	}, ObjectOptions{
    		VersionID: oi.VersionID,
    	}); err != nil {
    		storageLogIf(ctx, fmt.Errorf("Unable to update transition restore metadata for %s/%s(%s): %s", bucket, object, oi.VersionID, err))
    		return err
    	}
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top