- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 20 for requestStop (0.16 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/IncomingQueue.java
import java.util.concurrent.locks.Lock; class IncomingQueue extends MultiChannelQueue { IncomingQueue(Lock lock) { super(lock); } public void requestStop() { queue(new EndOfStream()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/ServiceLifecycle.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 4K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/AsyncStoppable.java
* Requesting stopping means preparing for stopping; stopping accepting new work. * You have to call stop at some point anyway if your intention is to completely stop the stoppable. */ void requestStop();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 1.4K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
connection = completion.create(serializer); hub.addConnection(connection); hub.noFurtherConnections(); completion = null; } @Override public void requestStop() { hub.requestStop(); } @Override public void stop() { // TODO:ADAM - need to cleanup completion too, if not used CompositeStoppable.stoppable(hub, connection).stop(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestManagedExecutor.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 2.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/ObjectConnection.java
void connect(); /** * Commences a graceful stop of this connection. Stops accepting outgoing messages. Requests that the peer stop * sending incoming messages. */ @Override void requestStop(); /** * Performs a graceful stop of this connection. Stops accepting outgoing messages. Blocks until all incoming messages * have been handled, and all outgoing messages have been forwarded to the peer.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 2.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonStateControl.java
* * <p>The daemon will stop accepting new work, so that subsequent calls to {@link #runCommand} will fail with {@link DaemonUnavailableException}. */ void requestStop(String reason); /** * Requests a forceful stops of the daemon. Does not wait until the daemon is idle to begin stopping. The stop will happen asynchronously, and this method does not block. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 3.6K 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)