Search Options

Results per page
Sort
Preferred Languages
Advance

Results 321 - 330 of 1,425 for Func (0.02 sec)

  1. src/bufio/scan_test.go

    type endlessZeros struct{}
    
    func (endlessZeros) Read(p []byte) (int, error) {
    	return 0, nil
    }
    
    func TestBadReader(t *testing.T) {
    	scanner := NewScanner(endlessZeros{})
    	for scanner.Scan() {
    		t.Fatal("read should fail")
    	}
    	err := scanner.Err()
    	if err != io.ErrNoProgress {
    		t.Errorf("unexpected error: %v", err)
    	}
    }
    
    func TestScanWordsExcessiveWhiteSpace(t *testing.T) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  2. internal/grid/benchmark_test.go

    	"time"
    
    	"github.com/minio/minio/internal/logger/target/testlogger"
    )
    
    func BenchmarkRequests(b *testing.B) {
    	for n := 2; n <= 32; n *= 2 {
    		b.Run("servers="+strconv.Itoa(n), func(b *testing.B) {
    			benchmarkGridRequests(b, n)
    		})
    	}
    }
    
    func benchmarkGridRequests(b *testing.B, n int) {
    	defer testlogger.T.SetErrorTB(b)()
    	errFatal := func(err error) {
    		b.Helper()
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  3. cmd/data-usage-cache_gen.go

    func (z *allTierStats) Msgsize() (s int) {
    	s = 1 + 3 + msgp.MapHeaderSize
    	if z.Tiers != nil {
    		for za0001, za0002 := range z.Tiers {
    			_ = za0002
    			s += msgp.StringPrefixSize + len(za0001) + 1 + 3 + msgp.Uint64Size + 3 + msgp.IntSize + 3 + msgp.IntSize
    		}
    	}
    	return
    }
    
    // MarshalMsg implements msgp.Marshaler
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 75K bytes
    - Viewed (0)
  4. cmd/notification-summary.go

    import (
    	"github.com/minio/madmin-go/v3"
    )
    
    // GetTotalCapacity gets the total capacity in the cluster.
    func GetTotalCapacity(diskInfo []madmin.Disk) (capacity uint64) {
    	for _, disk := range diskInfo {
    		capacity += disk.TotalSpace
    	}
    	return
    }
    
    // GetTotalUsableCapacity gets the total usable capacity in the cluster.
    func GetTotalUsableCapacity(diskInfo []madmin.Disk, s StorageInfo) (capacity uint64) {
    	for _, disk := range diskInfo {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 20 00:53:08 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  5. cmd/url_test.go

    	b.ResetTimer()
    
    	if err := req.ParseForm(); err != nil {
    		b.Fatal(err)
    	}
    
    	b.RunParallel(func(pb *testing.PB) {
    		for pb.Next() {
    			req.Form.Get("uploadId")
    		}
    	})
    
    	// Benchmark ends here. Stop timer.
    	b.StopTimer()
    }
    
    // BenchmarkURLQuery - benchmark URL memory allocations
    func BenchmarkURLQuery(b *testing.B) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Nov 16 17:28:29 UTC 2021
    - 2K bytes
    - Viewed (0)
  6. src/archive/zip/example_test.go

    }
    
    func ExampleWriter_RegisterCompressor() {
    	// Override the default Deflate compressor with a higher compression level.
    
    	// Create a buffer to write our archive to.
    	buf := new(bytes.Buffer)
    
    	// Create a new zip archive.
    	w := zip.NewWriter(buf)
    
    	// Register a custom Deflate compressor.
    	w.RegisterCompressor(zip.Deflate, func(out io.Writer) (io.WriteCloser, error) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jan 27 00:22:03 UTC 2016
    - 2K bytes
    - Viewed (0)
  7. cmd/erasure-decode_test.go

    }
    
    func BenchmarkErasureDecode_4_64KB(b *testing.B) {
    	const size = 64 * 1024
    	b.Run(" 00|00 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 0, 0, size, b) })
    	b.Run(" 00|X0 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 0, 1, size, b) })
    	b.Run(" X0|00 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 1, 0, size, b) })
    	b.Run(" X0|X0 ", func(b *testing.B) { benchmarkErasureDecode(2, 2, 1, 1, size, b) })
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  8. cmd/admin-handlers-site-replication.go

    	}
    
    	writeSuccessResponseJSON(w, body)
    }
    
    func getSRAddOptions(r *http.Request) (opts madmin.SRAddOptions) {
    	opts.ReplicateILMExpiry = r.Form.Get("replicateILMExpiry") == "true"
    	return
    }
    
    // SRPeerJoin - PUT /minio/admin/v3/site-replication/join
    //
    // used internally to tell current cluster to enable SR with
    // the provided peer clusters and service account.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  9. istioctl/pkg/cli/context.go

    	}
    	return f.clients[rev], nil
    }
    
    func (f *fakeInstance) CLIClient() (kube.CLIClient, error) {
    	return f.CLIClientWithRevision("")
    }
    
    func (f *fakeInstance) CLIClientsForContexts(contexts []string) ([]kube.CLIClient, error) {
    	c, err := f.CLIClientWithRevision("")
    	if err != nil {
    		return nil, err
    	}
    	return []kube.CLIClient{c}, nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 23 19:31:32 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  10. cni/pkg/util/podutil_test.go

    	assert.Equal(t, len(podIPs), 2)
    }
    
    func TestGetPodIPsIfNoPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 0)
    }
    
    func TestPodRedirectionEnabled(t *testing.T) {
    	var (
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.9K bytes
    - Viewed (0)
Back to top