Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 803 for connecting (0.05 sec)

  1. tests/test_tutorial/test_websockets/test_tutorial003.py

    
    def test_websocket_handle_disconnection(client: TestClient):
        with (
            client.websocket_connect("/ws/1234") as connection,
            client.websocket_connect("/ws/5678") as connection_two,
        ):
            connection.send_text("Hello from 1234")
            data1 = connection.receive_text()
            assert data1 == "You wrote: Hello from 1234"
            data2 = connection_two.receive_text()
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Dec 17 21:25:59 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  2. container-tests/src/test/java/okhttp3/containers/BasicProxyTest.kt

        }
      }
    
      @Test
      fun testUrlConnectionDirect() {
        testRequest {
          val url = URI(mockServer.endpoint + "/person?name=peter").toURL()
    
          val connection = url.openConnection() as HttpURLConnection
    
          assertThat(
            connection.inputStream
              .source()
              .buffer()
              .readUtf8(),
          ).contains("Peter the person")
        }
      }
    
      @Test
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 6.2K bytes
    - Viewed (1)
  3. src/main/java/jcifs/internal/smb2/rdma/RdmaTransport.java

                    log.info("RDMA connection established to {}", delegate.getRemoteAddress());
                } catch (IOException e) {
                    log.warn("Failed to establish RDMA connection: {}", e.getMessage());
                    throw e;
                }
            }
        }
    
        /**
         * Checks if RDMA connection is available.
         *
         * @return true if RDMA connection is active
         */
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb2/rdma/tcp/TcpRdmaConnection.java

                socket.setKeepAlive(true);
    
                state = RdmaConnectionState.CONNECTED;
                log.debug("TCP RDMA connection established to {}", remoteAddress);
    
            } catch (IOException e) {
                state = RdmaConnectionState.ERROR;
                throw new IOException("TCP RDMA connection failed", e);
            }
        }
    
        @Override
        public void send(ByteBuffer data, RdmaMemoryRegion region) throws IOException {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 05:11:12 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  5. okhttp/src/androidMain/baseline-prof.txt

    Lokhttp3/internal/connection/ExchangeFinder;
    Lokhttp3/internal/connection/FastFallbackExchangeFinder;
    Lokhttp3/internal/connection/RealCall$AsyncCall;
    Lokhttp3/internal/connection/RealCall$CallReference;
    Lokhttp3/internal/connection/RealCall$timeout$1;
    Lokhttp3/internal/connection/RealCall;
    Lokhttp3/internal/connection/RealConnection;
    Lokhttp3/internal/connection/RealConnectionPool$cleanupTask$1;
    Lokhttp3/internal/connection/RealConnectionPool;
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (1)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ReusePlan.kt

     */
    package okhttp3.internal.connection
    
    /** Reuse a connection from the pool. */
    internal class ReusePlan(
      val connection: RealConnection,
    ) : RoutePlanner.Plan {
      override val isReady = true
    
      override fun connectTcp() = error("already connected")
    
      override fun connectTlsEtc() = error("already connected")
    
      override fun handleSuccess() = connection
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 1K bytes
    - Viewed (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/internal/http/SocketFailureTest.kt

      class SocketClosingEventListener : EventListener() {
        var shouldClose: Boolean = false
        var lastSocket: Socket? = null
    
        override fun connectionAcquired(
          call: Call,
          connection: Connection,
        ) {
          lastSocket = connection.socket()
        }
    
        override fun requestHeadersStart(call: Call) {
          if (shouldClose) {
            lastSocket!!.close()
          }
        }
      }
    
      @Test
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Jul 29 21:11:09 UTC 2025
    - 3K bytes
    - Viewed (0)
  8. internal/http/close.go

    		// Without this closing connection would disallow re-using
    		// the same connection for future uses.
    		//  - http://stackoverflow.com/a/17961593/4465767
    		defer respBody.Close()
    		xioutil.DiscardReader(respBody)
    	}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Jan 18 07:03:17 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  9. src/test/java/jcifs/smb/SmbTreeHandleImplTest.java

        @DisplayName("getSession returns underlying session from tree connection")
        void getSessionReturnsUnderlying() {
            // Verifies getSession() exposes the session provided by the connection
            assertSame(session, handle.getSession());
            verify(treeConnection).getSession();
        }
    
        @Test
        @DisplayName("ensureDFSResolved forwards to tree connection with locator")
        void ensureDFSResolvedDelegates() throws Exception {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 14.4K bytes
    - Viewed (0)
  10. docs/en/docs/deployment/https.md

    After this, the client and the server have an **encrypted TCP connection**, this is what TLS provides. And then they can use that connection to start the actual **HTTP communication**.
    
    And that's what **HTTPS** is, it's just plain **HTTP** inside a **secure TLS connection** instead of a pure (unencrypted) TCP connection.
    
    /// tip
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 19:34:08 UTC 2025
    - 14.3K bytes
    - Viewed (0)
Back to top