diff options
author | Manjunath Kudlur <keveman@gmail.com> | 2015-11-06 16:27:58 -0800 |
---|---|---|
committer | Manjunath Kudlur <keveman@gmail.com> | 2015-11-06 16:27:58 -0800 |
commit | f41959ccb2d9d4c722fe8fc3351401d53bcf4900 (patch) | |
tree | ef0ca22cb2a5ac4bdec9d080d8e0788a53ed496d /tensorflow/python/lib/io/py_record_reader.cc |
TensorFlow: Initial commit of TensorFlow library.
TensorFlow is an open source software library for numerical computation
using data flow graphs.
Base CL: 107276108
Diffstat (limited to 'tensorflow/python/lib/io/py_record_reader.cc')
-rw-r--r-- | tensorflow/python/lib/io/py_record_reader.cc | 49 |
1 files changed, 49 insertions, 0 deletions
diff --git a/tensorflow/python/lib/io/py_record_reader.cc b/tensorflow/python/lib/io/py_record_reader.cc new file mode 100644 index 0000000000..5cc5229a8b --- /dev/null +++ b/tensorflow/python/lib/io/py_record_reader.cc @@ -0,0 +1,49 @@ +#include "tensorflow/python/lib/io/py_record_reader.h" + +#include "tensorflow/core/lib/core/stringpiece.h" +#include "tensorflow/core/lib/io/record_reader.h" +#include "tensorflow/core/platform/port.h" +#include "tensorflow/core/public/env.h" + +namespace tensorflow { + +class RandomAccessFile; + +namespace io { + +PyRecordReader::PyRecordReader() {} + +PyRecordReader* PyRecordReader::New(const string& filename, + uint64 start_offset) { + RandomAccessFile* file; + Status s = Env::Default()->NewRandomAccessFile(filename, &file); + if (!s.ok()) { + return nullptr; + } + PyRecordReader* reader = new PyRecordReader; + reader->offset_ = start_offset; + reader->file_ = file; + reader->reader_ = new RecordReader(reader->file_); + return reader; +} + +PyRecordReader::~PyRecordReader() { + delete reader_; + delete file_; +} + +bool PyRecordReader::GetNext() { + if (reader_ == nullptr) return false; + Status s = reader_->ReadRecord(&offset_, &record_); + return s.ok(); +} + +void PyRecordReader::Close() { + delete reader_; + delete file_; + file_ = nullptr; + reader_ = nullptr; +} + +} // namespace io +} // namespace tensorflow |