- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for runTask (0.2 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
awaitTaskToRun() } ?: return logger.logElapsed(task, task.queue!!) { var completedNormally = false try { runTask(task) completedNormally = true } finally { // If the task is crashing start another thread to service the queues. if (!completedNormally) { lock.withLock {
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.6K bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLokhttp3/internal/concurrent/TaskRunner;-><clinit>()V HSPLokhttp3/internal/concurrent/TaskRunner;-><init>(Lokhttp3/internal/concurrent/TaskRunner$Backend;Ljava/util/logging/Logger;I)V HSPLokhttp3/internal/concurrent/TaskRunner;->access$runTask(Lokhttp3/internal/concurrent/TaskRunner;Lokhttp3/internal/concurrent/Task;)V HSPLokhttp3/internal/concurrent/TaskRunner;->afterRun(Lokhttp3/internal/concurrent/Task;J)V
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Mar 21 11:22:00 GMT 2022 - 127.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
assertThat(result0).isEqualTo(plan0.connection) } taskFaker.runTasks() assertEvents( "take plan 0", "plan 0 TCP connecting...", ) taskFaker.advanceUntil(250.ms) assertEvents( "take plan 1", ) taskFaker.runTasks() assertEvents( "plan 0 TCP connected", "plan 0 cancel", ) }
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 20.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
taskFaker.runTasks() client.listener.assertFailure(IOException::class.java, "source is closed") assertThat(client.webSocket!!.send("Hello!")).isFalse() } @Test fun socketClosedDuringMessageKillsWebSocket() { client2Server.source.close() assertThat(client.webSocket!!.send("Hello!")).isTrue() taskFaker.runTasks()
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 16.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
* deterministic. * * This class ensures that at most one thread is running at a time. This is initially the JUnit test * thread, which temporarily shares its execution privilege by calling [runTasks], [runNextTask], or * [advanceUntil]. These methods wait for its task threads to stop executing before it returns. * * Task threads stall execution in these ways: *
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/AutobahnTester.kt
} } private fun runTest( number: Long, count: Long, ) { val latch = CountDownLatch(1) val startNanos = AtomicLong() newWebSocket( "/runCase?case=$number&agent=okhttp", object : WebSocketListener() { override fun onOpen( webSocket: WebSocket, response: Response, ) {
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
readControlFrame() } } /** * Reads a message body into across one or more frames. Control frames that occur between * fragments will be processed. If the message payload is masked this will unmask as it's being * processed. */ @Throws(IOException::class) private fun readMessage() { while (true) { if (closed) throw IOException("closed") if (frameLength > 0L) {
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
ChangeLog.md
- [`KT-42520`](https://youtrack.jetbrains.com/issue/KT-42520) Add a way to setup generating separate js files for each module inside gradle - [`KT-32086`](https://youtrack.jetbrains.com/issue/KT-32086) Gradle, JS: runTask.enabled = false has no effect on npm dependencies - [`KT-48358`](https://youtrack.jetbrains.com/issue/KT-48358) KJS: Circular dependency when multiple second-level Gradle modules have the same name
Plain Text - Registered: Fri Mar 22 08:18:09 GMT 2024 - Last Modified: Thu Dec 21 17:48:12 GMT 2023 - 268.7K bytes - Viewed (1)