Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 512 for Connections (0.23 sec)

  1. CHANGELOG.md

        in logs. For best security, don't put sensitive information in query parameters.
    
     *  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)
  2. src/main/java/jcifs/config/BaseConfiguration.java

        protected int smbSessionTimeout = SmbConstants.DEFAULT_SO_TIMEOUT;
        /** Whether idle timeout is disabled for connections */
        protected boolean idleTimeoutDisabled = false;
        /** Local address to bind for SMB connections */
        protected InetAddress smbLocalAddress;
        /** Local port to bind for SMB connections */
        protected int smbLocalPort = 0;
        /** Maximum multiplex count for concurrent requests */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 36.5K bytes
    - Viewed (0)
  3. src/main/java/jcifs/CIFSContext.java

         */
        SmbPipeResource getPipe(String url, int pipeType) throws CIFSException;
    
        /**
         * Close all connections and release resources associated with this context
         *
         * @return whether any connection was still in use
         * @throws CIFSException if an error occurs during cleanup
         */
        boolean close() throws CIFSException;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  4. src/main/java/jcifs/SmbTransportPool.java

         * Get transport connection
         *
         * @param tc
         *            context to use
         * @param address the server address
         * @param port the port number
         * @param exclusive
         *            whether to acquire an unshared connection
         * @param forceSigning
         *            whether to enforce SMB signing on this connection
         * @return a transport connection to the target
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 7.5K bytes
    - Viewed (0)
  5. src/main/java/jcifs/smb/NtStatus.java

                "The specified network name is no longer available.", "Network access is denied.", "Bad device type",
                "The network name cannot be found.",
                "No more connections can be made to this remote computer at this time because there are already as many connections as the computer can accept.",
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 14.9K bytes
    - Viewed (0)
  6. src/test/java/jcifs/internal/witness/MockWitnessService.java

                    // In a real implementation, this would handle RPC requests
                    // For the mock, we just accept connections and close them
                    clientSocket.close();
                } catch (IOException e) {
                    if (running.get()) {
                        log.debug("Error accepting client connection", e);
                    }
                }
            }
        }
    
        @Override
        public void close() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 09:06:40 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  7. 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 (7)
  8. prepare_stmt.go

    // Returns:
    // - A pointer to a PreparedStmtDB instance, which manages prepared statements using the provided connection pool and configuration.
    func NewPreparedStmtDB(connPool ConnPool, maxSize int, ttl time.Duration) *PreparedStmtDB {
    	return &PreparedStmtDB{
    		ConnPool: connPool,                     // Assigns the provided connection pool to manage database connections.
    Registered: Sun Sep 07 09:35:13 UTC 2025
    - Last Modified: Fri Apr 25 08:22:26 UTC 2025
    - 5.7K bytes
    - Viewed (0)
  9. okcurl/src/main/kotlin/okhttp3/curl/Main.kt

      ).int()
        .default(DEFAULT_TIMEOUT)
    
      val followRedirects: Boolean by option("-L", "--location").help("Follow redirects").flag()
    
      val allowInsecure: Boolean by option("-k", "--insecure").help("Allow connections to SSL sites without certs").flag()
    
      val showHeaders: Boolean by option("-i", "--include").help("Include protocol headers in the output").flag()
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6K bytes
    - Viewed (0)
  10. 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)
Back to top