| /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/util/ |
| D | reporter.cc | 25 : closed_(true), fname_(fname), test_name_(test_name) {} in TestReportFile()
28 if (closed_) return Status::OK(); in Append()
33 if (closed_) return Status::OK(); in Close()
34 closed_ = true; in Close()
52 closed_ = false; in Initialize()
|
| D | reporter.h | 48 bool IsClosed() const { return closed_; } in IsClosed()
53 bool closed_;
|
| /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/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | batch_scheduler.h | 134 Notification closed_; variable
289 return const_cast<Notification*>(&closed_)->HasBeenNotified(); in IsClosed()
294 const_cast<Notification*>(&closed_)->WaitForNotification(); in WaitUntilClosed()
299 closed_.Notify(); in Close()
|
| D | shared_batch_scheduler.h | 329 bool closed() const TF_NO_THREAD_SAFETY_ANALYSIS { return closed_.load(); } in closed()
367 std::atomic<bool> closed_ TF_GUARDED_BY(mu_){false}; in TF_GUARDED_BY()
635 DCHECK(!closed_); in ScheduleWithoutSplit()
697 DCHECK(!closed_); in ScheduleWithSplit()
844 closed_ = true; in CloseAndWaitUntilEmpty()
884 return closed_ || open_batch->size() >= max_execution_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_ TF_GUARDED_BY(mu_);
|
| D | priority_queue.cc | 84 if (closed_) { in TryEnqueue()
150 if (closed_) { in TryEnqueueMany()
213 if (closed_ && s == 0) { in TryDequeue()
309 if (closed_) { in TryDequeueMany()
335 if (s == 0 || !(closed_ && allow_small_batch)) { in TryDequeueMany()
|
| D | tensor_array.h | 146 closed_(false), in TensorArray()
264 CHECK(!closed_); in DebugString()
270 return closed_; in IsClosed()
341 closed_ = true; in ClearAndMarkClosed()
366 if (closed_) { in LockedReturnIfClosed()
381 bool closed_ TF_GUARDED_BY(mu_);
|
| D | random_shuffle_queue_op.cc | 141 if (closed_) { in TryEnqueue()
199 if (closed_) { in TryEnqueueMany()
248 if (closed_ && queue_size == 0) { in TryDequeue()
255 if (!closed_) queue_size -= min_after_dequeue_; in TryDequeue()
341 if (closed_ && queue_size < attempt->elements_requested) { in TryDequeueMany()
388 if (!closed_) queue_size -= min_after_dequeue_; in TryDequeueMany()
|
| D | stack.cc | 55 closed_(false) {} in Stack()
95 closed_ = true; in Close()
116 bool closed_ TF_GUARDED_BY(mu_);
120 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 | 71 return closed_; in is_closed()
150 bool closed_ TF_GUARDED_BY(mu_);
|
| /external/openscreen/third_party/chromium_quic/demo/ |
| D | delegates.h | 46 bool closed() const { return closed_; } in closed()
49 bool closed_ = false;
|
| D | delegates.cc | 40 closed_ = true; in OnClose()
|
| /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/libbrillo/brillo/streams/ |
| D | input_stream_set.cc | 75 return !closed_; in IsOpen()
156 closed_ = true; in CloseBlocking()
|
| D | input_stream_set.h | 125 bool closed_{false};
|
| /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/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::__anonf422a6c80111::ChannelAssociatedGroupController::Endpoint
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | direct_session.h | 315 if (closed_) return errors::Cancelled("Session has been closed."); in CheckNotClosed()
409 bool closed_ TF_GUARDED_BY(closed_lock_) = false;
|
| /external/tensorflow/tensorflow/core/distributed_runtime/ |
| D | master_session.h | 199 bool closed_ TF_GUARDED_BY(mu_) = false;
|