- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for CurrentState (0.24 sec)
-
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java
ExecHandleState currentState; lock.lock(); try { currentState = this.state; } finally { lock.unlock(); } ExecResultImpl newResult = new ExecResultImpl(exitValue, execExceptionFor(failureCause, currentState), displayName); if (!currentState.isTerminal() && newState != ExecHandleState.DETACHED) { try {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 15.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/testing/DaemonEventSequenceBuilder.groovy
void state(DaemonsState checkpointState) { finishCheckpoint() currentState = checkpointState } void numDaemons(int numDaemons) { this.numDaemons = numDaemons } private finishCheckpoint() { if (currentState == null) { if (!actions.empty) { currentState = DaemonsState.getWildcardState() finishCheckpoint() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/model/StateTransitionController.java
} public CurrentState<T> transitioningTo(T toState) { return new TransitioningToNewState<T>(toState, this); } public abstract CurrentState<T> nextState(T toState); } /** * Currently in the given state. */ private static class InState<T> extends CurrentState<T> { private final DisplayName displayName;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 03 03:31:44 UTC 2023 - 20.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/TestableDaemon.groovy
def lastRegistryState = registryProbe.currentState def lastLogState = logFileProbe.currentState while (!timer.hasExpired() && (lastRegistryState != state || lastLogState != state)) { Thread.sleep(200) lastRegistryState = registryProbe.currentState lastLogState = logFileProbe.currentState } if (lastRegistryState == state && lastLogState == state) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 3.4K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
defer c.mu.Unlock() c.mu.Lock() for resstr := range d.InProgressResources { res := *status.ResourceFromString(resstr) if _, ok := c.CurrentState[res]; !ok { c.CurrentState[res] = make(map[string]Progress) } c.CurrentState[res][d.Reporter] = Progress{d.InProgressResources[resstr], d.DataPlaneCount} } c.ObservationTime[d.Reporter] = c.clock.Now() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
operator/pkg/helmreconciler/apply_test.go
tests := []struct { name string currentState string input string want string wantErr bool }{ { name: "creates if not present", input: "testdata/configmap.yaml", want: "testdata/configmap.yaml", }, { name: "updates if present", currentState: "testdata/configmap.yaml", input: "testdata/configmap-changed.yaml",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 12 17:12:54 UTC 2023 - 4.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/LegacyDaemon.groovy
protected void waitForState(State state) { def timer = Time.startCountdownTimer(STATE_CHANGE_TIMEOUT) def lastLogState = logFileProbe.currentState while (!timer.hasExpired() && lastLogState != state) { Thread.sleep(200) lastLogState = logFileProbe.currentState } if (lastLogState == state) { return }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/testing/DaemonsEventSequence.groovy
def busy = registry.notIdle.size() def idle = registry.idle.size() def currentState = new DaemonsState(busy, idle) if (!lastDaemonsState.matches(currentState)) { putOnChangeQueue(currentState) lastDaemonsState = currentState lastStateChangeAt = new Date() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultResourceLockCoordinationService.java
DefaultResourceLockState previousState = currentState; this.currentState = newState; return previousState; } private void finishOperation(@Nullable DefaultResourceLockState previous) { if (currentOwner != Thread.currentThread()) { throw new IllegalStateException("Another thread holds the state lock."); } currentState = previous; if (currentState == null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 11.9K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/text/AbstractLineChoppingStyledTextOutput.java
*/ public abstract class AbstractLineChoppingStyledTextOutput extends AbstractStyledTextOutput { private final char[] eolChars; private final String eol; private SeenFromEol seenFromEol; private State currentState = INITIAL_STATE; protected AbstractLineChoppingStyledTextOutput() { eol = SystemProperties.getInstance().getLineSeparator(); eolChars = eol.toCharArray();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 8.1K bytes - Viewed (0)