Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 191 - 200 of 311 for feeds2 (0.04 seconds)

  1. cmd/admin-heal-ops.go

    type allHealState struct {
    	sync.RWMutex
    
    	// map of heal path to heal sequence
    	healSeqMap map[string]*healSequence // Indexed by endpoint
    	// keep track of the healing status of disks in the memory
    	//   false: the disk needs to be healed but no healing routine is started
    	//    true: the disk is currently healing
    	healLocalDisks map[Endpoint]bool
    	healStatus     map[string]healingTracker // Indexed by disk ID
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 25.4K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt

       * up the necessary in-memory cache information.
       *
       * The initialization time may vary depending on the journal file size and the current actual
       * cache size. The application needs to be aware of calling this function during the
       * initialization phase and preferably in a background worker thread.
       *
       * Note that if the application chooses to not call this method to initialize the cache. By
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Oct 03 17:41:45 GMT 2025
    - 26.8K bytes
    - Click Count (0)
  3. src/archive/zip/writer.go

    		b.uint16(h.ReaderVersion)
    		b.uint16(h.Flags)
    		b.uint16(h.Method)
    		b.uint16(h.ModifiedTime)
    		b.uint16(h.ModifiedDate)
    		b.uint32(h.CRC32)
    		if h.isZip64() || h.offset >= uint32max {
    			// the file needs a zip64 header. store maxint in both
    			// 32 bit size fields (and offset later) to signal that the
    			// zip64 extra header should be used.
    			b.uint32(uint32max) // compressed size
    			b.uint32(uint32max) // uncompressed size
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      //   have observed 12 micros on 64-bit linux systems to wake up a parked thread). So if the
      //   timeout is small we shouldn't park(). This needs to be traded off with the cpu overhead of
      //   spinning, so we use SPIN_THRESHOLD_NANOS which is what AbstractQueuedSynchronizer uses for
      //   similar purposes.
      // * We want to behave reasonably for timeouts of 0
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  5. CONTRIBUTING.md

        rare occasion we may reject it.
    
    **3. Review**
    
    -   For a valid PR, reviewer (person familiar with the code/functionality)
        checks if the PR looks good or needs additional changes.
    -   If all looks good, the reviewer will approve the PR.
    -   If a change is needed, the contributor is requested to make the suggested
        change.
    -   You make the change and submit it for the review again.
    Created: Tue Dec 30 12:39:10 GMT 2025
    - Last Modified: Sat Jan 11 04:47:59 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  6. scripts/docs.py

        def handle_data(self, data):
            self.text_parts.append(data)
    
        def extract_visible_text(self, html: str) -> str:
            self.reset()
            self.text_parts = []
            self.feed(html)
            return "".join(self.text_parts).strip()
    
    
    def slugify(text: str) -> str:
        return py_slugify(
            text,
            replacements=[
                ("`", ""),  # `dict`s -> dicts
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Dec 21 17:40:17 GMT 2025
    - 16.9K bytes
    - Click Count (0)
  7. cmd/storage-rest-server.go

    	case errors.Is(err, errDiskNotDir):
    		var hint string
    		if endpoint.URL != nil {
    			hint = fmt.Sprintf("Drive '%s' is not a directory, MinIO erasure coding needs a directory", endpoint.Path)
    		} else {
    			hint = "Drives are not directories, MinIO erasure coding needs directories"
    		}
    		logger.Fatal(config.ErrUnableToWriteInBackend(err).Hint("%s", hint), "Unable to initialize backend")
    	case errors.Is(err, errDiskAccessDenied):
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 45.7K bytes
    - Click Count (0)
  8. cmd/erasure-server-pool-rebalance.go

    	if err != nil {
    		rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets)))
    		workerSize = len(pool.sets)
    	}
    
    	// Each decom worker needs one List() goroutine/worker
    	// add that many extra workers.
    	workerSize += len(pool.sets)
    
    	wk, err := workers.New(workerSize)
    	if err != nil {
    		return err
    	}
    
    	for setIdx, set := range pool.sets {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 28.7K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

            .add("services", Collections2.filter(services, not(instanceOf(NoOpService.class))))
            .toString();
      }
    
      /**
       * An encapsulation of all the mutable state of the {@link ServiceManager} that needs to be
       * accessed by instances of {@link ServiceListener}.
       */
      private static final class ServiceManagerState {
        final Monitor monitor = new Monitor();
    
        @GuardedBy("monitor")
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 33.2K bytes
    - Click Count (1)
  10. guava/src/com/google/common/util/concurrent/ServiceManager.java

            .add("services", Collections2.filter(services, not(instanceOf(NoOpService.class))))
            .toString();
      }
    
      /**
       * An encapsulation of all the mutable state of the {@link ServiceManager} that needs to be
       * accessed by instances of {@link ServiceListener}.
       */
      private static final class ServiceManagerState {
        final Monitor monitor = new Monitor();
    
        @GuardedBy("monitor")
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 17:49:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
Back to Top