Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 91 - 100 of 507 for Connection (0.04 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/RequestBody.kt

       *
       * By default OkHttp will attempt to retransmit request bodies when the original request fails
       * due to any of:
       *
       *  * A stale connection. The request was made on a reused connection and that reused connection
       *    has since been closed by the server.
       *  * A client timeout (HTTP 408).
       *  * A authorization challenge (HTTP 401 and 407) that is satisfied by the [Authenticator].
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 14:16:29 GMT 2025
    - 9.3K bytes
    - Click Count (0)
  2. internal/event/target/nats.go

    		return err
    	}
    
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to NATS server.
    func (target *NATSTarget) Close() (err error) {
    	close(target.quitCh)
    	if target.stanConn != nil {
    		// closing the streaming connection does not close the provided NATS connection.
    		if target.stanConn.NatsConn() != nil {
    			target.stanConn.NatsConn().Close()
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Apr 27 04:30:57 GMT 2025
    - 13.5K bytes
    - Click Count (0)
  3. impl/maven-core/src/test/java/org/apache/maven/exception/DefaultExceptionHandlerTest.java

        @Test
        void testJdk7ipv6() {
            ConnectException connEx = new ConnectException("Connection refused: connect");
            IOException ioEx = new IOException("Unable to establish loopback connection", connEx);
            MojoExecutionException mojoEx =
                    new MojoExecutionException("Error executing Jetty: Unable to establish loopback connection", ioEx);
    
            ExceptionHandler exceptionHandler = new DefaultExceptionHandler();
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Oct 25 12:31:46 GMT 2024
    - 6.3K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Authenticator.kt

     * server.
     *
     * ## Preemptive Authentication
     *
     * To make HTTPS calls using an HTTP proxy server OkHttp must first negotiate a connection with
     * the proxy. This proxy connection is called a "TLS Tunnel" and is specified by
     * [RFC 2817][1]. The HTTP CONNECT request that creates this tunnel connection is special: it
     * does not participate in any [interceptors][Interceptor] or [event listeners][EventListener]. It
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 5.5K bytes
    - Click Count (0)
  5. .github/workflows/mint/nginx-4-node.conf

                proxy_connect_timeout 300;
                # Default is HTTP/1, keepalive is only enabled in HTTP/1.1
                proxy_http_version 1.1;
                proxy_set_header Connection "";
                chunked_transfer_encoding off;
    
                proxy_pass http://minio;
            }
        }
    
        server {
            listen       9001;
            listen  [::]:9001;
            server_name  localhost;
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 15 16:52:29 GMT 2024
    - 3.1K bytes
    - Click Count (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Address.kt

    import okhttp3.internal.toImmutableList
    
    /**
     * A specification for a connection to an origin server. For simple connections, this is the
     * server's hostname and port. If an explicit proxy is requested (or [no proxy][Proxy.NO_PROXY] is
     * explicitly requested), this also includes that proxy information. For secure connections the
     * address also includes the SSL socket factory, hostname verifier, and certificate pinner.
     *
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/ConnectInterceptor.kt

     *  See the License for the specific language governing permissions and
     *  limitations under the License.
     */
    package okhttp3.internal.connection
    
    import java.io.IOException
    import okhttp3.Interceptor
    import okhttp3.Response
    import okhttp3.internal.http.RealInterceptorChain
    
    /**
     * Opens a connection to the target server and proceeds to the next interceptor. The network might
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteDatabase.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.connection
    
    import okhttp3.Route
    
    /**
     * A denylist of failed routes to avoid when creating a new connection to a target address. This is
     * used so that OkHttp can learn from its mistakes: if there was a failure attempting to connect to
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Fri Dec 27 13:39:56 GMT 2024
    - 1.5K bytes
    - Click Count (0)
  9. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RetryTlsHandshake.kt

     * limitations under the License.
     */
    package okhttp3.internal.connection
    
    import java.io.InterruptedIOException
    import java.net.ProtocolException
    import java.security.cert.CertificateException
    import javax.net.ssl.SSLException
    import javax.net.ssl.SSLHandshakeException
    import javax.net.ssl.SSLPeerUnverifiedException
    import okio.IOException
    
    /** Returns true if a TLS connection should be retried after [e]. */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  10. mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt

        assertThat(requestsMade.size).isEqualTo(0)
        mockWebServer.dispatcher = dispatcher
        val url = mockWebServer.url("/").toUrl()
        val conn = url.openConnection() as HttpURLConnection
        conn.responseCode // Force the connection to hit the "server".
        // Make sure our dispatcher got the request.
        assertThat(requestsMade.size).isEqualTo(1)
      }
    
      @Test
      fun outOfOrderResponses() {
        val firstResponseCode = AtomicInteger()
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Wed Jun 18 12:28:21 GMT 2025
    - 3.2K bytes
    - Click Count (1)
Back to Top