*
   * <p>This uses an efficient binary recursive algorithm to compute the factorial with balanced
   * multiplies. It also removes all the 2s from the intermediate products (shifting them back in at
   * the end).
   *
   * @throws IllegalArgumentException if {@code n < 0}
   */
  public static BigInteger factorial(int n) {
    checkNonNegative("n", n);

    /**
     * Shutdown the resource manager
     */
    public void shutdown() {
        if (shutdownInProgress) {
            return;
        }

        shutdownInProgress = true;
        log.info("Shutting down ResourceManager");

        // Cancel cleanup task
        if (cleanupTask != null) {
            cleanupTask.cancel(false);
        }

        // Force cleanup of all resources

        try {
            cleanupScheduler.awaitTermination(5, TimeUnit.SECONDS);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            log.warn("Interrupted while shutting down cleanup scheduler", e);
        }

        log.info("Authentication rate limiter closed");
    }

    /**
     * Per-account attempt tracking
     */
    private static class AccountAttempts {

    connection.setReadTimeout(500)
    try {
      connection.getResponseCode()
      fail<Any>()
    } catch (expected: SocketTimeoutException) {
    }

    // Shutting down the server should unblock the dispatcher.
    server.shutdown()
  }

  @Test
  fun requestUrlReconstructed() {
    server.enqueue(MockResponse().setBody("hello world"))

// The close built-in function closes a channel, which must be either
// bidirectional or send-only. It should be executed only by the sender,
// never the receiver, and has the effect of shutting down the channel after
// the last sent value is received. After the last value has been received
// from a closed channel c, any receive from c will succeed without

type BucketOptions struct {
	Deleted    bool // true only when site replication is enabled
	Cached     bool // true only when we are requesting a cached response instead of hitting the disk for example ListBuckets() call.
	NoMetadata bool
}

// SetReplicaStatus sets replica status and timestamp for delete operations in ObjectOptions

                    totalRequests, totalChannelsCreated);
        }
    }

    /**
     * Cleanup and shutdown the multi-channel manager.
     */
    public void shutdown() {
        log.info("Shutting down MultiChannelManager");

        // Close all channels
        for (String sessionId : new ArrayList<>(sessionChannels.keySet())) {
            removeChannels(sessionId);
        }

        if (ref == null || ref.get() == null) {
            fileCache.remove(path);
        }
    }

    /**
     * Shutdown the lease manager
     */
    public void shutdown() {
        log.info("Shutting down lease manager");

        // Stop cleanup executor
        if (cleanupExecutor != null) {
            cleanupExecutor.shutdown();
            try {

            // When: Trying to encode (may throw exception due to deferred buffer)
            // Then: Should at least call the basic encoding methods before hitting deferred
            assertThrows(Exception.class, () -> {
                unicodeString.encode(mockNdrBuffer);
            }, "Should encounter issue with deferred buffer access");

    
    @Override
    public void shutdown() {
        if (endpointGroup != null) {
            try {
                endpointGroup.close();
            } catch (Exception e) {
                log.error("Error shutting down DiSNI", e);
            }
        }
        initialized = false;
    }
}

class DisniRdmaConnection extends RdmaConnection {
    private final RdmaActiveEndpoint endpoint;