- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for requestStop (0.23 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonStateCoordinator.java
} } } finally { lock.unlock(); } } @Override public void requestStop(String reason) { lock.lock(); try { if (state != State.StopRequested && state != State.Stopped && state != State.ForceStopped) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 17.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/AsyncDispatch.java
condition.signalAll(); } finally { lock.unlock(); } } /** * Commences a shutdown of this dispatch. */ @Override public void requestStop() { lock.lock(); try { doRequestStop(); } finally { lock.unlock(); } } private void doRequestStop() {
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/worker/DefaultWorkerProcess.java
} condition.signalAll(); stoppable = acceptor; } finally { lock.unlock(); } if (stoppable != null) { stoppable.requestStop(); } } private void onProcessStop(ExecResult execResult) { lock.lock(); try { try { execResult.rethrowFailure().assertNormalExitValue();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 19 14:39:33 UTC 2024 - 8.1K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.cc
} } else if (!status.ok()) { LOG(ERROR) << "Queue runner thread got a failure status: " << status.ToString(); UpdateStatus(status); if (coord_) { coord_->RequestStop().IgnoreError(); } } } Status QueueRunner::GetStatus() { mutex_lock l(mu_); return status_; } Status QueueRunner::ExportCostGraph(CostGraphDef* cost_graph) const {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/Daemon.java
} if (expirationCheck == IMMEDIATE_EXPIRE) { stateControl.requestForcefulStop(result.getReason()); } else { stateControl.requestStop(result.getReason()); } } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 12.9K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/ConcurrentTestUtil.groovy
threads.each { it.completesBefore(timeout) } } void stop(int timeoutValue, TimeUnit timeoutUnits) { throw new UnsupportedOperationException() } void requestStop() { throw new UnsupportedOperationException() } void execute(Runnable runnable) { threads.add(owner.startThread(runnable)) } void shutdown() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 22.9K bytes - Viewed (0)