Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for scannerLogIf (0.08 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  2. 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...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  3. 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
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  4. 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{}) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 03 18:49:48 UTC 2024
    - 7.1K 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()]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  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)
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top