aboutsummaryrefslogtreecommitdiffhomepage
path: root/tensorflow/core/framework/queue_interface.h
diff options
context:
space:
mode:
Diffstat (limited to 'tensorflow/core/framework/queue_interface.h')
-rw-r--r--tensorflow/core/framework/queue_interface.h3
1 files changed, 3 insertions, 0 deletions
diff --git a/tensorflow/core/framework/queue_interface.h b/tensorflow/core/framework/queue_interface.h
index baddf0bbfa..4aeaab3d9b 100644
--- a/tensorflow/core/framework/queue_interface.h
+++ b/tensorflow/core/framework/queue_interface.h
@@ -77,6 +77,9 @@ class QueueInterface : public ResourceBase {
virtual void Close(OpKernelContext* ctx, bool cancel_pending_enqueues,
DoneCallback callback) = 0;
+ // Returns true if a given queue is closed and false if it is open.
+ virtual bool is_closed() const = 0;
+
// Assuming *this represents a shared queue, verify that it matches
// another instantiation indicated by node_def.
virtual Status MatchesNodeDef(const NodeDef& node_def) = 0;