Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 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 Nov 03 19:28:11 UTC 2024
    - 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 18 03:27:04 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 08 20:27:40 UTC 2023
    - 9.3K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 00:34:56 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 04:44:00 UTC 2024
    - 7K bytes
    - Viewed (0)
  8. internal/s3select/sql/stringfuncs.go

    }
    
    func evalSQLSubstring(s string, startIdx, length int) (res string, err error) {
    	rs := []rune(s)
    
    	// According to s3 document, if startIdx < 1, it is set to 1.
    	if startIdx < 1 {
    		startIdx = 1
    	}
    
    	if startIdx > len(rs) {
    		startIdx = len(rs) + 1
    	}
    
    	// StartIdx is 1-based in the input
    	startIdx--
    	endIdx := len(rs)
    	if length != -1 {
    		if length < 0 {
    			return "", errInvalidSubstringIndexLen
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 4.2K bytes
    - Viewed (0)
  9. 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 Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Dec 15 08:31:23 UTC 2023
    - 7.5K 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 Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.8K bytes
    - Viewed (0)
Back to top