Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ConnectionClosed (0.25 sec)

  1. okhttp/src/test/java/okhttp3/RouteFailureTest.kt

    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue May 14 17:48:07 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

              connection.noNewExchanges = true
              connectionUser.releaseConnectionNoEvents()
            }
          if (toClose != null) {
            toClose.closeQuietly()
            connectionListener.connectionClosed(connection)
          } else if (noNewExchangesEvent) {
            connectionListener.noNewExchanges(connection)
          }
        }
        return null
      }
    
      fun put(connection: RealConnection) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt

       */
      open fun connectEnd(
        connection: Connection,
        route: Route,
        call: Call,
      ) {}
    
      /**
       * Invoked when a connection is released as no longer required.
       */
      open fun connectionClosed(connection: Connection) {}
    
      /**
       * Invoked when a call is assigned a particular connection.
       */
      open fun connectionAcquired(
        connection: Connection,
        call: Call,
      ) {}
    
      /**
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  4. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

        connection: Connection,
        route: Route,
        call: Call,
      ) {
        logEvent(ConnectionEvent.ConnectEnd(System.nanoTime(), connection, route, call))
      }
    
      override fun connectionClosed(connection: Connection) = logEvent(ConnectionEvent.ConnectionClosed(System.nanoTime(), connection))
    
      override fun connectionAcquired(
        connection: Connection,
        call: Call,
      ) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  5. okhttp-testing-support/src/main/kotlin/okhttp3/ConnectionEvent.kt

        val route: Route,
        val call: Call,
      ) : ConnectionEvent() {
        override fun closes(event: ConnectionEvent): Boolean = event is ConnectStart && call == event.call && route == event.route
      }
    
      data class ConnectionClosed(
        override val timestampNs: Long,
        override val connection: Connection,
      ) : ConnectionEvent()
    
      data class ConnectionAcquired(
        override val timestampNs: Long,
        override val connection: Connection,
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt

        connection.connectionListener.connectionReleased(connection, call)
      }
    
      override fun connectionConnectionClosed(connection: RealConnection) {
        connection.connectionListener.connectionClosed(connection)
      }
    
      override fun noNewExchanges(connection: RealConnection) {
        connection.connectionListener.noNewExchanges(connection)
      }
    
      override fun doExtensiveHealthChecks(): Boolean {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Mar 06 17:33:38 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/ConnectionListenerTest.kt

        }
        assertThat(listener.recordedEventTypes()).containsExactly(
          "ConnectStart",
          "ConnectEnd",
          "ConnectionAcquired",
          "NoNewExchanges",
          "ConnectionReleased",
          "ConnectionClosed",
        )
      }
    
      @Throws(IOException::class)
      private fun assertSuccessfulEventOrder() {
        val call =
          client.newCall(
            Request.Builder()
              .url(server!!.url("/"))
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  8. okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt

            eventListener.connectionReleased(this, connection)
            connection.connectionListener.connectionReleased(connection, this)
            if (toClose != null) {
              connection.connectionListener.connectionClosed(connection)
            }
          } else {
            check(toClose == null) // If we still have a connection we shouldn't be closing any sockets.
          }
        }
    
        val result = timeoutExit(e)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  9. okhttp/api/okhttp.api

    	public fun connectFailed (Lokhttp3/Route;Lokhttp3/Call;Ljava/io/IOException;)V
    	public fun connectStart (Lokhttp3/Route;Lokhttp3/Call;)V
    	public fun connectionAcquired (Lokhttp3/Connection;Lokhttp3/Call;)V
    	public fun connectionClosed (Lokhttp3/Connection;)V
    	public fun connectionReleased (Lokhttp3/Connection;Lokhttp3/Call;)V
    	public fun noNewExchanges (Lokhttp3/Connection;)V
    }
    
    public final class okhttp3/ConnectionListener$Companion {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 15 13:41:01 UTC 2024
    - 70.2K bytes
    - Viewed (0)
Back to top