Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Objs (0.16 sec)

  1. cmd/data-usage_test.go

    			}
    			if e.Size != int64(w.size) {
    				t.Error("got size", e.Size, "want", w.size)
    			}
    			if e.Objects != uint64(w.objs) {
    				t.Error("got objects", e.Objects, "want", w.objs)
    			}
    			if e.Versions != uint64(w.objs) {
    				t.Error("got versions", e.Versions, "want", w.objs)
    			}
    			if e.ObjSizes != w.oSizes {
    				t.Error("got histogram", e.ObjSizes, "want", w.oSizes)
    			}
    		})
    	}
    
    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)
  2. cmd/erasure-sets_test.go

    		{"Cost Benefit Analysis (2009-2010).pptx", objs[13]},
    		{"117Gn8rfHL2ACARPAhaFd0AGzic9pUbIA/5OCn5A", objs[1]},
    		{"SHØRT", objs[9]},
    		{"There are far too many object names, and far too few bucket names!", objs[13]},
    		{"a/b/c/", objs[1]},
    		{"/a/b/c", objs[4]},
    		{string([]byte{0xff, 0xfe, 0xfd}), objs[13]},
    	}
    
    	// Tests hashing order to be consistent.
    	for i, testCase := range testCases {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Feb 12 07:21:56 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  3. cmd/metacache-stream_test.go

    	r := loadMetacacheSample(t)
    	defer r.Close()
    	var readErr error
    	objs := make(chan metaCacheEntry, 1)
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() {
    		readErr = r.readAll(context.Background(), objs)
    		wg.Done()
    	}()
    	want := loadMetacacheSampleNames
    	i := 0
    	for entry := range objs {
    		if entry.name != want[i] {
    			t.Errorf("entry %d, want %q, got %q", i, want[i], entry.name)
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Sep 19 18:05:16 GMT 2022
    - 15K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    		wg.Add(len(z.serverPools))
    		for idx, pool := range z.serverPools {
    			go func(idx int, pool *erasureSets) {
    				defer wg.Done()
    				objs := poolObjIdxMap[idx]
    				if len(objs) > 0 {
    					orgIndexes := origIndexMap[idx]
    					deletedObjects, errs := pool.DeleteObjects(ctx, bucket, objs, opts)
    					mu.Lock()
    					for i, derr := range errs {
    						if derr != nil {
    							derrs[orgIndexes[i]] = derr
    						}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  5. cmd/metacache-stream.go

    // It is favorable to send as many objects as possible in a single write,
    // but no more than math.MaxUint32
    func (w *metacacheWriter) write(objs ...metaCacheEntry) error {
    	if w == nil {
    		return errors.New("metacacheWriter: nil writer")
    	}
    	if len(objs) == 0 {
    		return nil
    	}
    	if w.creator != nil {
    		err := w.creator()
    		w.creator = nil
    		if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 19.5K bytes
    - Viewed (0)
  6. cmd/erasure-sets.go

    		object ObjectToDelete
    	}
    
    	// Transform []delObj to the list of object names
    	toNames := func(delObjs []delObj) []ObjectToDelete {
    		objs := make([]ObjectToDelete, len(delObjs))
    		for i, obj := range delObjs {
    			objs[i] = obj.object
    		}
    		return objs
    	}
    
    	// The result of delete operation on all passed objects
    	delErrs := make([]error, len(objects))
    
    	// The result of delete objects
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
Back to top