Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for donde (0.03 sec)

  1. cmd/erasure-server-pool.go

    				defer xioutil.SafeClose(updates)
    				// Start update collector.
    				go func() {
    					defer wg.Done()
    					for info := range updates {
    						mu.Lock()
    						results[i] = info
    						mu.Unlock()
    					}
    				}()
    				// Start scanner. Blocks until done.
    				err := erObj.nsScanner(ctx, allBuckets, wantCycle, updates, healScanMode)
    				if err != nil {
    					scannerLogIf(ctx, err)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  2. cmd/peer-rest-server.go

    	}
    
    	opts := madmin.DriveSpeedTestOpts{
    		Serial:    serial,
    		BlockSize: blockSize,
    		FileSize:  fileSize,
    	}
    
    	done := keepHTTPResponseAlive(w)
    	result := driveSpeedTest(r.Context(), opts)
    	done(nil)
    
    	peersLogIf(r.Context(), gob.NewEncoder(w).Encode(result))
    }
    
    // GetReplicationMRFHandler - returns replication MRF for bucket
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  3. src/main/webapp/js/admin/jquery-3.7.1.min.js

    return f},ce.extend({Deferred:function(e){var o=[["notify","progress",ce.Callbacks("memory"),ce.Callbacks("memory"),2],["resolve","done",ce.Callbacks("once memory"),ce.Callbacks("once memory"),0,"resolved"],["reject","fail",ce.Callbacks("once memory"),ce.Callbacks("once memory"),1,"rejected"]],i="pending",a={state:function(){return i},always:function(){return s.done(arguments).fail(arguments),this},"catch":function(e){return a.then(null,e)},pipe:function(){var i=arguments;return ce.Deferred(func...
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 85.5K bytes
    - Viewed (0)
  4. cmd/iam.go

    		return sys.store.GetBucketUsers(bucket)
    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    // ListUsers - list all users.
    func (sys *IAMSys) ListUsers(ctx context.Context) (map[string]madmin.UserInfo, error) {
    	if !sys.Initialized() {
    		return nil, errServerNotInitialized
    	}
    	select {
    	case <-sys.configLoaded:
    		return sys.store.GetUsers(), nil
    	case <-ctx.Done():
    		return nil, ctx.Err()
    	}
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 74.6K bytes
    - Viewed (0)
  5. cmd/batch-handlers.go

    	return jpool
    }
    
    func (j *BatchJobPool) cleanupReports(randomWait func() time.Duration) {
    	t := time.NewTimer(randomWait())
    	defer t.Stop()
    
    	for {
    		select {
    		case <-GlobalContext.Done():
    			return
    		case <-t.C:
    			results := make(chan itemOrErr[ObjectInfo], 100)
    			ctx, cancel := context.WithCancel(j.ctx)
    			defer cancel()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  6. cmd/xl-storage.go

    		}
    		if sizeS.tiers != nil {
    			sizeS.tiers[storageclass.STANDARD] = tierStats{}
    			sizeS.tiers[storageclass.RRS] = tierStats{}
    		}
    
    		done := globalScannerMetrics.time(scannerMetricApplyAll)
    		objInfos, err := item.applyVersionActions(ctx, objAPI, fivs.Versions, globalExpiryState)
    		done()
    
    		if err != nil {
    			res["err"] = err.Error()
    			return sizeSummary{}, errSkipFile
    		}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (2)
  7. cmd/erasure-object.go

    		defer cancel()
    
    		wg := sync.WaitGroup{}
    		for i, disk := range disks {
    			if disk == nil {
    				done <- false
    				continue
    			}
    			if !disk.IsOnline() {
    				done <- false
    				continue
    			}
    			wg.Add(1)
    			go func(i int, disk StorageAPI) {
    				defer wg.Done()
    
    				var (
    					fi  FileInfo
    					rfi RawFileInfo
    					err error
    				)
    
    				if opts.VersionID != "" {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 78.5K bytes
    - Viewed (0)
  8. src/bufio/bufio_test.go

    				}
    				break
    			}
    			if want := testOutput[done : done+len(line)]; !bytes.Equal(want, line) {
    				t.Errorf("Bad line at stride %d: want: %x got: %x", stride, want, line)
    			}
    			done += len(line)
    		}
    		if done != len(testOutput) {
    			t.Errorf("ReadLine didn't return everything: got: %d, want: %d (stride: %d)", done, len(testOutput), stride)
    		}
    	}
    }
    
    func TestReadLine(t *testing.T) {
    Registered: Tue Oct 29 11:13:09 UTC 2024
    - Last Modified: Mon Oct 28 21:04:51 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    		eventArgsList := make([]eventArgs, 0, len(fanOutEntries))
    		for {
    			var objInfos []ObjectInfo
    			var errs []error
    
    			var done bool
    			if len(fanOutEntries) < concurrentSize {
    				objInfos, errs = fanOutPutObject(ctx, bucket, objectAPI, fanOutEntries, buf.Bytes()[:n], fanOutOpts)
    				done = true
    			} else {
    				objInfos, errs = fanOutPutObject(ctx, bucket, objectAPI, fanOutEntries[:concurrentSize], buf.Bytes()[:n], fanOutOpts)
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 12 12:24:04 UTC 2024
    - 63.4K bytes
    - Viewed (0)
  10. src/main/webapp/js/jquery-3.7.1.min.js

    return f},ce.extend({Deferred:function(e){var o=[["notify","progress",ce.Callbacks("memory"),ce.Callbacks("memory"),2],["resolve","done",ce.Callbacks("once memory"),ce.Callbacks("once memory"),0,"resolved"],["reject","fail",ce.Callbacks("once memory"),ce.Callbacks("once memory"),1,"rejected"]],i="pending",a={state:function(){return i},always:function(){return s.done(arguments).fail(arguments),this},"catch":function(e){return a.then(null,e)},pipe:function(){var i=arguments;return ce.Deferred(func...
    Registered: Mon Oct 28 08:04:08 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 85.5K bytes
    - Viewed (0)
Back to top