Home
last modified time | relevance | path

Searched refs:SetupStreamsLocked (Results 1 – 6 of 6) sorted by relevance

/external/tensorflow/tensorflow/contrib/kafka/kernels/
Dkafka_dataset_ops.cc164 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in GetNextInternal()
199 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in RestoreInternal()
213 Status SetupStreamsLocked(Env* env) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in SetupStreamsLocked() function in tensorflow::KafkaDatasetOp::Dataset::Iterator
/external/tensorflow/tensorflow/core/kernels/data/experimental/
Dlmdb_dataset_op.cc124 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in GetNextInternal()
146 Status SetupStreamsLocked(Env* env) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in SetupStreamsLocked() function in tensorflow::data::__anonb6c8cdac0111::LMDBDatasetOp::Dataset::Iterator
Dcsv_dataset_op.cc259 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in GetNextInternal()
301 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in RestoreInternal()
781 Status SetupStreamsLocked(Env* env) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in SetupStreamsLocked() function in tensorflow::data::__anon30b914390111::CSVDatasetOp::Dataset::Iterator
/external/tensorflow/tensorflow/core/kernels/data/
Dreader_dataset_ops.cc171 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in GetNextInternal()
211 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in RestoreInternal()
219 Status SetupStreamsLocked(Env* env) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in SetupStreamsLocked() function in tensorflow::data::__anon94ec6c760111::TextLineDatasetOp::Dataset::Iterator
867 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in GetNextInternal()
900 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in RestoreInternal()
908 Status SetupStreamsLocked(Env* env) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in SetupStreamsLocked() function in tensorflow::data::__anon94ec6c760111::TFRecordDatasetOp::Dataset::Iterator
/external/tensorflow/tensorflow/contrib/hadoop/kernels/
Dhadoop_dataset_ops.cc287 TF_RETURN_IF_ERROR(SetupStreamsLocked(ctx->env())); in GetNextInternal()
305 Status SetupStreamsLocked(Env* env) EXCLUSIVE_LOCKS_REQUIRED(mu_) { in SetupStreamsLocked() function in tensorflow::data::__anon0a34fe870111::SequenceFileDatasetOp::Dataset::Iterator
/external/tensorflow/tensorflow/contrib/kinesis/kernels/
Dkinesis_dataset_ops.cc225 TF_RETURN_IF_ERROR(SetupStreamsLocked()); in GetNextInternal()
280 Status SetupStreamsLocked() EXCLUSIVE_LOCKS_REQUIRED(mu_) { in SetupStreamsLocked() function in tensorflow::KinesisDatasetOp::Dataset::Iterator