Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ESTABLISHED (0.06 sec)

  1. src/main/java/jcifs/smb/SmbSessionImpl.java

                         * We explicitly set uid to 0 here to prevent a new
                         * SMB_COM_SESSION_SETUP_ANDX from having it's uid set to an
                         * old value when the session is re-established. Otherwise a
                         * "The parameter is incorrect" error can occur.
                         */
                        this.uid = 0;
    
                        if (trans.isSMB2()) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 68.9K bytes
    - Viewed (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

      @get:JvmName("dispatcher")
      val dispatcher: Dispatcher = builder.dispatcher
    
      /**
       * Returns an immutable list of interceptors that observe the full span of each call: from before
       * the connection is established (if any) until after the response source is selected (either the
       * origin server, cache, or both).
       */
      @get:JvmName("interceptors")
      val interceptors: List<Interceptor> =
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  3. docs/changelogs/changelog_3x.md

        duplex request bodies. Such interceptors should check `RequestBody.isDuplex()` and avoid
        accessing the request body when it is.
    
        Duplex calls require HTTP/2. If HTTP/1 is established instead the duplex call will fail. The
        most common use of duplex calls is [gRPC][grpc_http2].
    
     *  New: Prevent OkHttp from retransmitting a request body by overriding `RequestBody.isOneShot()`.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        setUp(protocol)
        server.enqueue(MockResponse(body = "abc"))
        server.enqueue(MockResponse(body = "def"))
    
        // Disconnect before the stream is created. A connection is still established!
        val call1 = client.newCall(Request(server.url("/")))
        val response = call1.execute()
        call1.cancel()
    
        // That connection is pooled, and it works.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    			healthy := erasureSetUpCount[poolIdx][setIdx].online >= poolWriteQuorums[poolIdx]
    			if !healthy && !opts.NoLogging {
    				storageLogIf(logger.SetReqInfo(ctx, reqInfo),
    					fmt.Errorf("Write quorum could not be established on pool: %d, set: %d, expected write quorum: %d, drives-online: %d",
    						poolIdx, setIdx, poolWriteQuorums[poolIdx], erasureSetUpCount[poolIdx][setIdx].online), logger.FatalKind)
    			}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbTransportImpl.java

                }
                switch (this.sbuf[0] & 0xFF) {
                case SessionServicePacket.POSITIVE_SESSION_RESPONSE:
                    if (log.isDebugEnabled()) {
                        log.debug("session established ok with " + this.address);
                    }
                    return;
                case SessionServicePacket.NEGATIVE_SESSION_RESPONSE:
                    final int errorCode = this.in.read() & 0xFF;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 69.8K bytes
    - Viewed (0)
Back to top