| /external/tensorflow/tensorflow/core/util/ |
| D | reporter.cc | 25 : closed_(true), fname_(fname), test_name_(test_name) {} in TestReporter()
28 if (closed_) return Status::OK(); in Close()
35 closed_ = true; in Close()
42 if (closed_) return Status::OK(); in Benchmark()
51 if (closed_) return Status::OK(); in SetProperty()
57 if (closed_) return Status::OK(); in SetProperty()
77 closed_ = false; in Initialize()
|
| D | reporter.h | 94 bool closed_; variable
|
| /external/libchrome/mojo/core/ |
| D | watcher_dispatcher.cc | 86 if (closed_ && result != MOJO_RESULT_CANCELLED) in InvokeWatchCallback()
103 if (closed_) in Close()
105 closed_ = true; in Close()
129 if (closed_) in WatchDispatcher()
160 remove_now = closed_; in WatchDispatcher()
174 if (closed_) in CancelWatch()
212 if (closed_) in Arm()
|
| D | watcher_dispatcher.h | 74 bool closed_ = false; variable
|
| /external/bsdiff/ |
| D | fake_patch_writer.h | 32 EXPECT_FALSE(closed_); in AddControlEntry()
48 EXPECT_FALSE(closed_) << "Close() already called"; in Close()
49 closed_ = true; in Close()
72 bool closed_{false};
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | batch_scheduler.h | 126 Notification closed_; variable
265 return const_cast<Notification*>(&closed_)->HasBeenNotified(); in IsClosed()
270 const_cast<Notification*>(&closed_)->WaitForNotification(); in WaitUntilClosed()
275 closed_.Notify(); in Close()
|
| D | shared_batch_scheduler.h | 273 return closed_; in closed()
306 bool closed_ GUARDED_BY(mu_) = false;
539 DCHECK(!closed_); in Schedule()
641 closed_ = true; in CloseAndWaitUntilEmpty()
670 return closed_ || open_batch->size() >= options_.max_batch_size || in IsOpenBatchSchedulable()
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | queue_base.cc | 59 closed_(false) {} in QueueBase()
224 closed_ = true; in CloseAndCancel()
251 if (closed_) { in Close()
255 closed_ = true; in Close()
274 if (closed_) { in TryAttemptLocked()
282 if (closed_) { in TryAttemptLocked()
|
| D | barrier_ops.cc | 53 : closed_(false), in Barrier()
112 if (closed_) { in TryInsertMany()
191 if (closed_ && incomplete_.empty() && queue_closed_ && ready > 0) { in TryInsertMany()
207 if (closed_) { in TryTakeMany()
258 if (closed_ && (cancel_pending_enqueues_ || !cancel_pending_enqueues)) { in Close()
265 closed_ = true; in Close()
315 if (closed_) { in InsertOneLocked()
428 bool closed_ GUARDED_BY(mu_);
|
| D | tensor_array.h | 148 closed_(false), in TensorArray()
266 CHECK(!closed_); in DebugString()
272 return closed_; in IsClosed()
343 closed_ = true; in ClearAndMarkClosed()
367 if (closed_) { in LockedReturnIfClosed()
382 bool closed_ GUARDED_BY(mu_);
|
| D | random_shuffle_queue_op.cc | 140 if (closed_) { in TryEnqueue()
198 if (closed_) { in TryEnqueueMany()
247 if (closed_ && queue_size == 0) { in TryDequeue()
254 if (!closed_) queue_size -= min_after_dequeue_; in TryDequeue()
340 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
387 if (!closed_) queue_size -= min_after_dequeue_; in TryDequeueMany()
|
| D | priority_queue.cc | 84 if (closed_) { in TryEnqueue()
149 if (closed_) { in TryEnqueueMany()
212 if (closed_ && s == 0) { in TryDequeue()
308 if (closed_) { in TryDequeueMany()
334 if (s == 0 || !(closed_ && allow_small_batch)) { in TryDequeueMany()
|
| D | stack.cc | 55 closed_(false) {} in Stack()
94 closed_ = true; in Close()
115 bool closed_ GUARDED_BY(mu_);
119 if (closed_) { in CheckNotClosed()
|
| D | fifo_queue.cc | 63 if (closed_) { in TryEnqueue()
121 if (closed_) { in TryEnqueueMany()
169 if (closed_ && queue_size == 0) { in TryDequeue()
262 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
|
| D | queue_base.h | 75 return closed_; in is_closed()
154 bool closed_ GUARDED_BY(mu_);
|
| D | padding_fifo_queue.cc | 103 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
|
| /external/puffin/src/ |
| D | puffin_stream.cc | 108 closed_(false), in PuffinStream()
159 TEST_AND_RETURN_FALSE(!closed_); in Seek()
201 closed_ = true; in Close()
206 TEST_AND_RETURN_FALSE(!closed_); in Read()
327 TEST_AND_RETURN_FALSE(!closed_); in Write()
|
| D | puffin_stream.h | 152 bool closed_; variable
|
| /external/libchrome/mojo/public/cpp/bindings/lib/ |
| D | multiplex_router.cc | 37 closed_(false), in InterfaceEndpoint()
51 bool closed() const { return closed_; } in closed()
54 closed_ = true; in set_closed()
86 DCHECK(!closed_); in AttachClient()
99 DCHECK(!closed_); in DetachClient()
203 bool closed_; member in mojo::internal::MultiplexRouter::InterfaceEndpoint
|
| /external/libbrillo/brillo/streams/ |
| D | input_stream_set.cc | 73 return !closed_; in IsOpen()
154 closed_ = true; in CloseBlocking()
|
| D | input_stream_set.h | 125 bool closed_{false};
|
| /external/libchrome/ipc/ |
| D | ipc_mojo_bootstrap.cc | 406 return closed_; in closed()
411 closed_ = true; in set_closed()
456 DCHECK(!closed_); in AttachClient()
467 DCHECK(!closed_); in DetachClient()
530 DCHECK(closed_); in ~Endpoint()
597 bool closed_ = false; member in IPC::__anonefff342a0111::ChannelAssociatedGroupController::Endpoint
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | direct_session.h | 292 if (closed_) return errors::Cancelled("Session has been closed."); in CheckNotClosed()
387 bool closed_ GUARDED_BY(closed_lock_) = false;
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | master_session.cc | 1401 if (closed_) { in Extend()
1552 if (closed_) { in Run()
1828 if (closed_) { in PostRunCleanup()
1907 if (closed_) { in MakeCallable()
1971 if (closed_) { in RunCallable()
2012 closed_ = true; // All subsequent calls to Run() or Extend() will fail. in Close()
2038 closed_ = true; in GarbageCollect()
|
| D | master_session.h | 201 bool closed_ GUARDED_BY(mu_) = false;
|