public ListenableFutureTester(ListenableFuture<?> future) {
    this.exec = newCachedThreadPool();
    this.future = checkNotNull(future);
    this.latch = new CountDownLatch(1);
  }

  public void setUp() {
    future.addListener(
        new Runnable() {
          @Override
          public void run() {
            latch.countDown();
          }
        },
        exec);

     * @param maxBuffers the maximum number of buffers to cache
     * @param maxSize the size of each buffer in bytes
     *
     */
    public BufferCacheImpl(final int maxBuffers, final int maxSize) {
        this.cache = new Object[maxBuffers];
        this.bufferSize = maxSize;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.BufferCache#getBuffer()
     */
    @Override
    public byte[] getBuffer() {

import jcifs.internal.util.SMBUtil;
import jcifs.util.Hexdump;

/**
 * SMB1 COM_RENAME command implementation.
 *
 * This command renames a file or directory on the SMB server.
 * It takes an old filename and new filename and performs the rename operation.
 */
public class SmbComRename extends ServerMessageBlock {

    private final int searchAttributes;
    private final String oldFileName;
    private final String newFileName;

    server.enqueue(
      MockResponse()
        .setResponseCode(HttpURLConnection.HTTP_MOVED_TEMP)
        .addHeader("Location: " + server.url("/new-path"))
        .setBody("This page has moved!"),
    )
    server.enqueue(MockResponse().setBody("This is the new location!"))
    val connection = server.url("/").toUrl().openConnection()
    val inputStream = connection.getInputStream()

	if err != nil {
		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
		return
	}

	writeSuccessResponseJSON(w, encryptedData)
}

// AddServiceAccountLDAP adds a new service account for provided LDAP username or DN
//
// PUT /minio/admin/v3/idp/ldap/add-service-account
func (a adminAPIHandlers) AddServiceAccountLDAP(w http.ResponseWriter, r *http.Request) {

     */
    public HtmlNext getVirtualHostPath(final HtmlNext page) {
        return processVirtualHost(s -> {
            final String basePath = getVirtualHostBasePath(s, page);
            return new HtmlNext(basePath + page.getRoutingPath());
        }, page);
    }

    /**
     * Gets the base path for virtual host based on the virtual host key and page.
     *
     * @param s The virtual host key

    ImmutableMap.Builder<String, PublicSuffixType> builder = ImmutableMap.builder();
    int encodedLen = encoded.length();
    int idx = 0;

    while (idx < encodedLen) {
      idx += doParseTrieToBuilder(new ArrayDeque<>(), encoded, idx, builder);
    }

    return builder.buildOrThrow();
  }

  /**
   * Parses a trie node and returns the number of characters consumed.
   *

        assertArgumentNotNull("target", target);

        return FieldUtil.get(field, target);
    }

    @Override
    public <T> T getStaticFieldValue() {
        if (!isStatic()) {
            throw new FieldNotStaticRuntimeException(beanDesc.getBeanClass(), fieldName);
        }
        return FieldUtil.get(field);
    }

    @Override
    public void setFieldValue(final Object target, final Object value) {

        final int nsalt = SMBUtil.readInt2(buffer, bufferIndex + 2);
        bufferIndex += 4;

        this.hashAlgos = new int[nalgos];
        for (int i = 0; i < nalgos; i++) {
            this.hashAlgos[i] = SMBUtil.readInt2(buffer, bufferIndex);
            bufferIndex += 2;
        }

        this.salt = new byte[nsalt];
        System.arraycopy(buffer, bufferIndex, this.salt, 0, nsalt);
        bufferIndex += nsalt;

  * Replicate a service definition and change the name of the new service appropriately.
  * Update the command section in each service.
  * Add a new MinIO server instance to the upstream directive in the Nginx configuration file.