Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for scannerLogIf (0.26 sec)

  1. cmd/erasure.go

    				cache, err = disk.NSScanner(ctx, cache, updates, healScanMode, nil)
    				if err != nil {
    					if !cache.Info.LastUpdate.IsZero() && cache.Info.LastUpdate.After(before) {
    						scannerLogIf(ctx, cache.save(ctx, er, cacheName))
    					} else {
    						scannerLogIf(ctx, err)
    					}
    					// This ensures that we don't close
    					// bucketResults channel while the
    					// updates-collector goroutine still
    					// holds a reference to this.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 16K bytes
    - Viewed (1)
  2. cmd/data-usage.go

    	attempts := 1
    	for dataUsageInfo := range dui {
    		json := jsoniter.ConfigCompatibleWithStandardLibrary
    		dataUsageJSON, err := json.Marshal(dataUsageInfo)
    		if err != nil {
    			scannerLogIf(ctx, err)
    			continue
    		}
    		if attempts > 10 {
    			saveConfig(ctx, objAPI, dataUsageObjNamePath+".bkp", dataUsageJSON) // Save a backup every 10th update.
    			attempts = 1
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  3. cmd/logging.go

    }
    
    func configLogOnceConsoleIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    	logger.LogOnceConsoleIf(ctx, "config", err, id, errKind...)
    }
    
    func scannerLogIf(ctx context.Context, err error, errKind ...interface{}) {
    	logger.LogIf(ctx, "scanner", err, errKind...)
    }
    
    func scannerLogOnceIf(ctx context.Context, err error, id string, errKind ...interface{}) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 16 15:43:39 GMT 2024
    - 6.6K bytes
    - Viewed (0)
  4. cmd/data-scanner.go

    			results := make(chan DataUsageInfo, 1)
    			go storeDataUsageInBackend(ctx, objAPI, results)
    			err := objAPI.NSScanner(ctx, results, uint32(cycleInfo.current), scanMode)
    			scannerLogIf(ctx, err)
    			res := map[string]string{"cycle": strconv.FormatUint(cycleInfo.current, 10)}
    			if err != nil {
    				res["error"] = err.Error()
    			}
    			stopFn(res)
    			if err == nil {
    				// Store new cycle...
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 47.4K bytes
    - Viewed (0)
  5. cmd/data-usage-cache.go

    		d.Cache = make(map[string]dataUsageEntry, 100)
    	}
    	e, ok := src.Cache[hash.String()]
    	if !ok {
    		return
    	}
    	d.Cache[hash.Key()] = e
    	for ch := range e.Children {
    		if ch == hash.Key() {
    			scannerLogIf(GlobalContext, errors.New("dataUsageCache.copyWithChildren: Circular reference"))
    			return
    		}
    		d.copyWithChildren(src, dataUsageHash(ch), &hash)
    	}
    	if parent != nil {
    		p := d.Cache[parent.Key()]
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 41.4K bytes
    - Viewed (1)
  6. cmd/erasure-server-pool.go

    						results[i] = info
    						mu.Unlock()
    					}
    				}()
    				// Start scanner. Blocks until done.
    				err := erObj.nsScanner(ctx, allBuckets, wantCycle, updates, healScanMode)
    				if err != nil {
    					scannerLogIf(ctx, err)
    					mu.Lock()
    					if firstErr == nil {
    						firstErr = err
    					}
    					// Cancel remaining...
    					cancel()
    					mu.Unlock()
    					return
    				}
    			}(resultIndex, erObj)
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
Back to top