Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for unblocking (0.21 sec)

  1. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

        assumeTrue(Build.VERSION.SDK_INT >= 23)
    
        val request = Request.Builder().url("http://squareup.com/robots.txt").build()
    
        try {
          client.newCall(request).execute()
          fail<Any>("expected cleartext blocking")
        } catch (_: java.net.UnknownServiceException) {
        }
      }
    
      data class HowsMySslResults(
        val unknown_cipher_suite_supported: Boolean,
        val beast_vuln: Boolean,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Jan 20 10:30:28 GMT 2024
    - 27K bytes
    - Viewed (1)
  2. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

            } finally {
              taskRunner.lock.withLock {
                activeThreads--
                startNextTask()
              }
            }
          }
        }
      }
    
      /**
       * This blocking queue hooks into a fake clock rather than using regular JVM timing for functions
       * like [poll]. It is only usable within task faker tasks.
       */
      private inner class TaskFakerBlockingQueue<T>(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 12.6K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      // Internal state of this connection is guarded by 'lock'. No blocking operations may be
      // performed while holding this lock!
      //
      // Socket writes are guarded by frameWriter.
      //
      // Socket reads are unguarded but are only made by the reader thread.
      //
      // Certain operations (like SYN_STREAM) need to synchronize on both the frameWriter (to do
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt

     *     failed connect attempts (such as trying the next [ConnectionSpec]), or as attempts that lost
     *     a race in fast follow-up.
     *
     *  4. If there's no existing connection, make a list of routes (which may require blocking DNS
     *     lookups) and attempt a new connection them. When failures occur, retries iterate the list of
     *     available routes.
     *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 4.2K bytes
    - Viewed (0)
  5. README.md

    configured to fall back for broad connectivity.
    
    Using OkHttp is easy. Its request/response API is designed with fluent builders and immutability. It
    supports both synchronous blocking calls and async calls with callbacks.
    
    
    Get a URL
    ---------
    
    This program downloads a URL and prints its contents as a string. [Full source][get_example].
    
    ```java
    OkHttpClient client = new OkHttpClient();
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Dec 20 23:27:07 GMT 2023
    - 6.2K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt

        val pooled1 = planReusePooledConnection()
        if (pooled1 != null) return pooled1
    
        // Attempt a deferred plan before new routes.
        if (deferredPlans.isNotEmpty()) return deferredPlans.removeFirst()
    
        // Do blocking calls to plan a route for a new connection.
        val connect = planConnect()
    
        // Now that we have a set of IP addresses, make another attempt at getting a connection from
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 12K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

      headers: Headers?,
    ) {
      internal val lock: ReentrantLock = ReentrantLock()
      val condition: Condition = lock.newCondition()
    
      // Internal state is guarded by [lock]. No long-running or potentially blocking operations are
      // performed while the lock is held.
    
      /** The bytes consumed and acknowledged by the stream. */
      val readBytes: WindowCounter = WindowCounter(id)
    
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 23.2K bytes
    - Viewed (1)
  8. okhttp/src/main/kotlin/okhttp3/WebSocket.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3
    
    import okio.ByteString
    
    /**
     * A non-blocking interface to a web socket. Use the [factory][WebSocket.Factory] to create
     * instances; usually this is [OkHttpClient].
     *
     * ## Web Socket Lifecycle
     *
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 5.3K bytes
    - Viewed (0)
Back to top