ConnPool
}

// NewPreparedStmtDB creates and initializes a new instance of PreparedStmtDB.
//
// Parameters:
// - connPool: A connection pool that implements the ConnPool interface, used for managing database connections.
// - maxSize: The maximum number of prepared statements that can be stored in the statement store.

    /** Task for monitoring idle connections */
    private TimeoutTask connectionMonitorTask;

    /** Connection timeout in milliseconds */
    protected Integer connectionTimeout;

    /** Maximum total number of connections */
    protected Integer maxTotalConnections;

    /** Maximum connections per route */
    protected Integer maxConnectionsPerRoute;

 */
package jcifs;

import java.io.IOException;
import java.net.InetAddress;
import java.net.UnknownHostException;

/**
 * This is an internal API for managing pools of SMB connections
 *
 * @author mbechler
 *
 * <p>This interface is intended for internal use.</p>
 */
public interface SmbTransportPool {

    /**
     * Gets an SMB transport connection to the specified server.
     *

  override fun createRequestBody(
    request: Request,
    contentLength: Long,
  ): Sink =
    when {
      request.body?.isDuplex() == true -> {
        throw ProtocolException(
          "Duplex connections are not supported for HTTP/1",
        )
      }

      request.isChunked -> {
        newChunkedSink()
      }

      // Stream a request body of unknown length.
      contentLength != -1L -> {

package okhttp3

import java.net.InetAddress
import java.net.InetSocketAddress
import java.net.Socket
import java.net.SocketAddress
import okhttp3.internal.platform.Platform

/**
 * A [SocketFactory] that redirects connections to [defaultAddress] or specific overridden address via [set].
 */
class SpecificHostSocketFactory(
  val defaultAddress: InetSocketAddress?,
) : DelegatingSocketFactory(getDefault()) {

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import jcifs.CIFSException;
import jcifs.Configuration;

/**
 * SMB3 Multi-Channel Manager.
 *
 * Manages multiple network connections for improved performance and redundancy
 * as specified in the SMB 3.x multi-channel feature.
 */
public class MultiChannelManager {

    private static final Logger log = LoggerFactory.getLogger(MultiChannelManager.class);

		},
		config.HelpKV{
			Key:         target.MqttKeepAliveInterval,
			Description: "keep-alive interval for MQTT connections in s,m,h,d",
			Optional:    true,
			Type:        "duration",
		},
		config.HelpKV{
			Key:         target.MqttReconnectInterval,
			Description: "reconnect interval for MQTT connections in s,m,h,d",
			Optional:    true,
			Type:        "duration",
		},
		config.HelpKV{

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
package jcifs.internal.smb2.multichannel;

/**
 * Load balancing strategies for multi-channel connections
 */
public enum LoadBalancingStrategy {
    /**
     * Round-robin selection through available channels
     */
    ROUND_ROBIN,

    /**
     * Select the least busy channel based on pending operations

        maxIdleConnections = 2,
      )
    val c1 = factory.newConnection(pool, routeA1, 50L)
    val c2 = factory.newConnection(pool, routeB1, 75L)

    // With 2 connections, there's no need to evict until the connections time out.
    assertThat(pool.closeConnections(100L)).isEqualTo(50L)
    assertThat(pool.connectionCount()).isEqualTo(2)
    assertThat(c1.socket().isClosed).isFalse()

  Set<N> adjacentNodes();

  Set<N> predecessors();

  Set<N> successors();

  /**
   * Returns an iterator over the incident edges.
   *
   * @param thisNode The node that this all of the connections in this class are connected to.
   */
  Iterator<EndpointPair<N>> incidentEdgeIterator(N thisNode);

  /**
   * Returns the value associated with the edge connecting the origin node to {@code node}, or null