}
		errs := make([]error, len(erasureSet.sets))
		wk, _ := workers.New(3)
		for idx, set := range erasureSet.sets {
			if opts.Set != nil && *opts.Set != idx {
				continue
			}
			wk.Take()
			go func(idx int, set *erasureObjects) {
				defer wk.Give()

				errs[idx] = set.listAndHeal(ctx, bucket, prefix, opts.Recursive, opts.ScanMode, healEntry)
			}(idx, set)
		}
		wk.Wait()

     * Gets the negotiation result code
     * @return the result code
     */
    public int getResult() {
        return this.result;
    }

    /**
     * Sets the negotiation result code
     * @param result the result code to set
     */
    public void setResult(final int result) {
        this.result = result;
    }

    /**
     * Gets the selected authentication mechanism OID

        return buf.toString();
    }

    /**
     * Sets whether to use the filename for MIME type detection.
     *
     * @param useFilename true to use the filename for MIME type detection, false otherwise
     */
    public void setUseFilename(final boolean useFilename) {
        this.useFilename = useFilename;
    }

    /**

            throw new CrawlerSystemException("Target or replacement cannot be null.");
        }
        convertMap.put(target, replacement);
    }

    /**
     * Sets the conversion map.
     * @param convertMap The conversion map to set.
     */
    public void setConvertMap(final Map<String, String> convertMap) {
        if (convertMap == null) {
            throw new CrawlerSystemException("convertMap is null.");

    listener.assertException(error);
  }

  public void testAddListenerAfterCallback() throws Throwable {
    inputFuture.set(VALID_INPUT_DATA);

    listener.assertSuccess(getSuccessfulResult());
  }

  public void testFutureBeforeCallback() throws Throwable {
    inputFuture.set(VALID_INPUT_DATA);

    listener.assertSuccess(getSuccessfulResult());
  }

  public void testInputFutureToString() throws Throwable {

            awaitUnchecked(barrier);
          }
        };
    Set<Object> finalResults = Collections.synchronizedSet(Sets.newIdentityHashSet());
    Runnable collectResultsRunnable =
        new Runnable() {
          @Override
          public void run() {
            try {
              String result = Uninterruptibles.getUninterruptibly(currentFuture.get());

	// sets the bucket policy using the policy statement generated from `getReadOnlyBucketStatement` so that the
	// unsigned request goes through and its validated again.
	ExecObjectLayerAPIAnonTest(t, obj, "TestGetBucketLocationHandler", bucketName, "", instanceType, apiRouter, anonReq, getAnonReadOnlyBucketPolicy(bucketName))

	// HTTP request for testing when `objectLayer` is set to `nil`.

        }
    }

    /**
     * Sets a character as a word character.
     *
     * @param ctype2
     *            The array of character types.
     * @param val
     *            The character code.
     */
    protected static void wordChar(final byte[] ctype2, final int val) {
        ctype2[val] |= CT_ALPHA;
    }

    /**
     * Sets characters as whitespace.
     *
     * @param ctype2

     * @return The current encoding.
     */
    public String getEncoding() {
        return encoding;
    }

    /**
     * Sets the encoding for content extraction.
     * @param encoding The encoding to set.
     */
    public void setEncoding(final String encoding) {
        this.encoding = encoding;
    }

    /**
     * Returns the preload size for charset detection.

   *     operation
   */
  void clear();

  /**
   * Adds all of the ranges from the specified range set to this range set (optional operation).
   * After this operation, this range set is the minimal range set that {@linkplain
   * #enclosesAll(RangeSet) encloses} both the original range set and {@code other}.
   *