Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 1,425 for Cake (0.06 seconds)

  1. cmd/erasure-encode_test.go

    		if err != nil {
    			t.Fatalf("Test %d: failed to create ErasureStorage: %v", i, err)
    		}
    		buffer := make([]byte, test.blocksize, 2*test.blocksize)
    
    		data := make([]byte, test.data)
    		if _, err = io.ReadFull(rand.Reader, data); err != nil {
    			t.Fatalf("Test %d: failed to generate random test data: %v", i, err)
    		}
    		writers := make([]io.Writer, len(disks))
    		for i, disk := range disks {
    			if disk == OfflineDisk {
    				continue
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  2. cmd/local-locker_test.go

    		t.Fatalf("lockUID len, got %d, want %d", len(l.lockUID), 0)
    	}
    }
    
    func TestLocalLockerUnlock(t *testing.T) {
    	const n = 1000
    	const m = 5
    	wResources := make([][m]string, n)
    	rResources := make([]string, n)
    	wUIDs := make([]string, n)
    	rUIDs := make([]string, 0, n*2)
    	l := newLocker()
    	ctx := t.Context()
    	quorum := 0
    	for i := range wResources {
    		names := [m]string{}
    		for j := range names {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  3. internal/logger/message/audit/entry.go

    	entry.ReqClaims = reqClaims
    	entry.ReqHost = r.Host
    	entry.ReqPath = r.URL.Path
    
    	q := r.URL.Query()
    	reqQuery := make(map[string]string, len(q))
    	for k, v := range q {
    		reqQuery[k] = strings.Join(v, ",")
    	}
    	entry.ReqQuery = reqQuery
    
    	reqHeader := make(map[string]string, len(r.Header))
    	for k, v := range r.Header {
    		reqHeader[k] = strings.Join(v, ",")
    	}
    	entry.ReqHeader = reqHeader
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/io/CloseablesTest.java

        // make sure that no exception is thrown regardless of value of
        // 'swallowException' when the mock does not throw an exception.
        setupCloseable(false);
        doClose(mockCloseable, false, false);
    
        setupCloseable(false);
        doClose(mockCloseable, true, false);
      }
    
      public void testClose_closeableWithEatenException() throws IOException {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 4.1K bytes
    - Click Count (0)
  5. docs/debugging/reorder-disks/main.go

    	}
    
    	format, err := getFormatJSON(localDisks[0].path)
    	if err != nil {
    		log.Fatal(err)
    	}
    
    	setSize := len(format.XL.Sets[0])
    
    	expectedDisksName := make(map[string]string)
    	actualDisksName := make(map[string]string)
    
    	// Calculate the set/disk index
    	for _, disk := range localDisks {
    		expectedDisksName[fmt.Sprintf("%d-%d", disk.index/setSize, disk.index%setSize)] = disk.path
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.4K bytes
    - Click Count (0)
  6. cmd/xl-storage-format-v2.go

    			BitrotChecksumAlgo: HighwayHash,
    			ErasureDist:        make([]uint8, len(fi.Erasure.Distribution)),
    			PartNumbers:        make([]int, len(fi.Parts)),
    			PartETags:          nil,
    			PartSizes:          make([]int64, len(fi.Parts)),
    			PartActualSizes:    make([]int64, len(fi.Parts)),
    			MetaSys:            make(map[string][]byte),
    			MetaUser:           make(map[string]string, len(fi.Metadata)),
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 65.6K bytes
    - Click Count (1)
  7. cmd/perf-tests.go

    	var retError string
    	var totalBytesWritten uint64
    	var totalBytesRead uint64
    
    	objCountPerThread := make([]uint64, opts.concurrency)
    
    	uploadsCtx, uploadsCancel := context.WithTimeout(ctx, opts.duration)
    	defer uploadsCancel()
    
    	objNamePrefix := pathJoin(speedTest, mustGetUUID())
    
    	userMetadata := make(map[string]string)
    	userMetadata[globalObjectPerfUserMetadata] = "true" // Bypass S3 API freeze
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  8. cmd/metrics-v3-types.go

    ) []prometheus.Metric {
    	metrics := make([]prometheus.Metric, 0, len(m.values))
    	for metricName, mv := range m.values {
    		desc := m.descriptors[metricName]
    		promDesc := desc.toPromDesc(namePrefix, extraLabels)
    		for _, v := range mv {
    			// labelValues is in the same order as the variable labels in the
    			// descriptor.
    			labelValues := make([]string, 0, len(v.Labels))
    			for _, k := range desc.VariableLabels {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Feb 28 19:33:08 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  9. internal/ringbuffer/ring_buffer_test.go

    	})
    	testCancel(func() {
    		rb.Write(make([]byte, sz))
    		rb.WriteByte(0)
    	})
    	testCancel(func() {
    		rb.Read([]byte{10: 1})
    	})
    	testCancel(func() {
    		rb.ReadByte()
    	})
    	testCancel(func() {
    		rb.Write(make([]byte, sz))
    		rb.Flush()
    	})
    }
    
    func TestWriteAfterWriterClose(t *testing.T) {
    	rb := New(100).SetBlocking(true)
    
    	done := make(chan error)
    	go func() {
    		defer close(done)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 26.7K bytes
    - Click Count (0)
  10. COMPLIANCE.md

    Open Source software for the Open Source software community. This requires applications to consider whether their usage of MinIO is in compliance with the GNU AGPLv3 [license](https://github.com/minio/minio/blob/master/LICENSE).
    
    MinIO cannot make the determination as to whether your application's usage of MinIO is in compliance with the AGPLv3 license requirements. You should instead rely on your own legal counsel or licensing specialists to audit and ensure your application is in compliance...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sat Feb 12 00:51:25 GMT 2022
    - 1.1K bytes
    - Click Count (0)
Back to Top