- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for QThread (0.24 sec)
-
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
takeEvent() } } private fun logEvent(e: ConnectionEvent) { if (e.connection != null) { assertThat(Thread.holdsLock(e.connection), "Called with lock $${e.connection}") .isFalse() } for (lock in forbiddenLocks) { assertThat(Thread.holdsLock(lock), "Called with lock $lock") .isFalse() } if (enforceOrder) { checkForStartEvent(e) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Interceptor.kt
* * * For asynchronous calls made with [Call.enqueue], an [IOException] is propagated to the caller * indicating that the call was canceled. The interceptor's exception is delivered to the current * thread's [uncaught exception handler][Thread.UncaughtExceptionHandler]. By default this * crashes the application on Android and prints a stacktrace on the JVM. (Crash reporting * libraries may customize this behavior.) *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/internal/SleepNanos.kt
* */ package mockwebserver3.internal internal fun sleepNanos(nanos: Long) { val ms = nanos / 1_000_000L val ns = nanos - (ms * 1_000_000L) if (ms > 0L || nanos > 0) { Thread.sleep(ms, ns.toInt()) }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Jan 07 16:05:34 GMT 2024 - 811 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Callback.kt
* proceed to read the response body with [Response.body]. The response is still live until its * response body is [closed][ResponseBody]. The recipient of the callback may consume the response * body on another thread. * * Note that transport-layer success (receiving a HTTP response code, headers and body) does not * necessarily indicate application-layer success: `response` may still indicate an unhappy HTTP
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.5K bytes - Viewed (0) -
docs/contribute/concurrency.md
So we have a dedicated thread for every socket that just reads frames and dispatches them. The reader thread must never run application-layer code. Otherwise one slow stream can hold up the entire connection.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 16:35:36 GMT 2022 - 7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
import okhttp3.internal.okHttpName /** * A set of tasks that are executed in sequential order. * * Work within queues is not concurrent. This is equivalent to each queue having a dedicated thread * for its work; in practice a set of queues may share a set of threads to save resources. */ class TaskQueue internal constructor( internal val taskRunner: TaskRunner, internal val name: String, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, pipe.source, metadata, 5) val future1 = executor.submit(sourceReader(relay.newSource())) val future2 = executor.submit(sourceReader(relay.newSource())) Thread.sleep(500) sink.writeUtf8("abcdefghij") Thread.sleep(500) sink.writeUtf8("klmnopqrst") sink.close() assertThat<ByteString>(future1.get()) .isEqualTo("abcdefghijklmnopqrst".encodeUtf8())
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
private var nextTcpConnectAtNanos = Long.MIN_VALUE /** * Plans currently being connected, and that will later be added to [connectResults]. This is * mutated by the call thread only. If is accessed by background connect threads. */ private val tcpConnectsInFlight = CopyOnWriteArrayList<Plan>() /** * Results are posted here as they occur. The find job is done when either one plan completes
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
docs/features/calls.md
Calls are executed in one of two ways: * **Synchronous:** your thread blocks until the response is readable. * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-callback/) on another thread when the response is readable.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.9K bytes - Viewed (0)