- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for getWorker (0.1 sec)
-
subprojects/core/src/main/java/org/gradle/process/internal/worker/DefaultWorkerProcessBuilder.java
public WorkerProcessBuilder worker(Action<? super WorkerProcessContext> action) { this.action = action; return this; } @Override public Action<? super WorkerProcessContext> getWorker() { return action; } @Override public JavaExecHandleBuilder getJavaCommand() { return javaCommand; } @Override public LogLevel getLogLevel() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 05:16:16 UTC 2024 - 12.1K bytes - Viewed (0) -
pkg/kubelet/prober/prober_manager_test.go
// Wait for the given workers to exit & clean up. func waitForWorkerExit(t *testing.T, m *manager, workerPaths []probeKey) error { for _, w := range workerPaths { condition := func() (bool, error) { _, exists := m.getWorker(w.podUID, w.containerName, w.probeType) return !exists, nil } if exited, _ := condition(); exited { continue // Already exited, no need to poll. } t.Logf("Polling %v", w)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 18.8K bytes - Viewed (0) -
cmd/global-heal.go
numHealers = numCores / 4 } else { numHealers = info.NRRequests / 4 } if numHealers < 4 { numHealers = 4 } // allow overriding this value as well.. if v := globalHealConfig.GetWorkers(); v > 0 { numHealers = uint64(v) } healingLogEvent(ctx, fmt.Sprintf("Healing drive '%s' - use %d parallel workers.", tracker.disk.String(), numHealers)) jt, _ := workers.New(int(numHealers))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 31 14:48:50 UTC 2024 - 15.1K bytes - Viewed (0)