Search Options

Results per page
Sort
Preferred Languages
Advance

Results 481 - 490 of 620 for uint24 (0.07 sec)

  1. src/archive/tar/fuzz_test.go

    	err := w.WriteHeader(&Header{
    		Name: "lorem.txt",
    		Mode: 0600,
    		Size: int64(len(inp)),
    	})
    	if err != nil {
    		f.Fatalf("failed to create writer: %s", err)
    	}
    	_, err = w.Write(inp)
    	if err != nil {
    		f.Fatalf("failed to write file to archive: %s", err)
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Jan 13 18:06:33 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  2. cni/pkg/iptables/iptables_linux.go

    		inpodMarkRule := netlink.NewRule()
    		inpodMarkRule.Family = family
    		inpodMarkRule.Table = RouteTableInbound
    		inpodMarkRule.Mark = InpodTProxyMark
    		inpodMarkRule.Mask = ptr.Of(uint32(InpodTProxyMask))
    		inpodMarkRule.Priority = 32764
    		rules = append(rules, inpodMarkRule)
    	}
    
    	for _, rule := range rules {
    		log.Debugf("processing netlink rule: %+v", rule)
    		if err := f(rule); err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Sep 06 09:44:28 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. internal/event/target/redis.go

    	Addr       xnet.Host `json:"address"`
    	Password   string    `json:"password"`
    	User       string    `json:"user"`
    	Key        string    `json:"key"`
    	QueueDir   string    `json:"queueDir"`
    	QueueLimit uint64    `json:"queueLimit"`
    }
    
    // RedisAccessEvent holds event log data and timestamp
    type RedisAccessEvent struct {
    	Event     []event.Event
    	EventTime string
    }
    
    // Validate RedisArgs fields
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  4. cmd/post-policy-fan-out.go

    	for i, req := range fanOutEntries {
    		wg.Add(1)
    		go func(idx int, req minio.PutObjectFanOutEntry) {
    			defer wg.Done()
    
    			objInfos[idx] = ObjectInfo{Name: req.Key}
    
    			hopts := hash.Options{
    				Size:       int64(len(fanOutBuf)),
    				MD5Hex:     opts.MD5Hex,
    				SHA256Hex:  "",
    				ActualSize: -1,
    				DisableMD5: true,
    			}
    			hr, err := hash.NewReaderWithOpts(ctx, bytes.NewReader(fanOutBuf), hopts)
    			if err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  5. cmd/batch-job-common-types_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"fmt"
    	"testing"
    )
    
    func TestBatchJobSizeInRange(t *testing.T) {
    	tests := []struct {
    		objSize    int64
    		sizeFilter BatchJobSizeFilter
    		want       bool
    	}{
    		{
    			// 1Mib < 2Mib < 10MiB -> in range
    			objSize: 2 << 20,
    			sizeFilter: BatchJobSizeFilter{
    				UpperBound: 10 << 20,
    				LowerBound: 1 << 20,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jan 08 23:22:28 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  6. internal/s3select/json/preader_test.go

    		b.Fatal(err)
    	}
    	for _, file := range files {
    		b.Run(file.Name(), func(b *testing.B) {
    			f, err := os.ReadFile(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				b.Fatal(err)
    			}
    			b.SetBytes(int64(len(f)))
    			b.ReportAllocs()
    			b.ResetTimer()
    			var record sql.Record
    			for i := 0; i < b.N; i++ {
    				r := NewPReader(io.NopCloser(bytes.NewBuffer(f)), &ReaderArgs{})
    				for {
    					record, err = r.Read(record)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  7. internal/s3select/json/reader_test.go

    		b.Fatal(err)
    	}
    	for _, file := range files {
    		b.Run(file.Name(), func(b *testing.B) {
    			f, err := os.ReadFile(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				b.Fatal(err)
    			}
    			b.SetBytes(int64(len(f)))
    			b.ReportAllocs()
    			b.ResetTimer()
    			var record sql.Record
    			for i := 0; i < b.N; i++ {
    				r := NewReader(io.NopCloser(bytes.NewBuffer(f)), &ReaderArgs{})
    				for {
    					record, err = r.Read(record)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  8. tests/distinct_test.go

    		t.Fatalf("invalid results length found, expects: %v, got %v", len(expects), len(results))
    	}
    
    	for idx, expect := range expects {
    		AssertObjEqual(t, results[idx], expect, "Name", "Age")
    	}
    
    	var count int64
    	if err := DB.Model(&User{}).Where("name like ?", "distinct%").Count(&count).Error; err != nil || count != 5 {
    		t.Errorf("failed to query users count, got error: %v, count: %v", err, count)
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 2.5K bytes
    - Viewed (0)
  9. tests/group_by_test.go

    	}
    
    	if name != "groupby1" || total != 660 {
    		t.Errorf("name should be groupby, but got %v, total should be 660, but got %v", name, total)
    	}
    
    	result := struct {
    		Name  string
    		Total int64
    	}{}
    
    	if err := DB.Model(&User{}).Select("name, sum(age) as total").Where("name LIKE ?", "groupby%").Group("name").Having("name = ?", "groupby1").Find(&result).Error; err != nil {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Jan 06 07:02:53 UTC 2022
    - 3.3K bytes
    - Viewed (0)
  10. internal/cachevalue/cache.go

    	opts Opts
    
    	// Once can be used to initialize values for lazy initialization.
    	// Should be set before calling Get().
    	Once sync.Once
    
    	// Managed values.
    	val          atomic.Pointer[T]
    	lastUpdateMs atomic.Int64
    	updating     sync.Mutex
    }
    
    // New allocates a new cached value instance. Tt must be initialized with
    // `.TnitOnce`.
    func New[T any]() *Cache[T] {
    	return &Cache[T]{}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top