- Sort Score
- Num 10 results
- Language All
Results 1 - 7 of 7 for runTask (0.09 seconds)
-
build-tools-internal/src/main/groovy/org/elasticsearch/gradle/internal/test/AntFixture.groovy
@Internal int maxWaitInSeconds = 30 /** * A flag to indicate whether the fixture should be run in the foreground, or spawned. * It is protected so subclasses can override (eg RunTask). */ protected boolean spawn = true /** * A closure to call before the fixture is considered ready. The closure is passed the fixture object,Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 01 09:19:30 GMT 2021 - 10.1K bytes - Click Count (0) -
CONTRIBUTING.md
specifically these lines tell you that Elasticsearch is ready: [2020-05-29T14:50:35,167][INFO ][o.e.h.AbstractHttpServerTransport] [runTask-0] publish_address {127.0.0.1:9200}, bound_addresses {[::1]:9200}, {127.0.0.1:9200} [2020-05-29T14:50:35,169][INFO ][o.e.n.Node ] [runTask-0] started But to be honest its typically easier to wait until the console stops scrolling and then run `curl` in another window like this:Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Wed Sep 01 07:32:01 GMT 2021 - 36.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/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() { server.source.close() assertThat(client.webSocket!!.send("Hello!")).isTrue() taskFaker.runTasks()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 18.7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinderTest.kt
plan0.connectState = TLS_CONNECTED taskRunner.newQueue().execute("connect") { val result0 = finder.find() assertThat(result0).isEqualTo(plan0.connection) } taskFaker.runTasks() assertEvents( "take plan 0", ) taskFaker.assertNoMoreTasks() } @Test fun takeConnectingConnection() { val plan0 = routePlanner.addPlan()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 20.9K bytes - Click Count (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 yields its execution privilege while calling [runTasks], [runNextTask], or * [advanceUntil]. These functions don't return until the task threads are all idle. * * Task threads release their execution privilege in these ways: *
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 11.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/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 (receivedCloseFrame) throw IOException("closed") if (frameLength > 0L) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 10K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt
blueQueue.execute("blue task", 200.µs) { log += "blue:run@${taskFaker.nanoTime}" } assertThat(taskFaker.executeCallCount).isEqualTo(1) // Nothing to do. taskFaker.runTasks() assertThat(log).isEmpty() // At 100.µs, the coordinator runs the red task and starts a thread for the new coordinator. taskFaker.advanceUntil(100.µs) assertThat(log).containsExactly("red:run@100000")
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Feb 03 22:17:59 GMT 2026 - 23K bytes - Click Count (0)