- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 173 for stopped_ (0.1 sec)
-
tensorflow/cc/training/coordinator_test.cc
return status_; } Status GetStatus() { return status_; } void SetStatus(const Status& status) { status_ = status; } bool IsRunning() const override { return !stopped_; }; void Stop() { stopped_ = true; } private: void CountThread(std::atomic<int>* counter, int until, Notification* start) { if (start != nullptr) start->WaitForNotification();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Mar 23 09:10:43 UTC 2023 - 6.9K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.h
/// Returns the latest status. Status GetStatus(); // Returns the stored cost model. Status ExportCostGraph(CostGraphDef* cost_graph) const override; private: QueueRunner() : coord_(nullptr), stopped_(false), cg_mu_(nullptr) {} // Initializes the instance with the QueueRunnerDef proto. Status Init(const QueueRunnerDef& queue_runner_def); // The Run function for each thread.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Aug 31 18:27:00 UTC 2022 - 5K bytes - Viewed (0) -
tensorflow/cc/training/queue_runner.cc
} void QueueRunner::Stop(Session* sess) { if (coord_ != nullptr) { coord_->WaitForStop(); } if (!cancel_op_name_.empty()) { UpdateStatus(RealRun(sess, cancel_op_name_, false)); } stopped_ = true; } Status QueueRunner::Join() { thread_pool_.reset(); mutex_lock l(mu_); return status_; } void QueueRunner::UpdateStatus(const Status& status) { { mutex_lock l(mu_);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 08:30:37 UTC 2024 - 7K bytes - Viewed (0) -
cmd/rebalance-admin.go
continue } diskStats[disk.PoolIndex].AvailableSpace += disk.AvailableSpace diskStats[disk.PoolIndex].TotalSpace += disk.TotalSpace } stopTime := meta.StoppedAt r = rebalanceAdminStatus{ ID: meta.ID, StoppedAt: meta.StoppedAt, Pools: make([]rebalancePoolStatus, len(meta.PoolStats)), } for i, ps := range meta.PoolStats { r.Pools[i] = rebalancePoolStatus{ ID: i,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Dec 22 00:56:43 UTC 2023 - 3.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/ready.go
"context" "fmt" "sync" ) type status int const ( Pending status = iota Ready Stopped ) // ready is a three state condition variable that blocks until is Ready if is not Stopped. // Its initial state is Pending and its state machine diagram is as follow. // // Pending <------> Ready -----> Stopped // // | ^ // └---------------------------┘ type ready struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 16 13:32:11 UTC 2023 - 4.1K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
f.Lock() defer f.Unlock() if !f.stopped { klog.V(4).Infof("Stopping fake watcher.") close(f.result) f.stopped = true } } func (f *FakeWatcher) IsStopped() bool { f.Lock() defer f.Unlock() return f.stopped } // Reset prepares the watcher to be reused. func (f *FakeWatcher) Reset() { f.Lock() defer f.Unlock() f.stopped = false f.result = make(chan Event) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonReportStatusIntegrationSpec.groovy
out =~ /\n\s*\d+\s+IDLE\s+([\w\.\+\-]+)/ out =~ /\n\s*\d+\s+BUSY\s+([\w\.\+\-]+)/ out =~ /\n\s*12346\s+STOPPED\s+\(GRACEFUL_EXPIRE_REASON\)/ cleanup: block?.releaseAll() build?.waitForFinish() } def "reports stopped status of recently stopped daemons"() { given:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/mux.go
m.incomingBlock.Lock() defer m.incomingBlock.Unlock() // Ensure that if the broadcaster is stopped we do not send events to it. select { case <-m.stopped: return false, fmt.Errorf("broadcaster already stopped") default: } select { case m.incoming <- Event{action, obj}: return true, nil default: return false, nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 16 15:26:36 UTC 2022 - 9.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/ServiceLifecycle.java
case STOPPING: throw new IllegalStateException(String.format("Cannot use %s as it is currently stopping.", displayName)); case STOPPED: throw new IllegalStateException(String.format("Cannot use %s as it has been stopped.", displayName)); } Integer depth = usages.get(Thread.currentThread()); if (depth == null) {
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/messaging/src/main/java/org/gradle/internal/dispatch/AsyncDispatch.java
if (interrupted) { Thread.currentThread().interrupt(); } if (state == State.Stopped) { throw new IllegalStateException("Cannot dispatch message, as this message dispatch has been stopped. Message: " + message); } queue.add(message); condition.signalAll(); } finally { lock.unlock(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6.7K bytes - Viewed (0)