- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 40 for Coordinator (0.4 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
val latch = CountDownLatch(1) override fun runOnce(): Long { latch.countDown() return -1L } } /** Adds [task] to run in [delayNanos]. Returns true if the coordinator is impacted. */ internal fun scheduleAndDecide( task: Task, delayNanos: Long, recurrence: Boolean, ): Boolean { task.initQueue(this) val now = taskRunner.backend.nanoTime()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockCoordinationService.java
* {@link InternalTransformer} should return a {@link org.gradle.internal.resources.ResourceLockState.Disposition} * that tells the resource coordinator how to proceed: * * FINISHED - All locks were acquired, release the state lock * FAILED - One or more locks were not acquired, roll back any locks that were acquired and release the state lock
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 2.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
return readyTask } // Notify the coordinator of a task that's coming up soon. coordinatorWaiting -> { if (minDelayNanos < coordinatorWakeUpAt - now) { backend.coordinatorNotify(this@TaskRunner) } return null } // No other thread is coordinating. Become the coordinator! else -> { coordinatorWaiting = true
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
testing/internal-performance-testing/src/main/groovy/org/gradle/performance/WithExternalRepository.groovy
server.insertHandler(context) server.start() } catch (IllegalArgumentException ignored) { server = null // repository not found, probably running on coordinator. If not, error will be caught later } } void stopServer() { server?.stop() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.1K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultExecutionPlanParallelTest.groovy
when: def failures = [] coordinator.withStateLock { finalizedPlan.collectFailures(failures) } then: failures.size() == 1 def e = failures.first() e.message.contains("Execution failed for task :finalizer") then: coordinator.withStateLock {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 93.5K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/taskgraph/DefaultTaskExecutionGraphSpec.groovy
def listenerBuildOperationDecorator = new TestListenerBuildOperationDecorator() def workerLimits = new DefaultWorkerLimits(1) def workerLeases = new DefaultWorkerLeaseService(coordinator, workerLimits) def executorFactory = Mock(ExecutorFactory) def accessHierarchies = new ExecutionNodeAccessHierarchies(CASE_SENSITIVE, Stub(Stat))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 20.6K bytes - Viewed (0) -
src/cmd/go/testdata/script/test_fuzz_mutator_repeat.txt
[!GOOS:darwin] [!GOOS:linux] [!GOOS:windows] skip # Verify that the fuzzing engine records the actual crashing input, even when # a worker process terminates without communicating the crashing input back # to the coordinator. [short] skip env GOCACHE=$WORK/cache # Start fuzzing. The worker crashes after 100 iterations. # The fuzz function writes the crashing input to "want" before exiting.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 16 16:53:11 UTC 2023 - 2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/internal/file/archive/DecompressionCoordinator.java
* limitations under the License. */ package org.gradle.api.internal.file.archive; import java.io.Closeable; import java.io.File; /** * A coordinator that can be used to manage access to decompressed data extracted from archive files like zip and tars. * * <p> * For a given build tree, only a single process is allowed write access to extract archives at a time. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 26 15:15:04 UTC 2024 - 2.1K bytes - Viewed (0) -
build-logic/performance-testing/src/test/kotlin/gradlebuild/performance/tasks/DetermineBaselinesTest.kt
} @After fun cleanUp() { unmockkStatic("gradlebuild.basics.kotlindsl.Kotlin_dsl_upstream_candidatesKt") } @Test fun `keeps flakiness-detection-commit as it is in coordinator build`() { verifyBaselineDetermination("any", true, flakinessDetectionCommitBaseline, flakinessDetectionCommitBaseline) } @Test fun `resolves to current commit in worker build`() { // given
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 21 09:29:24 UTC 2023 - 5.9K bytes - Viewed (0) -
src/internal/fuzz/coverage.go
} // SnapshotCoverage copies the current counter values into coverageSnapshot, // preserving them for later inspection. SnapshotCoverage also rounds each // counter down to the nearest power of two. This lets the coordinator store // multiple values for each counter by OR'ing them together. func SnapshotCoverage() { cov := coverage() for i, b := range cov { b |= b >> 1 b |= b >> 2 b |= b >> 4 b -= b >> 1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 2.5K bytes - Viewed (0)