Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 103 for scanner (0.07 sec)

  1. cmd/data-scanner.go

    	minSleep time.Duration
    
    	// cycle will be closed
    	cycle chan struct{}
    
    	// isScanner should be set when this is used by the scanner
    	// to record metrics.
    	isScanner bool
    }
    
    // newDynamicSleeper
    func newDynamicSleeper(factor float64, maxWait time.Duration, isScanner bool) *dynamicSleeper {
    	return &dynamicSleeper{
    		factor:    factor,
    		cycle:     make(chan struct{}),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  2. 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...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 16 08:43:49 UTC 2024
    - 17.9K bytes
    - Viewed (1)
  3. src/bufio/scan.go

    // Scan advances the [Scanner] to the next token, which will then be
    // available through the [Scanner.Bytes] or [Scanner.Text] method. It returns false when
    // there are no more tokens, either by reaching the end of the input or an error.
    // After Scan returns false, the [Scanner.Err] method will return any error that
    // occurred during scanning, except that if it was [io.EOF], [Scanner.Err]
    // will return nil.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Oct 23 09:06:30 UTC 2023
    - 14.2K bytes
    - Viewed (0)
  4. cmd/erasure.go

    	// Put all buckets into channel.
    	bucketCh := make(chan BucketInfo, len(buckets))
    
    	// Shuffle buckets to ensure total randomness of buckets, being scanned.
    	// Otherwise same set of buckets get scanned across erasure sets always.
    	// at any given point in time. This allows different buckets to be scanned
    	// in different order per erasure set, this wider spread is needed when
    	// there are lots of buckets with different order of objects in them.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 22:23:33 UTC 2024
    - 16.1K bytes
    - Viewed (0)
  5. src/bufio/scan_test.go

    	scanner.Split(ScanWords)
    	if !scanner.Scan() {
    		t.Fatalf("scan failed: %v", scanner.Err())
    	}
    	if token := scanner.Text(); token != word {
    		t.Fatalf("unexpected token: %v", token)
    	}
    }
    
    // Test that empty tokens, including at end of line or end of file, are found by the scanner.
    // Issue 8672: Could miss final empty token.
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  6. src/cmd/asm/internal/asm/parse.go

    		return
    	}
    
    	// Constant.
    	haveConstant := false
    	switch tok.ScanToken {
    	case scanner.Int, scanner.Float, scanner.String, scanner.Char, '+', '-', '~':
    		haveConstant = true
    	case '(':
    		// Could be parenthesized expression or (R). Must be something, though.
    		tok := p.next()
    		if tok.ScanToken == scanner.EOF {
    			p.errorf("missing right parenthesis")
    			return
    		}
    		rname := tok.String()
    		p.back()
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Sep 04 18:16:59 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  7. src/cmd/asm/internal/lex/input.go

    			}
    			in.beginningOfLine = in.hash()
    			in.text = "#"
    			return '#'
    
    		case scanner.Ident:
    			// Is it a macro name?
    			name := in.Stack.Text()
    			macro := in.macros[name]
    			if macro != nil {
    				nesting++
    				in.invokeMacro(macro)
    				continue
    			}
    			fallthrough
    		default:
    			if tok == scanner.EOF && len(in.ifdefStack) > 0 {
    				// We're skipping text but have run out of input with no #endif.
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Sep 06 13:17:27 UTC 2024
    - 12.5K bytes
    - Viewed (0)
  8. tests/scanner_valuer_test.go

    	}
    
    	if err := DB.Create(&data).Error; err != nil {
    		t.Fatalf("No error should happened when create scanner valuer struct, but got %v", err)
    	}
    
    	var result ScannerValuerStruct
    
    	if err := DB.Find(&result, "id = ?", data.ID).Error; err != nil {
    		t.Fatalf("no error should happen when query scanner, valuer struct, but got %v", err)
    	}
    
    	if result.ExampleStructPtr.Val != "value2" {
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Wed Jun 07 07:02:07 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  9. 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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
  10. cni/pkg/nodeagent/podcgroupns.go

    func GetCgroups(procCgroupData bytes.Buffer) ([]Cgroup, error) {
    	reader := bytes.NewReader(procCgroupData.Bytes())
    	var cgroups []Cgroup
    	scanner := bufio.NewScanner(reader)
    
    	for scanner.Scan() {
    		token := scanner.Text()
    		substrings := strings.SplitN(token, ":", 3)
    		if len(substrings) < 3 {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Apr 12 21:47:31 UTC 2024
    - 11K bytes
    - Viewed (0)
Back to top