Search Options

Results per page
Sort
Preferred Languages
Advance

Results 271 - 280 of 512 for Connection (0.06 sec)

  1. README.md

        for (SmbFile f : file.listFiles()) {
            System.out.println(f.getName());
        }
    }
    ```
    
    ## Configuration
    
    ### Basic Configuration Properties
    
    ```properties
    # Connection settings
    jcifs.smb.client.connTimeout=35000
    jcifs.smb.client.soTimeout=180000
    jcifs.smb.client.responseTimeout=30000
    
    # Authentication
    jcifs.smb.client.domain=WORKGROUP
    jcifs.smb.client.username=guest
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 09:24:52 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  2. 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)
  3. src/test/java/jcifs/util/transport/TransportTest.java

                    transport.setState(state);
                    assertFalse(transport.isFailed(), "State " + state + " should not be failed");
                }
            }
        }
    
        @Nested
        @DisplayName("Connection lifecycle tests")
        class ConnectionLifecycleTests {
    
            @Test
            @DisplayName("connect should return true if already connected")
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/RecordingExecutor.kt

    import assertk.assertions.containsExactly
    import java.util.concurrent.AbstractExecutorService
    import java.util.concurrent.RejectedExecutionException
    import java.util.concurrent.TimeUnit
    import okhttp3.internal.connection.RealCall
    import okhttp3.internal.finishedAccessor
    
    internal class RecordingExecutor(
      private val dispatcherTest: DispatcherTest,
    ) : AbstractExecutorService() {
      private var shutdown: Boolean = false
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  5. docs/smb3-features/03-multi-channel-design.md

        DISCONNECTED(0),     // Not connected
        CONNECTING(1),       // Connection in progress
        AUTHENTICATING(2),   // Authentication in progress
        ESTABLISHED(3),      // Ready for use
        BINDING(4),         // Channel binding in progress
        ACTIVE(5),          // Actively transferring data
        FAILED(6),          // Connection failed
        CLOSING(7);         // Closing connection
        
        private final int value;
        
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  6. mockwebserver/src/main/kotlin/mockwebserver3/SocketEffect.kt

        public val shutdownOutput: Boolean = false,
      ) : SocketEffect
    
      /**
       * On HTTP/2, send a [GOAWAY frame](https://tools.ietf.org/html/rfc7540#section-6.8) immediately
       * after the response and will close the connection when the client's socket is exhausted.
       *
       * On HTTP/1 this closes the socket.
       */
      public object ShutdownConnection : SocketEffect
    
      /**
       * On HTTP/2 this will send the error code on the stream.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb1/dcerpc/DcerpcHandle.java

         */
        protected int max_xmit = 4280;
        /**
         * Maximum receive buffer size for DCERPC messages
         */
        protected int max_recv = max_xmit;
        /**
         * The current state of the DCERPC connection
         */
        protected int state = 0;
        /**
         * The security provider for authentication and message protection
         */
        protected DcerpcSecurityProvider securityProvider = null;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Settings.kt

     * limitations under the License.
     */
    package okhttp3.internal.http2
    
    /**
     * Settings describe characteristics of the sending peer, which are used by the receiving peer.
     * Settings are [connection][Http2Connection] scoped.
     */
    class Settings {
      /** Bitfield of which flags that values. */
      private var set: Int = 0
    
      /** Flag values. */
      private val values = IntArray(COUNT)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Protocol.kt

       *
       * [rfc_7540_34]: https://datatracker.ietf.org/doc/html/rfc7540#autoid-10
       */
      H2_PRIOR_KNOWLEDGE("h2_prior_knowledge"),
    
      /**
       * QUIC (Quick UDP Internet Connection) is a new multiplexed and secure transport atop UDP,
       * designed from the ground up and optimized for HTTP/2 semantics. HTTP/1.1 semantics are layered
       * on HTTP/2.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jun 23 18:58:57 UTC 2025
    - 4.4K bytes
    - Viewed (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/WebSocketListener.kt

       */
      open fun onClosing(
        webSocket: WebSocket,
        code: Int,
        reason: String,
      ) {
      }
    
      /**
       * Invoked when both peers have indicated that no more messages will be transmitted and the
       * connection has been successfully released. No further calls to this listener will be made.
       */
      open fun onClosed(
        webSocket: WebSocket,
        code: Int,
        reason: String,
      ) {
      }
    
      /**
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 2K bytes
    - Viewed (0)
Back to top