Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 169 for Cleanup (0.14 sec)

  1. cmd/admin-heal-ops.go

    }
    
    // newHealState - initialize global heal state management
    func newHealState(ctx context.Context, cleanup bool) *allHealState {
    	hstate := &allHealState{
    		healSeqMap:     make(map[string]*healSequence),
    		healLocalDisks: make(map[Endpoint]bool),
    		healStatus:     make(map[string]healingTracker),
    	}
    	if cleanup {
    		go hstate.periodicHealSeqsClean(ctx)
    	}
    	return hstate
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  2. cmd/xl-storage_test.go

    	}
    	t.Cleanup(func() {
    		os.Chmod(slashpath.Join(permDeniedDir, "mybucket"), 0o775)
    	})
    
    	if err = os.Chmod(permDeniedDir, 0o400); err != nil {
    		t.Fatalf("Unable to change permission to temporary directory %v. %v", permDeniedDir, err)
    	}
    	t.Cleanup(func() {
    		os.Chmod(permDeniedDir, 0o775)
    	})
    
    	return permDeniedDir
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/cache/CacheBuilder.java

     * entries may be counted in {@link Cache#size}, but will never be visible to read or write
     * operations.
     *
     * <p>Certain cache configurations will result in the accrual of periodic maintenance tasks which
     * will be performed during write operations, or during occasional read operations in the absence of
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 19:07:49 UTC 2024
    - 52K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertEquals(liveCount, countLiveEntries(map));
        ImmutableMap<Object, Object> originalMap = ImmutableMap.copyOf(map);
        assertEquals(liveCount, originalMap.size());
        // can't compare map contents until cleanup occurs
    
        for (int i = 1; i <= originalCount * 2; i *= 2) {
          if (i > 1) {
            // TODO(b/145386688): This access should be guarded by 'segment', which is not currently
            // held
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 20 17:00:05 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/MapMakerInternalMapTest.java

        assertEquals(liveCount, countLiveEntries(map));
        ImmutableMap<Object, Object> originalMap = ImmutableMap.copyOf(map);
        assertEquals(liveCount, originalMap.size());
        // can't compare map contents until cleanup occurs
    
        for (int i = 1; i <= originalCount * 2; i *= 2) {
          if (i > 1) {
            // TODO(b/145386688): This access should be guarded by 'segment', which is not currently
            // held
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Feb 20 17:00:05 UTC 2024
    - 35.1K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/cache/Cache.java

      ConcurrentMap<K, V> asMap();
    
      /**
       * Performs any pending maintenance operations needed by the cache. Exactly which activities are
       * performed -- if any -- is implementation-dependent.
       */
      void cleanUp();
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Aug 07 02:38:22 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  7. api/go1.18.txt

    pkg testing, func MainStart(testDeps, []InternalTest, []InternalBenchmark, []InternalFuzzTarget, []InternalExample) *M
    pkg testing, method (*F) Add(...interface{})
    pkg testing, method (*F) Cleanup(func())
    pkg testing, method (*F) Error(...interface{})
    pkg testing, method (*F) Errorf(string, ...interface{})
    pkg testing, method (*F) Fail()
    pkg testing, method (*F) FailNow()
    pkg testing, method (*F) Failed() bool
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Feb 17 20:31:46 UTC 2023
    - 13K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/informers.go

    		// If it was a job pod that (a) we captured and (b) just terminated (successfully or otherwise)
    		// remove it (the pod process is gone, but kube will keep the Pods around in
    		// a terminated || failed state - we should still do cleanup)
    		if isAnnotated && isTerminated {
    			log.Debugf("deleting pod from mesh: pod was enabled but is now terminated")
    			// Unlike the other cases, we actually want to use the "old" event for terminated job pods
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

      private val routePlanner = FakeRoutePlanner()
      private val factory = routePlanner.factory
      private val taskFaker = routePlanner.taskFaker
      private val peer = MockHttp2Peer()
    
      /** The fake task runner prevents the cleanup runnable from being started.  */
      private val addressA = factory.newAddress("a")
      private val routeA1 = factory.newRoute(addressA)
      private val addressB = factory.newAddress("b")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.23.md

      - [Changelog since v1.23.14](#changelog-since-v12314)
      - [Changes by Kind](#changes-by-kind-2)
        - [Feature](#feature-2)
        - [Bug or Regression](#bug-or-regression-2)
        - [Other (Cleanup or Flake)](#other-cleanup-or-flake)
      - [Dependencies](#dependencies-2)
        - [Added](#added-2)
        - [Changed](#changed-2)
        - [Removed](#removed-2)
    - [v1.23.14](#v12314)
      - [Downloads for v1.23.14](#downloads-for-v12314)
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Feb 28 21:06:52 UTC 2023
    - 424.5K bytes
    - Viewed (0)
Back to top