Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 54 for 5000 (0.13 sec)

  1. cmd/metacache-manager.go

    }
    
    type metacacheManager struct {
    	mu      sync.RWMutex
    	init    sync.Once
    	buckets map[string]*bucketMetacache
    	trash   map[string]metacache // Recently deleted lists.
    }
    
    const metacacheMaxEntries = 5000
    
    // initManager will start async saving the cache.
    func (m *metacacheManager) initManager() {
    	// Add a transient bucket.
    	// Start saver when object layer is ready.
    	go func() {
    		objAPI := newObjectLayerFn()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Oct 25 00:44:15 GMT 2022
    - 5.2K bytes
    - Viewed (0)
  2. internal/grid/connection.go

    		Remote:             o.remote,
    		Local:              o.local,
    		id:                 o.id,
    		ctx:                o.ctx,
    		outgoing:           xsync.NewMapOfPresized[uint64, *muxClient](1000),
    		inStream:           xsync.NewMapOfPresized[uint64, *muxServer](1000),
    		outQueue:           make(chan []byte, defaultOutQueue),
    		dialer:             o.dial,
    		side:               ws.StateServerSide,
    		connChange:         &sync.Cond{L: &sync.Mutex{}},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 42.6K bytes
    - Viewed (0)
  3. cmd/data-usage_test.go

    func TestDataUsageUpdate(t *testing.T) {
    	base := t.TempDir()
    	const bucket = "bucket"
    	files := []usageTestFile{
    		{name: "rootfile", size: 10000},
    		{name: "rootfile2", size: 10000},
    		{name: "dir1/d1file", size: 2000},
    		{name: "dir2/d2file", size: 300},
    		{name: "dir1/dira/dafile", size: 100000},
    		{name: "dir1/dira/dbfile", size: 200000},
    		{name: "dir1/dira/dirasub/dcfile", size: 1000000},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 14.1K bytes
    - Viewed (0)
  4. cmd/storage-datatypes_test.go

    	for i := 0; i < b.N; i++ {
    		err := v.DecodeMsg(dc)
    		if err != nil {
    			b.Fatal(err)
    		}
    	}
    }
    
    func BenchmarkDecodeDiskInfoMsgp(b *testing.B) {
    	v := DiskInfo{
    		Total:     1000,
    		Free:      1000,
    		Used:      1000,
    		FSType:    "xfs",
    		RootDisk:  true,
    		Healing:   true,
    		Endpoint:  "http://localhost:9001/tmp/drive1",
    		MountPath: "/tmp/drive1",
    		ID:        "uuid",
    		Error:     "",
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 9.4K bytes
    - Viewed (0)
  5. cmd/httprange_test.go

    	}{
    		{"bytes=0-", 0, 10},
    		{"bytes=1-", 1, 9},
    		{"bytes=0-9", 0, 10},
    		{"bytes=1-10", 1, 9},
    		{"bytes=1-1", 1, 1},
    		{"bytes=2-5", 2, 4},
    		{"bytes=-5", 5, 5},
    		{"bytes=-1", 9, 1},
    		{"bytes=-1000", 0, 10},
    	}
    	for i, testCase := range validRangeSpecs {
    		rs, err := parseRequestRangeSpec(testCase.spec)
    		if err != nil {
    			t.Errorf("unexpected err: %v", err)
    		}
    		o, l, err := rs.GetOffsetLength(resourceSize)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 3.7K bytes
    - Viewed (0)
  6. internal/event/rules_test.go

    	}{
    		{rulesCase1, "photos.jpg", NewTargetIDSet()},
    		{rulesCase2, "photos.jpg", NewTargetIDSet(TargetID{"1", "webhook"})},
    		{rulesCase3, "2010/photos.jpg", NewTargetIDSet(TargetID{"1", "webhook"})},
    		{rulesCase4, "2000/photos.jpg", NewTargetIDSet()},
    	}
    
    	for i, testCase := range testCases {
    		result := testCase.rules.Match(testCase.objectName)
    
    		if !reflect.DeepEqual(testCase.expectedResult, result) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jun 01 21:59:40 GMT 2021
    - 8.8K bytes
    - Viewed (0)
  7. cmd/object-api-deleteobject_test.go

    		oi, err := obj.DeleteObject(context.Background(), testCase.bucketName, testCase.pathToDelete, ObjectOptions{})
    		t.Log(oi, err)
    
    		result, err := obj.ListObjects(context.Background(), testCase.bucketName, "", "", "", 1000)
    		if err != nil {
    			t.Errorf("Test %d: %s:  Expected to pass, but failed with: <ERROR> %s", i+1, instanceType, err.Error())
    			continue
    		}
    
    		if len(result.Objects) != len(testCase.objectsAfterDelete) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 23 15:46:00 GMT 2022
    - 3.9K bytes
    - Viewed (0)
  8. cmd/kms-router.go

    	kmsAPI := kmsAPIHandlers{}
    	kmsRouter := router.PathPrefix(kmsPathPrefix).Subrouter()
    
    	KMSVersions := []string{
    		kmsAPIVersionPrefix,
    	}
    
    	gz, err := gzhttp.NewWrapper(gzhttp.MinSize(1000), gzhttp.CompressionLevel(gzip.BestSpeed))
    	if err != nil {
    		// Static params, so this is very unlikely.
    		logger.Fatal(err, "Unable to initialize server")
    	}
    
    	for _, version := range KMSVersions {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Aug 19 14:37:53 GMT 2023
    - 4.5K bytes
    - Viewed (0)
  9. docs/debugging/xl-meta/main.go

    						}
    					}
    					var ei erasureInfo
    					if err := json.Unmarshal(buf.Bytes(), &ei); err == nil && ei.V2Obj != nil {
    						verID := uuid.UUID(header.VersionID).String()
    						if verID == "00000000-0000-0000-0000-000000000000" {
    							// If the version ID is all zeros, use the signature as version ID.
    							verID = fmt.Sprintf("null/%08x", header.Signature)
    							v0 = verID
    						}
    						idx := ei.V2Obj.EcIndex
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  10. cmd/server_test.go

    		expectedStrings []string
    	}{
    		{getListObjectsV1URL(s.endPoint, bucketName, "", "1000", ""), []string{"<Key>foo bar 1</Key>", "<Key>foo bar 2</Key>"}},
    		{getListObjectsV1URL(s.endPoint, bucketName, "", "1000", "url"), []string{"<Key>foo+bar+1</Key>", "<Key>foo+bar+2</Key>"}},
    		{
    			getListObjectsV2URL(s.endPoint, bucketName, "", "1000", "", ""),
    			[]string{
    				"<Key>foo bar 1</Key>",
    				"<Key>foo bar 2</Key>",
    			},
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
Back to top