return bulkBufferSize;
    }

    /**
     * Sets the bulk buffer size for batch operations.
     *
     * @param bulkBufferSize The bulk buffer size.
     */
    public void setBulkBufferSize(final int bulkBufferSize) {
        this.bulkBufferSize = bulkBufferSize;
    }

    /**
     * Sets the number of shards for the OpenSearch index.
     *

    /**
     * Gets the context flags indicating security capabilities
     * @return the context flags
     */
    public int getContextFlags() {
        return this.contextFlags;
    }

    /**
     * Sets the context flags indicating security capabilities
     * @param contextFlags the context flags to set
     */
    public void setContextFlags(final int contextFlags) {
        this.contextFlags = contextFlags;
    }

                Arguments.of(0x00001234, NtStatus.NT_STATUS_UNSUCCESSFUL));
    }

    @ParameterizedTest
    @MethodSource("intErrorCodes")
    @DisplayName("int ctor: sets message and NT status as expected")
    void intConstructor_populatesMessageAndStatus(int errCode, int expectedStatus) {
        // Arrange & Act: create exception with error code

package org.apache.maven.cling.invoker.mvnup.goals;

import java.nio.file.Path;
import java.util.Collections;
import java.util.HashSet;
import java.util.Set;

/**
 * Result of an upgrade strategy application.
 * Uses sets of paths to track which POMs were processed, modified, or had errors,
 * avoiding double-counting when multiple strategies affect the same POMs.
 *
 * @param processedPoms the set of POMs that were processed

// Return the disks belonging to the poolIdx, and setIdx.
func (z *erasureServerPools) GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) {
	if poolIdx < len(z.serverPools) && setIdx < len(z.serverPools[poolIdx].sets) {
		return z.serverPools[poolIdx].sets[setIdx].getDisks(), nil
	}
	return nil, fmt.Errorf("Matching pool %s, set %s not found", humanize.Ordinal(poolIdx+1), humanize.Ordinal(setIdx+1))
}

// Return the count of disks in each pool

        }
    }

    /**
     * Gets the new input word.
     *
     * @return The new input word.
     */
    public String getNewInput() {
        return newInput;
    }

    /**
     * Sets the new input word.
     *
     * @param newInput The new input word.
     */
    public void setNewInput(final String newInput) {
        this.newInput = newInput;
    }

    /**

   */
  @CanIgnoreReturnValue
  boolean addNode(N node);

  /**
   * Adds an edge connecting {@code nodeU} to {@code nodeV} if one is not already present, and sets
   * a value for that edge to {@code value} (overwriting the existing value, if any).
   *
   * <p>If the graph is directed, the resultant edge will be directed; otherwise, it will be
   * undirected.
   *

                  }

                  @Override
                  public List<String> order(List<String> insertionOrder) {
                    return new ArrayList<>(Sets.newTreeSet(insertionOrder));
                  }
                })
            .named("ForwardingNavigableSet[SafeTreeSet] with standard implementations")
            .withFeatures(
                CollectionSize.ANY,

     *
     * @return An <code>int</code> containing the flags in use for this
     *         message.
     */
    public int getFlags() {
        return this.flags;
    }

    /**
     * Sets the flags for this message.
     *
     * @param flags
     *            The flags for this message.
     */
    public void setFlags(final int flags) {
        this.flags = flags;
    }

    /**

     *
     * @return A <code>byte[]</code> containing the LanManager response.
     */
    public byte[] getLMResponse() {
        return lmResponse;
    }

    /**
     * Sets the LanManager/LMv2 response for this message.
     *
     * @param lmResponse The LanManager response.
     */
    public void setLMResponse(final byte[] lmResponse) {
        this.lmResponse = lmResponse;
    }