Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 211 - 220 of 552 for peer (0.02 seconds)

  1. guava/src/com/google/common/collect/CollectCollectors.java

        checkNotNull(valuesFunction);
        return collectingAndThen(
            flatteningToMultimap(
                input -> checkNotNull(keyFunction.apply(input)),
                input -> valuesFunction.apply(input).peek(Preconditions::checkNotNull),
                MultimapBuilder.linkedHashKeys().arrayListValues()::<K, V>build),
            ImmutableListMultimap::copyOf);
      }
    
      static <T extends @Nullable Object, K, V>
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 16.6K bytes
    - Click Count (0)
  2. .github/workflows/stale-pr.yml

    permissions: {}
    
    jobs:
      stale:
        permissions:
          pull-requests: write
    
        runs-on: ubuntu-latest
        steps:
          - uses: actions/stale@v10
            with:
              operations-per-run: 50
              ascending: true
              exempt-all-milestones: true
    
              # ISSUES (deactivated) ----------------------------------------------
              # This workflow should touch no issues, so times are set to -1
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Sep 04 22:13:29 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  3. cmd/bucket-notification-handlers.go

    	"github.com/minio/pkg/v3/policy"
    )
    
    const (
    	bucketNotificationConfig = "notification.xml"
    )
    
    // GetBucketNotificationHandler - This HTTP handler returns event notification configuration
    // as per http://docs.aws.amazon.com/AmazonS3/latest/dev/NotificationHowTo.html.
    // It returns empty configuration if its not set.
    func (api objectAPIHandlers) GetBucketNotificationHandler(w http.ResponseWriter, r *http.Request) {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 23:05:23 GMT 2024
    - 5.1K bytes
    - Click Count (0)
  4. cmd/speedtest.go

    			if globalEndpoints.NEndpoints() < concurrency {
    				concurrency = globalEndpoints.NEndpoints()
    			}
    
    			// Check if we have local disks per pool less than
    			// the concurrency make sure we choose only the "start"
    			// concurrency to be equal to the lowest number of
    			// local disks per server.
    			for _, localDiskCount := range globalEndpoints.NLocalDisksPathsPerPool() {
    				if localDiskCount < concurrency {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue May 27 15:19:03 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  5. cmd/erasure-sets.go

    	format *formatErasureV3
    
    	// erasureDisks mutex to lock erasureDisks.
    	erasureDisksMu sync.RWMutex
    
    	// Re-ordered list of disks per set.
    	erasureDisks [][]StorageAPI
    
    	// Distributed locker clients.
    	erasureLockers setsDsyncLockers
    
    	// Distributed lock owner (constant per running instance).
    	erasureLockOwner string
    
    	// List of endpoints provided on the command line.
    	endpoints PoolEndpoints
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 37K bytes
    - Click Count (1)
  6. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/MojoDescriptor.java

        public static final String MAVEN_PLUGIN = "maven-plugin";
    
        /** "once-per-session" execution strategy */
        public static final String SINGLE_PASS_EXEC_STRATEGY = "once-per-session";
    
        /** "always" execution strategy */
        public static final String MULTI_PASS_EXEC_STRATEGY = "always";
    
        private static final String DEFAULT_INSTANTIATION_STRATEGY = "per-lookup";
    
        private static final String DEFAULT_LANGUAGE = "java";
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  7. api/README

    Files in this directory are data for Go's API checker ("go tool api", in src/cmd/api).
    
    Each file is a list of API features, one per line.
    
    go1.txt (and similarly named files) are frozen once a version has been
    shipped. Each file adds new lines but does not remove any.
    
    except.txt lists features that may disappear without breaking true
    compatibility.
    
    Starting with go1.19.txt, each API feature line must end in "#nnnnn"
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Wed Jan 31 19:22:50 GMT 2024
    - 1.2K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java

     *     .maximumSize(1000)
     *     .create();
     * }
     *
     * <p>As a {@link Queue} it functions exactly as a {@link PriorityQueue}: its head element -- the
     * implicit target of the methods {@link #peek()}, {@link #poll()} and {@link #remove()} -- is
     * defined as the <i>least</i> element in the queue according to the queue's comparator. But unlike
     * a regular priority queue, the methods {@link #peekLast}, {@link #pollLast} and {@link
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 33.9K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/escape/ArrayBasedUnicodeEscaper.java

          safeMax = -1;
          safeMin = Integer.MAX_VALUE;
        }
        this.safeMin = safeMin;
        this.safeMax = safeMax;
    
        // This is a bit of a hack but lets us do quicker per-character checks in
        // the fast path code. The safe min/max values are very unlikely to extend
        // into the range of surrogate characters, but if they do we must not test
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Feb 13 15:45:16 GMT 2025
    - 8.5K bytes
    - Click Count (0)
  10. cmd/batch-replicate_test.go

        snowball: # automatically activated if the source is local
          disable: true # optionally turn-off snowball archive transfer
    #      batch: 100 # upto this many objects per archive
    #      inmemory: true # indicates if the archive must be staged locally or in-memory
    #      compress: false # S2/Snappy compressed archive
    #      smallerThan: 5MiB # create archive for all objects smaller than 5MiB
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Aug 01 12:53:30 GMT 2024
    - 7.9K bytes
    - Click Count (0)
Back to Top