throw new LdapOperationException("Failed to search " + dn, e);
        }
    }

    /**
     * An interface for consuming search results.
     */
    interface SearchConsumer {
        /**
         * Accepts a list of search results.
         *
         * @param t The list of search results.
         * @throws NamingException If a naming exception occurs.

en",g.borderColor="darkgreen",g.color="darkgreen",h=d.strong),e.css(g).text(h)})}});var f=function(b,c,d,e,f){var g=c.valAttr("req-params")||c.data("validation-req-params")||{},h=c.valAttr("param-name")||c.attr("name"),i=function(a,b){b(a)};if(!h)throw new Error("Missing input name used for http requests made by server validator");g||(g={}),"string"==typeof g&&(g=a.parseJSON(g)),g[h]=d,a.ajax({url:b,type:"POST",cache:!1,data:g,dataType:"json",error:function(a){return i({valid:!1,message:"Connection...

      // permitted not to throw because it would be a no-op
    }
    expectUnchanged();
  }

  @MapFeature.Require(value = SUPPORTS_PUT, absent = ALLOWS_NULL_KEY_QUERIES)
  public void testReplace_absentNullKeyUnsupported() {
    try {
      getMap().replace(null, v3());
    } catch (NullPointerException tolerated) {
      // permitted not to throw because it would be a no-op
    }
    expectUnchanged();

    }

    /**
     * Decode a list of AvPairs
     *
     * @param data the encoded AV pairs data
     * @return individual pairs
     * @throws CIFSException if decoding fails
     */
    public static List<AvPair> decode(final byte[] data) throws CIFSException {
        final List<AvPair> pairs = new LinkedList<>();
        int pos = 0;
        boolean foundEnd = false;
        while (pos + 4 <= data.length) {

    // Test executePython with blank filename
    public void test_executePython_blankFilename() {
        pythonJob.filename("");

        try {
            pythonJob.executePython();
            fail("Should throw JobProcessingException");
        } catch (JobProcessingException e) {
            assertEquals("Python script is not specified.", e.getMessage());
        }
    }

    // Test executePython with null filename

   * @param n the number of characters to skip
   * @throws EOFException if this stream reaches the end before skipping all the characters
   * @throws IOException if an I/O error occurs
   */
  public static void skipFully(Reader reader, long n) throws IOException {
    checkNotNull(reader);
    while (n > 0) {
      long amt = reader.skip(n);
      if (amt == 0) {
        throw new EOFException();
      }
      n -= amt;
    }

      .build();

    Response response = client.newCall(request).execute();
    if (!response.isSuccessful()) throw new IOException("Unexpected code " + response);

    System.out.println(response.body().string());
  }

  public static void main(String... args) throws Exception {
    new UploadProgress().run();
  }

  private static class ProgressRequestBody extends RequestBody {

     * @param handle
     * @param th
     * @throws SmbException
     */
    SmbPipeInputStream(final SmbPipeHandleImpl handle, final SmbTreeHandleImpl th) throws CIFSException {
        super(handle.getPipe(), th, null);
        this.handle = handle;
    }

    /**
     * Ensures that the tree connection is established.
     *
     * @return the tree handle implementation
     * @throws CIFSException if a connection error occurs
     */

        try {
            ruleManager.addRule(-1, rule2);
            fail("Should throw IndexOutOfBoundsException for negative index");
        } catch (IndexOutOfBoundsException e) {
            // Expected
        }

        try {
            ruleManager.addRule(5, rule2);
            fail("Should throw IndexOutOfBoundsException for index > size");
        } catch (IndexOutOfBoundsException e) {

     * errors by throwing an {@link Exception}. Error conditions should provide
     * sufficient detail to aid troubleshooting.</p>
     *
     * @throws Exception if any issue occurs that prevents the successful execution
     *                   of the Mojo
     */
    void execute() throws Exception;