Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 46 for scandir (0.76 sec)

  1. cmd/metacache-walk.go

    			if sterr == nil && st.Mode().IsRegular() {
    				return errFileNotFound
    			}
    		}
    	}
    
    	prefix := opts.FilterPrefix
    	var scanDir func(path string) error
    
    	scanDir = func(current string) error {
    		// Skip forward, if requested...
    		sb := bytebufferpool.Get()
    		defer func() {
    			sb.Reset()
    			bytebufferpool.Put(sb)
    		}()
    
    		forward := ""
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  2. cmd/config-current.go

    		} else {
    			globalBatchConfig.Update(batchCfg)
    		}
    	case config.ScannerSubSys:
    		scannerCfg, err := scanner.LookupConfig(s[config.ScannerSubSys][config.Default])
    		if err != nil {
    			errs = append(errs, fmt.Errorf("Unable to apply scanner config: %w", err))
    		} else {
    			// update dynamic scanner values.
    			scannerIdleMode.Store(scannerCfg.IdleMode)
    			scannerCycle.Store(scannerCfg.Cycle)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 11:33:28 GMT 2024
    - 30.7K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle-audit.go

    type lcEventSrc uint8
    
    //revive:disable:var-naming Underscores is used here to indicate where common prefix ends and the enumeration name begins
    const (
    	lcEventSrc_None lcEventSrc = iota
    	lcEventSrc_Heal
    	lcEventSrc_Scanner
    	lcEventSrc_Decom
    	lcEventSrc_Rebal
    	lcEventSrc_s3HeadObject
    	lcEventSrc_s3GetObject
    	lcEventSrc_s3ListObjects
    	lcEventSrc_s3PutObject
    	lcEventSrc_s3CopyObject
    	lcEventSrc_s3CompleteMultipartUpload
    )
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Dec 01 15:56:24 GMT 2023
    - 2.6K bytes
    - Viewed (0)
  4. cmd/common-main.go

    	if err != nil {
    		return nil, err
    	}
    	defer f.Close()
    	var ekvs []envKV
    	scanner := bufio.NewScanner(f)
    	for scanner.Scan() {
    		ekv, err := parsEnvEntry(scanner.Text())
    		if err != nil {
    			return nil, err
    		}
    		if ekv.Skip {
    			// Skips empty lines
    			continue
    		}
    		ekvs = append(ekvs, ekv)
    	}
    	if err = scanner.Err(); err != nil {
    		return nil, err
    	}
    	return ekvs, nil
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 35.5K bytes
    - Viewed (2)
  5. cmd/data-scanner_test.go

    Krishnan Parthasarathi <******@****.***> 1709356263 -0800
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  6. docs/config/README.md

    usage calculation. The scanner adapts to the system speed and completely pauses when the system is under load. It is possible to adjust the speed of the scanner and thereby the latency of updates being reflected. The delays between each operation of the scanner can be adjusted by the `mc admin config set alias/ delay=15.0`. By default the value is `10.0`. This means the scanner will sleep *10x* the time each operation takes.
    
    In most setups this will keep the scanner slow enough to not impact...
    Plain Text
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 17.7K bytes
    - Viewed (0)
  7. internal/event/name.go

    		return "s3:ObjectTransition:Failed"
    	case ObjectTransitionComplete:
    		return "s3:ObjectTransition:Complete"
    	case ObjectManyVersions:
    		return "s3:Scanner:ManyVersions"
    	case ObjectLargeVersions:
    		return "s3:Scanner:LargeVersions"
    
    	case PrefixManyFolders:
    		return "s3:Scanner:BigPrefix"
    	}
    
    	return ""
    }
    
    // MarshalXML - encodes to XML data.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 17:45:03 GMT 2024
    - 10.2K bytes
    - Viewed (0)
  8. docs/debugging/reorder-disks/main.go

    	if err != nil {
    		return nil, err
    	}
    	defer mountInfo.Close()
    
    	scanner := bufio.NewScanner(mountInfo)
    	for scanner.Scan() {
    		s := strings.Split(scanner.Text(), " ")
    		if len(s) != 11 {
    			return nil, errors.New("unsupported /proc/self/mountinfo format")
    		}
    		result[s[2]] = s[9]
    	}
    
    	if err := scanner.Err(); err != nil {
    		return nil, err
    	}
    
    	return result, nil
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Jan 18 07:03:17 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  9. internal/mountinfo/mountinfo_linux.go

    		return nil, err
    	}
    	defer file.Close()
    	return parseMountFrom(file)
    }
    
    func parseMountFrom(file io.Reader) (mountInfos, error) {
    	mounts := mountInfos{}
    	scanner := bufio.NewReader(file)
    	for {
    		line, err := scanner.ReadString('\n')
    		if err == io.EOF {
    			break
    		}
    
    		fields := strings.Fields(line)
    		if len(fields) != expectedNumFieldsPerLine {
    			// ignore incorrect lines.
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Sun Jan 02 17:15:06 GMT 2022
    - 4.7K bytes
    - Viewed (0)
  10. internal/config/heal/help.go

    	}
    
    	// Help provides help for config values
    	Help = config.HelpKVS{
    		config.HelpKV{
    			Key:         Bitrot,
    			Description: `perform bitrot scan on drives when checking objects during scanner` + defaultHelpPostfix(Bitrot),
    			Optional:    true,
    			Type:        "on|off",
    		},
    		config.HelpKV{
    			Key:         Sleep,
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 11 21:48:54 GMT 2023
    - 1.8K bytes
    - Viewed (0)
Back to top