- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 146 for connectionsOf (0.29 sec)
-
src/main/java/jcifs/SmbTransportPool.java
*/ 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. *
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 7.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
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);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 20.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
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 -> newKnownLengthSink() // Stream a request body of a known length.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 17.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnection.kt
allocationLimit = settings.getMaxConcurrentStreams() if (allocationLimit < oldLimit) { // We might need new connections to keep policies satisfied connectionPool.scheduleOpener(route.address) } else if (allocationLimit > oldLimit) { // We might no longer need some connections connectionPool.scheduleCloser() } } } override fun handshake(): Handshake? = handshake
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 14.9K bytes - Viewed (0) -
CHANGELOG.md
* New: `ConnectionPool.setPolicy()` configures a minimum connection pool size for a target address. Use this to proactively open HTTP connections. Connections opened to fulfill this policy are subject to the connection pool's `keepAliveDuration` but do not count against the pool-wide `maxIdleConnections` limit.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Mon Jul 07 19:32:33 UTC 2025 - 31.6K bytes - Viewed (1) -
src/main/java/jcifs/internal/smb2/multichannel/LoadBalancingStrategy.java
* 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
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 1.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/PoolConnectionUser.kt
import java.net.Proxy import java.net.Socket import okhttp3.Connection import okhttp3.Handshake import okhttp3.HttpUrl import okhttp3.Protocol import okhttp3.Route /** * A user that is a connection pool creating connections in the background * without an intent to immediately use them. */ object PoolConnectionUser : ConnectionUser { override fun addPlanToCancel(connectPlan: ConnectPlan) { }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 2.6K bytes - Viewed (0) -
android/guava/src/com/google/common/graph/GraphConnections.java
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
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.4K bytes - Viewed (0) -
internal/stmt_store/stmt_store.go
// isTransaction: Indicates whether this operation is part of a transaction, which may affect the caching strategy. // connPool: A connection pool that provides database connections. // locker: A synchronization lock that is unlocked after initialization to avoid deadlocks. // Returns: // *Stmt: A newly created statement object for executing SQL operations.
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Sun Apr 27 06:05:16 UTC 2025 - 6K bytes - Viewed (0) -
docs/SMB3_IMPLEMENTATION_PLAN.md
- Update `SmbFile` caching logic to use leases - Add lease break handling in `SmbTransport` --- ### Phase 2: Persistent Handles **Priority: HIGH** | **Estimated Effort: 4-5 weeks** Persistent handles allow connections to survive network interruptions and server failovers. #### 2.1 Core Persistent Handle Infrastructure ``` Package: jcifs.internal.smb2.persistent ├── PersistentHandleContext.java - Persistent handle create context
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 10.7K bytes - Viewed (0)