- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for CurrentState (0.12 sec)
-
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) -
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/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) -
src/test/java/org/codelibs/opensearch/extension/analysis/ReloadableKuromojiTokenizerFactory.java
attributeImplsField.set(this, attributeImplsObj); final Field currentStateField = getAccessibleField(AttributeSource.class, "currentState"); final Object currentStateObj = currentStateField.get(tokenizer); currentStateField.set(this, currentStateObj); } catch (final Exception e) {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 9.5K bytes - Viewed (0)