Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for rs (0.02 sec)

  1. cmd/httprange_test.go

    	}
    	for i, urs := range unparsableRangeSpecs {
    		rs, err := parseRequestRangeSpec(urs)
    		if err == nil {
    			t.Errorf("Case %d: Did not get an expected error - got %v", i, rs)
    		}
    		if isErrInvalidRange(err) {
    			t.Errorf("Case %d: Got invalid range error instead of a parse error", i)
    		}
    		if rs != nil {
    			t.Errorf("Case %d: Got non-nil rs though err != nil: %v", i, rs)
    		}
    	}
    
    	invalidRangeSpecs := []string{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun May 05 16:56:21 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  2. cmd/site-replication-utils.go

    	if !ok {
    		return nil
    	}
    	rs, ok := sm.resyncStatus[rst.resyncID]
    	if !ok {
    		return nil
    	}
    	m := madmin.SiteResyncMetrics{
    		CollectedAt:     rs.LastUpdate,
    		StartTime:       rs.StartTime,
    		LastUpdate:      rs.LastUpdate,
    		ResyncStatus:    rs.Status.String(),
    		ResyncID:        rst.resyncID,
    		DeplID:          rs.DeplID,
    		ReplicatedSize:  rs.ReplicatedSize,
    		ReplicatedCount: rs.ReplicatedCount,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils_test.go

    	name      string
    	rs        ReplicationState
    	arn       string
    	expStatus replication.StatusType
    }{
    	{ // 1. no replication status header
    		name:      "no replicated targets",
    		rs:        ReplicationState{},
    		expStatus: replication.StatusType(""),
    	},
    	{ // 2. replication status for one target
    		name:      "replication status for one target",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  4. cmd/copy-part-range.go

    // e.g. 'bytes=3-10'. Other use cases will be rejected.
    func checkCopyPartRangeWithSize(rs *HTTPRangeSpec, resourceSize int64) (err error) {
    	if rs == nil {
    		return nil
    	}
    	if rs.IsSuffixLength || rs.Start >= resourceSize || rs.End >= resourceSize {
    		return errInvalidRangeSource
    	}
    	return nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 18 03:27:04 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  5. schema/schema_helper_test.go

    	for name, relations := range actual {
    		rs := expected[name]
    		t.Run("CheckEmbeddedRelations/"+name, func(t *testing.T) {
    			if len(relations.Relations) != len(rs.Relations) {
    				t.Errorf("schema relations count don't match, expects %d, got %d", len(rs.Relations), len(relations.Relations))
    			}
    			if len(relations.EmbeddedRelations) != len(rs.EmbeddedRelations) {
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Thu Aug 28 02:57:17 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  6. cmd/copy-part-range_test.go

    		{"bytes=2-2", 2, 2},
    		{"bytes=0000-0006", 0, 6},
    	}
    	objectSize := int64(10)
    
    	for _, successCase := range successCases {
    		rs, err := parseCopyPartRangeSpec(successCase.rangeString)
    		if err != nil {
    			t.Fatalf("expected: <nil>, got: %s", err)
    		}
    
    		start, length, err1 := rs.GetOffsetLength(objectSize)
    		if err1 != nil {
    			t.Fatalf("expected: <nil>, got: %s", err1)
    		}
    
    		if start != successCase.offsetBegin {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  7. cmd/veeam-sos-api.go

    		buf = encodeResponse(&ci)
    	default:
    		return nil, errFileNotFound
    	}
    
    	etag := getMD5Hash(buf)
    	r := bytes.NewReader(buf)
    
    	off, length := int64(0), r.Size()
    	if rs != nil {
    		off, length, err = rs.GetOffsetLength(r.Size())
    		if err != nil {
    			return nil, err
    		}
    	}
    	r.Seek(off, io.SeekStart)
    
    	return NewGetObjectReaderFromReader(io.LimitReader(r, length), ObjectInfo{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  8. cmd/api-headers.go

    	if err != nil {
    		return err
    	}
    
    	if rs == nil && opts.PartNumber > 0 {
    		rs = partNumberToRangeSpec(objInfo, opts.PartNumber)
    	}
    
    	// For providing ranged content
    	start, rangeLen, err = rs.GetOffsetLength(totalObjectSize)
    	if err != nil {
    		return err
    	}
    
    	// Set content length.
    	w.Header().Set(xhttp.ContentLength, strconv.FormatInt(rangeLen, 10))
    	if rs != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.6K bytes
    - Viewed (0)
  9. cmd/bitrot.go

    	}
    	return newWholeBitrotReader(disk, bucket, filePath, algo, tillOffset, sum)
    }
    
    // Close all the readers.
    func closeBitrotReaders(rs []io.ReaderAt) {
    	for _, r := range rs {
    		if r != nil {
    			if br, ok := r.(io.Closer); ok {
    				br.Close()
    			}
    		}
    	}
    }
    
    // Close all the writers.
    func closeBitrotWriters(ws []io.Writer) []error {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Feb 26 19:26:13 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  10. compat/maven-compat/src/main/java/org/apache/maven/project/ProjectUtils.java

                Repository repo, ArtifactRepositoryFactory artifactRepositoryFactory, PlexusContainer c)
                throws InvalidRepositoryException {
            RepositorySystem repositorySystem = rs(c);
            RepositorySystemSession session = rss(c);
    
            ArtifactRepository repository = repositorySystem.buildArtifactRepository(repo);
    
            if (session != null) {
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.8K bytes
    - Viewed (0)
Back to top