Search Options

Results per page
Sort
Preferred Languages
Advance

Results 121 - 130 of 251 for recs (0.05 sec)

  1. cmd/peer-s3-client.go

    	}
    
    	res := madmin.HealResultItem{
    		Type:     madmin.HealItemBucket,
    		Bucket:   bucket,
    		SetCount: -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    	for i, err := range errs {
    		if err == nil {
    			res.Before.Drives = append(res.Before.Drives, healBucketResults[i].Before.Drives...)
    			res.After.Drives = append(res.After.Drives, healBucketResults[i].After.Drives...)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  2. cmd/peer-s3-server.go

    	// Initialize heal result info
    	res = madmin.HealResultItem{
    		Type:      madmin.HealItemBucket,
    		Bucket:    bucket,
    		DiskCount: len(localDrives),
    		SetCount:  -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    	// mutate only if not a dry-run
    	if opts.DryRun {
    		return res, nil
    	}
    
    	for i := range beforeState {
    		res.Before.Drives = append(res.Before.Drives, madmin.HealDriveInfo{
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  3. cmd/object-api-options_test.go

    			},
    		},
    	}
    
    	for _, testCase := range testCases {
    		t.Run(testCase.name, func(t *testing.T) {
    			rec := httptest.NewRecorder()
    			req := httptest.NewRequest("GET", "/test", nil)
    			req.Header = testCase.headers
    
    			opts, _ := getAndValidateAttributesOpts(ctx, rec, req, bucket, "testobject")
    
    			if !reflect.DeepEqual(opts.ObjectAttributes, testCase.wantObjectAttrs) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Apr 09 14:28:39 UTC 2025
    - 2.4K bytes
    - Viewed (0)
  4. .github/workflows/docs.yml

    jobs:
      test_docs:
        permissions:
          checks: write # for actions/upload-artifact
        runs-on: ubuntu-latest
        if: github.ref == 'refs/heads/master' || contains(github.event.pull_request.labels.*.name, 'documentation')
    
        steps:
          - name: Checkout
            uses: actions/checkout@v6
    
          - name: Configure JDK
            uses: actions/setup-java@v5
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 12 23:30:30 UTC 2025
    - 987 bytes
    - Viewed (0)
  5. cmd/last-minute.go

    	l.LastSec = sec
    }
    
    // Merge all recorded latencies of last minute into one
    func (l *lastMinuteLatency) getTotal() AccElem {
    	var res AccElem
    	sec := time.Now().Unix()
    	l.forwardTo(sec)
    	for _, elem := range l.Totals[:] {
    		res.merge(elem)
    	}
    	return res
    }
    
    // forwardTo time t, clearing any entries in between.
    func (l *lastMinuteLatency) forwardTo(t int64) {
    	if l.LastSec >= t {
    		return
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Jul 05 17:40:45 UTC 2023
    - 4.8K bytes
    - Viewed (0)
  6. src/test/java/jcifs/smb/DirFileEntryEnumIterator1Test.java

                Trans2FindFirst2Response resp = inv.getArgument(1);
                // First response content
                FE[] res = java.util.Arrays.stream(batches.get(0)).map(FE::new).toArray(FE[]::new);
                setField(resp, jcifs.internal.smb1.trans.SmbComTransactionResponse.class, "results", res);
                setField(resp, Trans2FindFirst2Response.class, "sid", 42);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  7. internal/lru/lru.go

    	if res.ttl != noEvictionTTL {
    		go func(done <-chan struct{}) {
    			ticker := time.NewTicker(res.ttl / numBuckets)
    			defer ticker.Stop()
    			for {
    				select {
    				case <-done:
    					return
    				case <-ticker.C:
    					res.deleteExpired()
    				}
    			}
    		}(res.done)
    	}
    	return &res
    }
    
    // Purge clears the cache completely.
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 12.5K bytes
    - Viewed (0)
  8. internal/event/name.go

    		}
    	case ObjectScannerAll:
    		return []Name{
    			ObjectManyVersions,
    			ObjectLargeVersions,
    			PrefixManyFolders,
    		}
    	case Everything:
    		res := make([]Name, objectSingleTypesEnd-1)
    		for i := range res {
    			res[i] = Name(i + 1)
    		}
    		return res
    	default:
    		return []Name{name}
    	}
    }
    
    // Mask returns the type as mask.
    // Compound "All" types are expanded.
    func (name Name) Mask() uint64 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/io/CharStreamsCopyBenchmark.java

        }
        data = sb.toString();
      }
    
      @Benchmark
      public long timeCopy(int reps) throws IOException {
        long r = 0;
        String localData = data;
        TargetSupplier localTarget = target;
        CopyStrategy localStrategy = strategy;
        for (int i = 0; i < reps; i++) {
          Appendable appendable = localTarget.get(localData.length());
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 3.2K bytes
    - Viewed (0)
  10. docs/debugging/xl-meta/main.go

    		hh.Write(data)
    		if !bytes.Equal(want, hh.Sum(nil)) {
    			return res, fmt.Errorf("bitrot detected")
    		}
    		res = append(res, data...)
    		val = val[32+len(data):]
    		if len(res) > startOffset {
    			return res[startOffset:], nil
    		}
    	}
    	return res, fmt.Errorf("bitrot: data too short to get block. len(res)=%d, startOffset=%d", len(res), startOffset)
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 40.4K bytes
    - Viewed (0)
Back to top