Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 125 for tracker (0.29 sec)

  1. cmd/background-newdisks-heal-ops.go

    		dataUsageInfo := cache.dui(dataUsageRoot, nil)
    		tracker.ObjectsTotalCount = dataUsageInfo.ObjectsTotalCount
    		tracker.ObjectsTotalSize = dataUsageInfo.ObjectsTotalSize
    	}
    
    	tracker.PoolIndex, tracker.SetIndex, tracker.DiskIndex = disk.GetDiskLoc()
    	tracker.setQueuedBuckets(buckets)
    	if err := tracker.save(ctx); err != nil {
    		return err
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  2. cmd/global-heal.go

    			}
    		}
    
    		// Collect updates to tracker from concurrent healEntry calls
    		results := make(chan healEntryResult, 1000)
    		go func() {
    			for res := range results {
    				if res.entryDone {
    					tracker.setObject(res.name)
    					if time.Since(tracker.getLastUpdate()) > time.Minute {
    						healingLogIf(ctx, tracker.update(ctx))
    					}
    					continue
    				}
    
    				tracker.updateProgress(res.success, res.skipped, res.bytes)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 15K bytes
    - Viewed (1)
  3. maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelValidator.java

                InputLocationTracker tracker) {
            if (!validateNotNull(prefix, fieldName, problems, severity, version, string, sourceHint, tracker)) {
                return false;
            }
    
            if (!string.isEmpty()) {
                return true;
            }
    
            addViolation(problems, severity, version, prefix + fieldName, sourceHint, "is missing.", tracker);
    
            return false;
        }
    
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Fri Apr 12 10:50:18 GMT 2024
    - 65K bytes
    - Viewed (0)
  4. .github/SUPPORT.md

    Unlike many projects on GitHub, the Go project does not use its bug tracker for general discussion or asking questions.
    We only use our bug tracker for tracking bugs and tracking proposals going through the [Proposal Process](https://go.dev/s/proposal-process).
    
    For asking questions, see:
    
    * [The golang-nuts mailing list](https://groups.google.com/d/forum/golang-nuts)
    
    * [The Go Forum](https://forum.golangbridge.org/), a web-based forum
    
    Plain Text
    - Registered: Tue Apr 30 11:13:12 GMT 2024
    - Last Modified: Wed Mar 29 22:00:27 GMT 2023
    - 692 bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    func diskHealthCheckOK(ctx context.Context, err error) bool {
    	// Check if context has a disk health check.
    	tracker, ok := ctx.Value(healthDiskCtxKey{}).(*healthDiskCtxValue)
    	if !ok {
    		// No tracker, return
    		return err == nil || errors.Is(err, io.EOF)
    	}
    	if err == nil || errors.Is(err, io.EOF) {
    		tracker.logSuccess()
    		return true
    	}
    	return false
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  6. .github/ISSUE_TEMPLATE/20_contributor_feature_request.yml

            Please open Android-related issues on [the Android Issue Tracker](https://source.android.com/source/report-bugs)
            Please open IntelliJ-related issues on [the JetBrains Issue Tracker](https://youtrack.jetbrains.com/newIssue?project=IDEA)
    Others
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Thu Apr 06 11:10:39 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  7. cmd/admin-heal-ops.go

    func (ahs *allHealState) updateHealStatus(tracker *healingTracker) {
    	ahs.Lock()
    	defer ahs.Unlock()
    
    	tracker.mu.RLock()
    	t := *tracker
    	t.QueuedBuckets = append(make([]string, 0, len(tracker.QueuedBuckets)), tracker.QueuedBuckets...)
    	t.HealedBuckets = append(make([]string, 0, len(tracker.HealedBuckets)), tracker.HealedBuckets...)
    	ahs.healStatus[tracker.ID] = t
    	tracker.mu.RUnlock()
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.1K bytes
    - Viewed (1)
  8. build-logic/integration-testing/src/main/kotlin/gradlebuild/integrationtests/tasks/DistributionTest.kt

            jvmArgumentProviders.add(srcDistributionZip)
        }
    
        override fun executeTests() {
            cachesCleaner.get().cleanUpCaches()
    
            if (tracker.isPresent) {
                val daemonTrackerService = tracker.get()
                val testListener = daemonTrackerService.javaClass.getMethod("newDaemonListener").invoke(daemonTrackerService) as TestListener
                addTestListener(testListener)
            }
    Plain Text
    - Registered: Wed Mar 27 11:36:08 GMT 2024
    - Last Modified: Fri Jul 01 22:53:59 GMT 2022
    - 8K bytes
    - Viewed (0)
  9. .github/ISSUE_TEMPLATE/10_contributor_bug_report.yml

            Please open Android-related issues on [the Android Issue Tracker](https://source.android.com/source/report-bugs)
            Please open IntelliJ-related issues on [the JetBrains Issue Tracker](https://youtrack.jetbrains.com/newIssue?project=IDEA)
    Others
    - Registered: Wed May 01 11:36:15 GMT 2024
    - Last Modified: Fri Feb 16 07:49:32 GMT 2024
    - 3K bytes
    - Viewed (0)
  10. cmd/data-scanner-metric.go

    	return func(path string) {
    			atomic.StorePointer(tracker.name, unsafe.Pointer(&path))
    		}, func() {
    			p.currentPaths.Delete(disk)
    		}
    }
    
    // getCurrentPaths returns the paths currently being processed.
    func (p *scannerMetrics) getCurrentPaths() []string {
    	var res []string
    	prefix := globalLocalNodeName + "/"
    	p.currentPaths.Range(func(key, value interface{}) bool {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 25 05:15:31 GMT 2023
    - 9.1K bytes
    - Viewed (0)
Back to top