Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 23 for partitions (0.07 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/collect/Iterables.java

       * <p><b>Note:</b> if {@code iterable} is a {@link List}, use {@link Lists#partition(List, int)}
       * instead.
       *
       * @param iterable the iterable to return a partitioned view of
       * @param size the desired size of each partition (the last may be smaller)
       * @return an iterable of unmodifiable lists containing the elements of {@code iterable} divided
       *     into partitions
       * @throws IllegalArgumentException if {@code size} is nonpositive
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 16 18:35:28 GMT 2025
    - 43.8K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/TopKSelector.java

          }
        }
      }
    
      /**
       * Partitions the contents of buffer in the range [left, right] around the pivot element
       * previously stored in buffer[pivotValue]. Returns the new index of the pivot element,
       * pivotNewIndex, so that everything in [left, pivotNewIndex] is ≤ pivotValue and everything in
       * (pivotNewIndex, right] is greater than pivotValue.
       */
      private int partition(int left, int right, int pivotIndex) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Aug 31 13:15:26 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  3. cmd/admin-handlers.go

    			anonymizeAddr(&localPartitions)
    			healthInfo.Sys.Partitions = append(healthInfo.Sys.Partitions, localPartitions)
    
    			peerPartitions := globalNotificationSys.GetPartitions(healthCtx)
    			for _, p := range peerPartitions {
    				anonymizeAddr(&p)
    				healthInfo.Sys.Partitions = append(healthInfo.Sys.Partitions, p)
    			}
    			partialWrite(healthInfo)
    		}
    	}
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  4. cmd/peer-rest-server.go

    	info := madmin.GetNetInfo(globalLocalNodeName, globalInternodeInterface)
    	return madminNetInfo.NewJSONWith(&info), nil
    }
    
    // GetPartitionsHandler - returns disk partition information.
    func (s *peerRESTServer) GetPartitionsHandler(_ *grid.MSS) (*grid.JSON[madmin.Partitions], *grid.RemoteErr) {
    	info := madmin.GetPartitions(context.Background(), globalLocalNodeName)
    	return madminPartitions.NewJSONWith(&info), nil
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 53.6K bytes
    - Click Count (0)
  5. guava/src/com/google/common/collect/Iterables.java

       * <p><b>Note:</b> if {@code iterable} is a {@link List}, use {@link Lists#partition(List, int)}
       * instead.
       *
       * @param iterable the iterable to return a partitioned view of
       * @param size the desired size of each partition (the last may be smaller)
       * @return an iterable of unmodifiable lists containing the elements of {@code iterable} divided
       *     into partitions
       * @throws IllegalArgumentException if {@code size} is nonpositive
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Nov 17 22:50:48 GMT 2025
    - 43.6K bytes
    - Click Count (0)
  6. guava/src/com/google/common/collect/Iterators.java

       * OutOfMemoryError}.
       *
       * @param iterator the iterator to return a partitioned view of
       * @param size the desired size of each partition (the last may be smaller)
       * @return an iterator of immutable lists containing the elements of {@code iterator} divided into
       *     partitions
       * @throws IllegalArgumentException if {@code size} is nonpositive
       */
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 16 12:42:11 GMT 2025
    - 51.4K bytes
    - Click Count (0)
  7. cmd/notification.go

    		if err != nil {
    			sys.addNodeErr(&reply[index], sys.peerClients[index], err)
    		}
    	}
    	return reply
    }
    
    // GetPartitions - Disk partition information
    func (sys *NotificationSys) GetPartitions(ctx context.Context) []madmin.Partitions {
    	reply := make([]madmin.Partitions, len(sys.peerClients))
    
    	g := errgroup.WithNErrs(len(sys.peerClients))
    	for index, client := range sys.peerClients {
    		if client == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 46K bytes
    - Click Count (0)
  8. cmd/peer-rest-client.go

    	resp, err := getNetInfoRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	return resp.ValueOrZero(), err
    }
    
    // GetPartitions - fetch disk partition information for a remote node.
    func (client *peerRESTClient) GetPartitions(ctx context.Context) (info madmin.Partitions, err error) {
    	resp, err := getPartitionsRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    	return resp.ValueOrZero(), err
    }
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/cache/CacheBuilder.java

      }
    
      /**
       * Guides the allowed concurrency among update operations. Used as a hint for internal sizing. The
       * table is internally partitioned to try to permit the indicated number of concurrent updates
       * without contention. Because assignment of entries to these partitions is not necessarily
       * uniform, the actual concurrency observed may vary. Ideally, you should choose a value to
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 51.9K bytes
    - Click Count (0)
  10. docs/recipes.md

            }
          }
        ```
    
    ### Timeouts ([.kt][ConfigureTimeoutsKotlin], [.java][ConfigureTimeoutsJava])
    
    Use timeouts to fail a call when its peer is unreachable. Network partitions can be due to client connectivity problems, server availability problems, or anything between. OkHttp supports connect, write, read, and full call timeouts.
    
    === ":material-language-kotlin: Kotlin"
        ```kotlin
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Aug 30 17:01:12 GMT 2025
    - 47.8K bytes
    - Click Count (0)
Back to Top