- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for waitForStop (0.18 sec)
-
pkg/kube/portforwarder.go
// This can return nil if the port forwarding stops gracefully. ErrChan() <-chan error // WaitForStop blocks until connection closed (e.g. control-C interrupt) WaitForStop() } var _ PortForwarder = &forwarder{} type forwarder struct { stopCh chan struct{} restConfig *rest.Config podName string ns string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 5.5K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/CrossProcessFileLockIntegrationTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 15:21:23 UTC 2024 - 2.7K bytes - Viewed (0) -
platforms/software/testing-base/src/test/groovy/org/gradle/api/internal/tasks/testing/worker/ForkingTestClassProcessorTest.groovy
processor.processTestClass(Mock(TestClassRunInfo)) processor.stopNow() processor.stop() then: 1 * workerProcess.stopNow() _ * workerProcess.waitForStop() >> { throw new ExecException("waitForStop can throw") } notThrown(ExecException) } def "captures and rethrows unrecoverable exceptions thrown by the connection"() { def handler
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 6.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/executer/ForkingGradleHandle.java
public ExecutionResult waitForFinish() { return waitForStop(false); } @Override public ExecutionFailure waitForFailure() { return (ExecutionFailure) waitForStop(true); } @Override public void waitForExit() { getExecHandle().waitForFinish().rethrowFailure(); } private ExecutionResult waitForStop(boolean expectFailure) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/DefaultMultiRequestWorkerProcessBuilder.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 30 19:54:37 UTC 2024 - 7.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/WorkerProcess.java
WorkerProcess start(); /** * The connection to the worker. Call {@link ObjectConnection#connect()} to complete the connection. */ ObjectConnection getConnection(); ExecResult waitForStop(); /** * Returns the result of the process, if it has exited. If the process has not exited yet, returns {@link Optional#empty()}. */ Optional<ExecResult> getExecResult();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 19 21:45:01 UTC 2024 - 1.6K bytes - Viewed (0) -
istioctl/pkg/cli/mock_client.go
return "localhost:3456" } func (m MockPortForwarder) Close() { } func (m MockPortForwarder) ErrChan() <-chan error { return make(chan error) } func (m MockPortForwarder) WaitForStop() { } var _ kube.PortForwarder = MockPortForwarder{} type MockClient struct { // Results is a map of podName to the results of the expected test on the pod Results map[string][]byte kube.CLIClient }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 08 08:38:19 UTC 2024 - 2.1K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.cc
return; } status_ = status; } Status Coordinator::GetStatus() { mutex_lock l(status_lock_); return status_; } void Coordinator::WaitForStop() { mutex_lock l(mu_); while (!should_stop_) { wait_for_stop_.wait(l); } } Status Coordinator::ExportCostGraph(CostGraphDef* cost_graph) const { mutex_lock l(runners_lock_);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 3.2K bytes - Viewed (0) -
tensorflow/cc/training/coordinator.h
/// Returns the latest status. Status GetStatus(); /// Returns immediately if the coordinator is stopped or blocks until /// RequestStop() is called. void WaitForStop(); // Returns the cost graph from stored run metadata in registered runners. Status ExportCostGraph(CostGraphDef* cost_graph) const; private: std::unordered_set<int> clean_stop_errors_;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Oct 12 08:49:52 UTC 2023 - 4.4K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/worker/DefaultSingleRequestWorkerProcessBuilder.java
requester.runThenStop(new Request(request, CurrentBuildOperationRef.instance().get())); boolean hasResult = receiver.awaitNextResult(); workerProcess.waitForStop(); if (!hasResult) { // Reached the end of input, worker has exited without failing
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 04 09:27:37 UTC 2023 - 5.7K bytes - Viewed (0)