diff --git a/third_party/nucleus/io/gfile.cc b/third_party/nucleus/io/gfile.cc index aafd069b..a66fdcab 100644 --- a/third_party/nucleus/io/gfile.cc +++ b/third_party/nucleus/io/gfile.cc @@ -41,13 +41,13 @@ namespace nucleus { bool Exists(const std::string& filename) { // FileExists sets s to tensorflow::error::NOT_FOUND if it doesn't exist. - absl::Status s = tensorflow::Env::Default()->FileExists(filename); + tensorflow::Status s = tensorflow::Env::Default()->FileExists(filename); return s.ok(); } std::vector Glob(const std::string& pattern) { std::vector results; - absl::Status s = + ::tensorflow::Status s = tensorflow::Env::Default()->GetMatchingPaths(pattern, &results); return results; } @@ -56,7 +56,7 @@ ReadableFile::ReadableFile() {} std::unique_ptr ReadableFile::New(const std::string& filename) { std::unique_ptr file; - absl::Status status = + tensorflow::Status status = tensorflow::Env::Default()->NewRandomAccessFile(filename, &file); if (!status.ok()) { return nullptr; @@ -91,7 +91,8 @@ WritableFile::WritableFile() {} std::unique_ptr WritableFile::New(const std::string& filename) { std::unique_ptr file; - absl::Status s = tensorflow::Env::Default()->NewWritableFile(filename, &file); + tensorflow::Status s = + tensorflow::Env::Default()->NewWritableFile(filename, &file); if (!s.ok()) { return nullptr; @@ -104,7 +105,7 @@ std::unique_ptr WritableFile::New(const std::string& filename) { } bool WritableFile::Write(const std::string& s) { - absl::Status status = file_->Append(s); + tensorflow::Status status = file_->Append(s); return status.ok(); } diff --git a/third_party/nucleus/io/tfrecord_reader.cc b/third_party/nucleus/io/tfrecord_reader.cc index 3b119e66..2826bdbe 100644 --- a/third_party/nucleus/io/tfrecord_reader.cc +++ b/third_party/nucleus/io/tfrecord_reader.cc @@ -45,7 +45,7 @@ TFRecordReader::TFRecordReader() {} std::unique_ptr TFRecordReader::New( const std::string& filename, const std::string& compression_type) { std::unique_ptr file; - absl::Status s = + tensorflow::Status s = tensorflow::Env::Default()->NewRandomAccessFile(filename, &file); if (!s.ok()) { LOG(ERROR) << s; @@ -74,7 +74,7 @@ bool TFRecordReader::GetNext() { return false; } - absl::Status s = reader_->ReadRecord(&offset_, &record_); + tensorflow::Status s = reader_->ReadRecord(&offset_, &record_); return s.ok(); } diff --git a/third_party/nucleus/io/tfrecord_writer.cc b/third_party/nucleus/io/tfrecord_writer.cc index c84360d4..c4f79314 100644 --- a/third_party/nucleus/io/tfrecord_writer.cc +++ b/third_party/nucleus/io/tfrecord_writer.cc @@ -45,7 +45,8 @@ TFRecordWriter::TFRecordWriter() {} std::unique_ptr TFRecordWriter::New( const std::string& filename, const std::string& compression_type) { std::unique_ptr file; - absl::Status s = tensorflow::Env::Default()->NewWritableFile(filename, &file); + tensorflow::Status s = + tensorflow::Env::Default()->NewWritableFile(filename, &file); if (!s.ok()) { LOG(ERROR) << s; return nullptr; @@ -68,7 +69,7 @@ bool TFRecordWriter::WriteRecord(const std::string& record) { if (writer_ == nullptr) { return false; } - absl::Status s = writer_->WriteRecord(record); + tensorflow::Status s = writer_->WriteRecord(record); return s.ok(); } @@ -76,13 +77,13 @@ bool TFRecordWriter::Flush() { if (writer_ == nullptr) { return false; } - absl::Status s = writer_->Flush(); + tensorflow:: Status s = writer_->Flush(); return s.ok(); } bool TFRecordWriter::Close() { if (writer_ != nullptr) { - absl::Status s = writer_->Close(); + tensorflow::Status s = writer_->Close(); if (!s.ok()) { return false; } @@ -90,7 +91,7 @@ bool TFRecordWriter::Close() { } if (file_ != nullptr) { - absl::Status s = file_->Close(); + tensorflow:: Status s = file_->Close(); if (!s.ok()) { return false; }