- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 156 for SetState (0.1 sec)
-
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/text/AbstractLineChoppingStyledTextOutput.java
context.seenFromEol.add('\r'); context.setState(WINDOWS_EOL_PARSING_ODDITY_STATE); } else if (context.isCurrentCharEquals('\n')) { context.flushLineText(); context.flushEndLine("\n"); context.next(); context.reset(); context.setState(START_LINE_STATE); } else { context.next();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:05:18 UTC 2023 - 8.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
setState(State.Idle); } catch (Throwable throwable) { setState(State.Broken); throw UncheckedException.throwAsUncheckedException(throwable); } break; case StopRequested: setState(State.Idle);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
operator/pkg/util/progress/progress_test.go
foo.ReportProgress() expect(`- Processing resources for ` + cnpo + `.`) foo.ReportFinished() expect(`🧠` + cnpo + ` installed`) p.SetState(StatePruning) expect(`- Pruning removed resources`) p.SetState(StateComplete) expect(`✅ Installation complete`) p.SetState(StateUninstallComplete) expect(`✅ Uninstall complete`)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 19:23:44 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/AsyncDispatch.java
} } private void doRequestStop() { setState(State.Stopped); } /** * Stops accepting new messages, and blocks until all queued messages have been dispatched. */ @Override public void stop() { lock.lock(); try { setState(State.Stopped); waitForAllMessages(); } finally {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java
return Collections.unmodifiableMap(environment); } @Override public ExecHandleState getState() { lock.lock(); try { return state; } finally { lock.unlock(); } } private void setState(ExecHandleState state) { lock.lock(); try { LOGGER.debug("Changing state to: {}", state);
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/main/java/org/gradle/launcher/daemon/registry/DaemonInfo.java
this.token = Preconditions.checkNotNull(token); this.clock = Preconditions.checkNotNull(busyClock); this.lastBusy = -1; // Will be overwritten by setIdle if not idle. setState(state); } private DaemonInfo(Address address, DaemonContext context, byte[] token, State state, long lastBusy) { this.address = address; this.context = context; this.token = token;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.2K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
private ThreadHandle blockingThread; public void expectBlocks(Closure action) { try { setState(State.Idle, State.Blocking); setBlockingThread(start(action)); setState(State.Blocking, State.Blocked); waitForState(State.Unblocked, State.Failed); } catch (InterruptedException e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
platforms/native/language-native/src/main/java/org/gradle/language/nativeplatform/internal/incremental/BuildableCompilationState.java
private final Map<File, SourceFileState> sourceFileStates = new HashMap<File, SourceFileState>(); public Set<File> getSourceInputs() { return sourceFileStates.keySet(); } public void setState(File file, SourceFileState sourceFileState) { sourceFileStates.put(file, sourceFileState); } public CompilationState snapshot() { return new CompilationState(ImmutableMap.copyOf(sourceFileStates));
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 16 20:20:03 UTC 2023 - 1.3K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonExpirationStrategyTest.groovy
DaemonContext context = Mock(DaemonContext) { _ * getUid() >> uid } DaemonInfo info = new DaemonInfo(daemonAddress, context, "password".bytes, Busy, new MockClock(lastIdleTime)) info.setState(state) registry.store(info) return info } private static Address createAddress(int i) { new Address() { int getNum() { i }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.1K bytes - Viewed (0) -
src/cmd/compile/internal/types2/named.go
n.methods = methods n.loader = nil } n.setState(complete) return n } // state atomically accesses the current state of the receiver. func (n *Named) state() namedState { return namedState(atomic.LoadUint32(&n.state_)) } // setState atomically stores the given state for n. // Must only be called while holding n.mu. func (n *Named) setState(state namedState) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 20:03:31 UTC 2024 - 23.9K bytes - Viewed (0)