- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 72 for workerCh (0.17 sec)
-
cmd/bucket-replication-utils.go
} type replicationResyncer struct { // map of bucket to their resync status statusMap map[string]BucketReplicationResyncStatus workerSize int resyncCancelCh chan struct{} workerCh chan struct{} sync.RWMutex } const ( replicationDir = ".replication" resyncFileName = "resync.bin" resyncMetaFormat = 1 resyncMetaVersionV1 = 1
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 26.3K bytes - Viewed (0) -
platforms/core-execution/worker-main/src/main/java/org/gradle/process/internal/worker/child/SystemApplicationClassLoaderWorker.java
import org.gradle.process.internal.health.memory.OsMemoryInfo; import org.gradle.process.internal.worker.WorkerJvmMemoryInfoSerializer; import org.gradle.process.internal.worker.WorkerLoggingSerializer; import org.gradle.process.internal.worker.WorkerProcessContext; import org.gradle.process.internal.worker.messaging.WorkerConfig; import org.gradle.process.internal.worker.messaging.WorkerConfigSerializer; import java.io.DataInputStream; import java.io.File;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 11.9K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
workers = workers[:len(workers)-1] worker <- expiryOp(nil) es.stats.workers.Add(-1) } // Atomically replace workers. es.workers.Store(&workers) } // Worker handles 4 types of expiration tasks. // 1. Expiry of objects, includes regular and transitioned objects // 2. Expiry of noncurrent versions due to NewerNoncurrentVersions
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:31:51 UTC 2024 - 33.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/child/WorkerProcessClassPathProvider.java
"gradle-base-services", "gradle-enterprise-logging", "gradle-enterprise-workers", "gradle-cli", "gradle-concurrent", "gradle-io", "gradle-wrapper-shared", "gradle-native", "gradle-dependency-management", "gradle-workers", "gradle-worker-main", "gradle-build-process-services", "gradle-problems-api",
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 14:28:48 UTC 2024 - 11.1K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonServer.java
import org.gradle.internal.state.ManagedFactoryRegistry; import org.gradle.process.internal.ExecFactory; import org.gradle.process.internal.worker.RequestHandler; import org.gradle.process.internal.worker.request.RequestArgumentSerializers; import javax.annotation.Nonnull; import javax.annotation.Nullable; import javax.inject.Inject; import java.io.File;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 12.8K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/WorkerDaemonClientsManager.java
if (OperatingSystem.current().isUnix() && exitCode > 127) { LOGGER.warn("Worker daemon '" + candidate.getDisplayName() + "' exited unexpectedly after being killed with signal " + (exitCode - 128) + ". This is likely because an external process has killed the worker."); } else { LOGGER.warn("Worker daemon '" + candidate.getDisplayName() + "' exited unexpectedly with exit code " + exitCode + ".");
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:54:37 UTC 2024 - 10K bytes - Viewed (0) -
platforms/jvm/language-groovy/src/main/java/org/gradle/api/internal/tasks/compile/daemon/DaemonGroovyCompiler.java
import org.gradle.process.JavaForkOptions; import org.gradle.process.internal.JavaForkOptionsFactory; import org.gradle.workers.internal.DaemonForkOptions; import org.gradle.workers.internal.DaemonForkOptionsBuilder; import org.gradle.workers.internal.HierarchicalClassLoaderStructure; import org.gradle.workers.internal.KeepAliveMode; import java.io.File; import java.util.Arrays; import java.util.Collection;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 05:33:15 UTC 2024 - 9.8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r35/BuildProgressCrossVersionSpec.groovy
def "generates events for worker actions with new Worker API (post 5.1)"() { expect: runBuildWithWorkerAction() != null } private ProgressEvents.Operation runBuildWithWorkerAction() { buildFile << """ import org.gradle.workers.* abstract class MyWorkerAction implements WorkAction<WorkParameters.None>{ @Override public void execute() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 11.1K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/integTest/groovy/org/gradle/cache/internal/DefaultFileLockManagerContentionIntegrationTest.groovy
} // This test simulates a long running Zinc compiler setup by running code similar to ZincScalaCompilerFactory through the worker API. // if many workers wait for the same exclusive lock, a worker does not time out because several others get the lock before def "worker not timeout"() { given: def gradleUserHome = file("home").absoluteFile buildFile << """
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 15.1K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/NativeServicesIntegrationTest.groovy
@ToBeImplemented("https://github.com/gradle/gradle/issues/28203") def "native services flag should be passed to the daemon and to the worker"() { given: executer.withArguments(systemProperties.collect { it.toString() }) buildScript(""" import org.gradle.workers.WorkParameters import org.gradle.internal.nativeintegration.services.NativeServices
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 05:18:22 UTC 2024 - 10.9K bytes - Viewed (0)