}

        // Check if we should add/remove channels
        adjustChannelCount();
    }

    private void adjustChannelCount() {
        int currentChannels = channels.size();
        int targetChannels = Math.min(maxChannels, Math.min(localInterfaces.size(), remoteInterfaces.size()));

        if (currentChannels < targetChannels) {
            // Add more channels
            establishAdditionalChannels();

     * <p>Values do not have to be unique. However, values must be non-null.
     *
     * <p>If {@code nodeU} and {@code nodeV} are not already present in this graph, this method will
     * silently {@link #addNode(Object) add} {@code nodeU} and {@code nodeV} to the graph.
     *
     * @return this {@code Builder} object
     * @throws IllegalArgumentException if the introduction of the edge would violate {@link
     *     #allowsSelfLoops()}

     */
    int FILE_READ_DATA = 0x00000001; // 1
    /**
     * Permission to write data to a file or add files to a directory
     */
    int FILE_WRITE_DATA = 0x00000002; // 2
    /**
     * Permission to append data to a file or add subdirectories
     */
    int FILE_APPEND_DATA = 0x00000004; // 3
    /**
     * Permission to read extended attributes
     */

**The Elasticsearch build will fail if any deprecated Gradle API is used.**

### Make a change in the build

There are a few guidelines to follow that should make your life easier to make changes to the elasticsearch build.
Please add a member of the `es-delivery` team as a reviewer if you're making non-trivial changes to the build.

#### Custom Plugin and Task implementations

    putEdge(N1, N2);
    assertThat(successors).containsExactlyElementsIn(graph.successors(N1));
  }

  @Override
  @Test
  public void incidentEdges_checkReturnedSetMutability() {
    assume().that(graphIsMutable()).isTrue();

    addNode(N1);
    Set<EndpointPair<Integer>> incidentEdges = graph.incidentEdges(N1);
    assertThrows(

        suggester.settings().elevateWord().add(elevateWord1);
        suggester.settings().elevateWord().add(elevateWord2);
        suggester.settings().elevateWord().add(elevateWord3);

        suggester.indexer().restoreElevateWord();
        suggester.refresh();

    /**
     * Adds a script engine.
     * @param name The name of the script engine.
     * @param scriptEngine The script engine.
     */
    public void add(final String name, final ScriptEngine scriptEngine) {
        if (name == null || scriptEngine == null) {
            throw new IllegalArgumentException(

            Repository repository = new Repository();
            repository.setId(REPO_ID);
            repository.setUrl(REPO_URL);
            repository.setLayout(REPO_LAYOUT);
            m.getRepositories().add(repository);
            return m;
        }
        return null;
    }

        shutdownListener.onShutdown();
    }

    /**
     * Adds a shutdown listener to be notified when the executor is shutting down.
     *
     * @param listener the shutdown listener to add
     */
    public void addShutdownListener(final ShutdownListener listener) {
        shutdownListener = listener;
    }

    /**
     * Interface for listening to shutdown events.
     */

 *
 * @author Chris Povirk
 */
@GwtCompatible
public enum IteratorFeature {
  /** Support for {@link Iterator#remove()}. */
  SUPPORTS_REMOVE,
  /**
   * Support for {@link ListIterator#add(Object)}; ignored for plain {@link Iterator}
   * implementations.
   */
  SUPPORTS_ADD,
  /**
   * Support for {@link ListIterator#set(Object)}; ignored for plain {@link Iterator}
   * implementations.
   */