Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 74 for rs (0.03 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. android/guava/src/com/google/common/cache/Striped64.java

                if (busy == 0 && casBusy()) {
                  boolean created = false;
                  try { // Recheck under lock
                    Cell[] rs;
                    int m, j;
                    if ((rs = cells) != null && (m = rs.length) > 0 && rs[j = (m - 1) & h] == null) {
                      rs[j] = r;
                      created = true;
                    }
                  } finally {
                    busy = 0;
                  }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  3. 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)
  4. cmd/bucket-replication-utils.go

    			// provided object replication completed for all targets.
    			if rs.ReplicaTimeStamp.Equal(timeSentinel) || rs.ReplicaTimeStamp.IsZero() {
    				return replStatus
    			}
    			if replStatus == replication.Completed && rs.ReplicaTimeStamp.After(rs.ReplicationTimeStamp) {
    				return rs.ReplicaStatus
    			}
    			return replStatus
    		}
    	case !rs.ReplicaStatus.Empty():
    		return rs.ReplicaStatus
    	default:
    		return
    	}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  5. cmd/bucket-replication-stats.go

    		}
    		bs.Stats[ri.Arn] = b
    	}
    
    	switch {
    	case rs.Completed:
    		b.ReplicatedSize += rs.TransferSize
    		b.ReplicatedCount++
    		if rs.TransferDuration > 0 {
    			b.Latency.update(rs.TransferSize, rs.TransferDuration)
    			b.updateXferRate(rs.TransferSize, rs.TransferDuration)
    		}
    	case rs.Failed:
    		b.FailStats.addsize(rs.TransferSize, rs.Err)
    	case rs.Pending:
    	}
    }
    
    type replStat struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  6. guava/src/com/google/common/hash/Striped64.java

                if (busy == 0 && casBusy()) {
                  boolean created = false;
                  try { // Recheck under lock
                    Cell[] rs;
                    int m, j;
                    if ((rs = cells) != null && (m = rs.length) > 0 && rs[j = (m - 1) & h] == null) {
                      rs[j] = r;
                      created = true;
                    }
                  } finally {
                    busy = 0;
                  }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 14 17:55:55 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top