Search Options

Results per page
Sort
Preferred Languages
Advance

Results 261 - 270 of 1,425 for Func (0.06 sec)

  1. src/archive/zip/zip_test.go

    // 0xFFFFFFFF, but not before.
    func TestZip64DirectoryOffset(t *testing.T) {
    	if testing.Short() {
    		t.Skip("skipping in short mode")
    	}
    	t.Parallel()
    	const filename = "huge.txt"
    	gen := func(wantOff uint64) func(*Writer) {
    		return func(w *Writer) {
    			w.testHookCloseSizeOffset = func(size, off uint64) {
    				if off != wantOff {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  2. cni/pkg/iptables/iptables_e2e_test.go

    	"istio.io/istio/cni/pkg/scopes"
    	"istio.io/istio/pkg/test/util/assert"
    	dep "istio.io/istio/tools/istio-iptables/pkg/dependencies"
    )
    
    func TestIptablesCleanRoundTrip(t *testing.T) {
    	setup(t)
    	tt := struct {
    		name   string
    		config func(cfg *Config)
    	}{
    		"default",
    		func(cfg *Config) {
    			cfg.RedirectDNS = true
    		},
    	}
    
    	probeSNATipv4 := netip.MustParseAddr("169.254.7.127")
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Oct 15 15:39:28 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  3. cmd/erasure-encode_test.go

    	b.Run(" 000000|X00000 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 0, 1, size, b) })
    	b.Run(" X00000|000000 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 1, 0, size, b) })
    	b.Run(" 000000|XXXXX0 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 0, 5, size, b) })
    	b.Run(" XXXXX0|000000 ", func(b *testing.B) { benchmarkErasureEncode(6, 6, 5, 0, size, b) })
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool-decom_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgPoolDecommissionInfo(b *testing.B) {
    	v := PoolDecommissionInfo{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgPoolDecommissionInfo(b *testing.B) {
    	v := PoolDecommissionInfo{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 12 02:48:43 UTC 2022
    - 11K bytes
    - Viewed (0)
  5. cmd/batch-job-common-types_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBatchJobKV(b *testing.B) {
    	v := BatchJobKV{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBatchJobKV(b *testing.B) {
    	v := BatchJobKV{}
    	bts := make([]byte, 0, v.Msgsize())
    	bts, _ = v.MarshalMsg(bts[0:0])
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Dec 02 10:51:33 UTC 2023
    - 11.3K bytes
    - Viewed (0)
  6. cmd/batch-rotate_gen_test.go

    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgBatchJobKeyRotateEncryption(b *testing.B) {
    	v := BatchJobKeyRotateEncryption{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgBatchJobKeyRotateEncryption(b *testing.B) {
    	v := BatchJobKeyRotateEncryption{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 29 18:27:23 UTC 2023
    - 11.8K bytes
    - Viewed (0)
  7. cmd/xl-storage-format-v2_gen_test.go

    		t.Fatal(err)
    	}
    	if len(left) > 0 {
    		t.Errorf("%d bytes left over after Skip(): %q", len(left), left)
    	}
    }
    
    func BenchmarkMarshalMsgxlMetaDataDirDecoder(b *testing.B) {
    	v := xlMetaDataDirDecoder{}
    	b.ReportAllocs()
    	b.ResetTimer()
    	for i := 0; i < b.N; i++ {
    		v.MarshalMsg(nil)
    	}
    }
    
    func BenchmarkAppendMsgxlMetaDataDirDecoder(b *testing.B) {
    	v := xlMetaDataDirDecoder{}
    	bts := make([]byte, 0, v.Msgsize())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Nov 18 20:15:22 UTC 2021
    - 11.5K bytes
    - Viewed (0)
  8. src/archive/tar/writer_test.go

    }
    
    // failOnceWriter fails exactly once and then always reports success.
    type failOnceWriter bool
    
    func (w *failOnceWriter) Write(b []byte) (int, error) {
    	if !*w {
    		return 0, io.ErrShortWrite
    	}
    	*w = true
    	return len(b), nil
    }
    
    func TestWriterErrors(t *testing.T) {
    	t.Run("HeaderOnly", func(t *testing.T) {
    		tw := NewWriter(new(bytes.Buffer))
    		hdr := &Header{Name: "dir/", Typeflag: TypeDir}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  9. internal/ioutil/ioutil_test.go

    )
    
    type sleepWriter struct {
    	timeout time.Duration
    }
    
    func (w *sleepWriter) Write(p []byte) (n int, err error) {
    	time.Sleep(w.timeout)
    	return len(p), nil
    }
    
    func (w *sleepWriter) Close() error {
    	return nil
    }
    
    func TestDeadlineWorker(t *testing.T) {
    	work := NewDeadlineWorker(500 * time.Millisecond)
    
    	err := work.Run(func() error {
    		time.Sleep(600 * time.Millisecond)
    		return nil
    	})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  10. internal/config/lambda/target/webhook.go

    	return target.httpClient.Do(req)
    }
    
    // Close the target. Will cancel all active requests.
    func (target *WebhookTarget) Close() error {
    	target.cancel()
    	return nil
    }
    
    func (target *WebhookTarget) init() error {
    	return target.lazyInit.Do(target.initWebhook)
    }
    
    // Only called from init()
    func (target *WebhookTarget) initWebhook() error {
    	args := target.args
    	transport := target.transport
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top