Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for stopFn (0.07 sec)

  1. cmd/data-scanner.go

    					// Add non-compacted empty entry.
    					f.updateCache.replaceHashed(h, &thisHash, dataUsageEntry{})
    				}
    			}
    			f.updateCurrentPath(folder.name)
    			stopFn := globalScannerMetrics.log(scannerMetricScanFolder, f.root, folder.name)
    			scanFolder(folder)
    			stopFn(map[string]string{"type": "new"})
    
    			// Add new folders if this is new and we don't have existing.
    			if !into.Compacted {
    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. cmd/xl-storage.go

    	atomic.AddInt32(&s.scanning, 1)
    	defer atomic.AddInt32(&s.scanning, -1)
    
    	var err error
    	stopFn := globalScannerMetrics.log(scannerMetricScanBucketDrive, s.drivePath, cache.Info.Name)
    	defer func() {
    		res := make(map[string]string)
    		if err != nil {
    			res["err"] = err.Error()
    		}
    		stopFn(res)
    	}()
    
    	// Updates must be closed before we return.
    	defer xioutil.SafeClose(updates)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  3. src/bufio/example_test.go

    			return 0, data, bufio.ErrFinalToken
    		}
    		// If the token is "STOP", stop the scanning and ignore the rest.
    		if string(data[:i]) == "STOP" {
    			return i + 1, nil, bufio.ErrFinalToken
    		}
    		// Otherwise, return the token before the comma.
    		return i + 1, data[:i], nil
    	}
    	const input = "1,2,STOP,4,"
    	scanner := bufio.NewScanner(strings.NewReader(input))
    	scanner.Split(onComma)
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  4. guava/src/com/google/common/base/Stopwatch.java

        startTick = ticker.read();
        return this;
      }
    
      /**
       * Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this
       * point.
       *
       * @return this {@code Stopwatch} instance
       * @throws IllegalStateException if the stopwatch is already stopped.
       */
      @CanIgnoreReturnValue
      public Stopwatch stop() {
        long tick = ticker.read();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 9.3K bytes
    - Viewed (0)
  5. cmd/admin-heal-ops.go

    	defer h.mutex.RUnlock()
    	// background heal never ends
    	if h.clientToken == bgHealingUUID {
    		return false
    	}
    	return !h.endTime.IsZero()
    }
    
    // stops the heal sequence - safe to call multiple times.
    func (h *healSequence) stop() {
    	h.cancelCtx()
    }
    
    // pushHealResultItem - pushes a heal result item for consumption in
    // the heal-status API. It blocks if there are
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  6. compat/maven-compat/src/main/java/org/apache/maven/repository/DefaultMirrorSelector.java

                        result = true;
                        // don't stop processing in case a future segment explicitly excludes this repo
                    }
                    // check for external:http:*
                    else if (EXTERNAL_HTTP_WILDCARD.equals(repo) && isExternalHttpRepo(originalRepository)) {
                        result = true;
                        // don't stop processing in case a future segment explicitly excludes this repo
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 8K bytes
    - Viewed (0)
  7. .github/workflows/arm-ci.yml

          matrix:
            pyver: ['3.10']
        steps:
          - name: Stop old running containers (if any)
            shell: bash
            run: |
              running_containers=$(docker ps -q) && \
              if [[ $running_containers == "" ]]; then
                echo "No running containers";
              else
                echo "Running container(s) found" && \
                docker stop $running_containers;
              fi
              docker container prune -f
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Nov 01 08:40:10 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  8. .github/workflows/arm-ci-extended-cpp.yml

          matrix:
            pyver: ['3.10']
        steps:
          - name: Stop old running containers (if any)
            shell: bash
            run: |
              running_containers=$(docker ps -q) && \
              if [[ $running_containers == "" ]]; then
                echo "No running containers";
              else
                echo "Running container(s) found" && \
                docker stop $running_containers;
              fi
              docker container prune -f
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Nov 01 08:40:10 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  9. .github/workflows/arm-cd.yml

            pyver: ['3.9', '3.10', '3.11', '3.12']
        steps:
          - name: Stop old running containers (if any)
            shell: bash
            run: |
              running_containers=$(docker ps -q) && \
              if [[ $running_containers == "" ]]; then
                echo "No running containers";
              else
                echo "Running container(s) found" && \
                docker stop $running_containers;
              fi
              docker container prune -f
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Fri Nov 01 08:40:10 UTC 2024
    - 3K bytes
    - Viewed (0)
  10. fess-crawler-opensearch/src/test/java/org/codelibs/fess/crawler/CrawlerTest.java

                dataService.delete(sessionId1);
                dataService.delete(sessionId2);
            } finally {
                try {
                    server1.stop();
                } finally {
                    server2.stop();
                }
            }
        }
    
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 7.7K bytes
    - Viewed (0)
Back to top