Chromium Code Reviews| Index: webrtc/modules/video_coding/utility/ivf_file_writer.cc |
| diff --git a/webrtc/modules/video_coding/utility/ivf_file_writer.cc b/webrtc/modules/video_coding/utility/ivf_file_writer.cc |
| index a80cf9bf6bc5c11f66f01072795735cce94f7150..42dfa7dd6d24de58f6aac0c8de82b0f3d9077163 100644 |
| --- a/webrtc/modules/video_coding/utility/ivf_file_writer.cc |
| +++ b/webrtc/modules/video_coding/utility/ivf_file_writer.cc |
| @@ -10,22 +10,22 @@ |
| #include "webrtc/modules/video_coding/utility/ivf_file_writer.h" |
| +#include <string> |
| +#include <utility> |
| + |
| #include "webrtc/base/checks.h" |
| #include "webrtc/base/logging.h" |
| #include "webrtc/modules/rtp_rtcp/source/byte_io.h" |
| namespace webrtc { |
| -IvfFileWriter::IvfFileWriter(const std::string& file_name, |
| - std::unique_ptr<FileWrapper> file, |
| - VideoCodecType codec_type) |
| - : codec_type_(codec_type), |
| +IvfFileWriter::IvfFileWriter(rtc::File file) |
| + : codec_type_(kVideoCodecUnknown), |
| num_frames_(0), |
| width_(0), |
| height_(0), |
| last_timestamp_(-1), |
| using_capture_timestamps_(false), |
| - file_name_(file_name), |
| file_(std::move(file)) {} |
| IvfFileWriter::~IvfFileWriter() { |
| @@ -34,24 +34,15 @@ IvfFileWriter::~IvfFileWriter() { |
| const size_t kIvfHeaderSize = 32; |
| -std::unique_ptr<IvfFileWriter> IvfFileWriter::Open(const std::string& file_name, |
| - VideoCodecType codec_type) { |
| - std::unique_ptr<IvfFileWriter> file_writer; |
| - std::unique_ptr<FileWrapper> file(FileWrapper::Create()); |
| - if (!file->OpenFile(file_name.c_str(), false)) |
| - return file_writer; |
| - |
| - file_writer.reset(new IvfFileWriter( |
| - file_name, std::unique_ptr<FileWrapper>(std::move(file)), codec_type)); |
| - if (!file_writer->WriteHeader()) |
| - file_writer.reset(); |
| - |
| - return file_writer; |
| +std::unique_ptr<IvfFileWriter> IvfFileWriter::Wrap(rtc::File file) { |
| + return std::unique_ptr<IvfFileWriter>(new IvfFileWriter(std::move(file))); |
| } |
| bool IvfFileWriter::WriteHeader() { |
| - if (file_->Rewind() != 0) { |
| - LOG(LS_WARNING) << "Unable to rewind output file " << file_name_; |
| + if (!file_.Seek(0)) { |
| + // TODO(palmkvist): make logging more informative in the absence of a file |
| + // name (or get one) |
|
sprang_webrtc
2016/09/04 14:48:47
Probably enough to add one of these TODO's at the
|
| + LOG(LS_WARNING) << "Unable to rewind ivf output file."; |
| return false; |
| } |
| @@ -98,21 +89,26 @@ bool IvfFileWriter::WriteHeader() { |
| static_cast<uint32_t>(num_frames_)); |
| ByteWriter<uint32_t>::WriteLittleEndian(&ivf_header[28], 0); // Reserved. |
| - if (!file_->Write(ivf_header, kIvfHeaderSize)) { |
| - LOG(LS_ERROR) << "Unable to write IVF header for file " << file_name_; |
| + if (file_.Write(ivf_header, kIvfHeaderSize) < kIvfHeaderSize) { |
| + // TODO(palmkvist): make logging more informative in the absence of a file |
| + // name (or get one) |
| + LOG(LS_ERROR) << "Unable to write IVF header for ivf output file."; |
| return false; |
| } |
| return true; |
| } |
| -bool IvfFileWriter::InitFromFirstFrame(const EncodedImage& encoded_image) { |
| +bool IvfFileWriter::InitFromFirstFrame(const EncodedImage& encoded_image, |
| + VideoCodecType codec_type) { |
| width_ = encoded_image._encodedWidth; |
| height_ = encoded_image._encodedHeight; |
| RTC_CHECK_GT(width_, 0); |
| RTC_CHECK_GT(height_, 0); |
| using_capture_timestamps_ = encoded_image._timeStamp == 0; |
| + codec_type_ = codec_type; |
| + |
| if (!WriteHeader()) |
| return false; |
| @@ -130,19 +126,22 @@ bool IvfFileWriter::InitFromFirstFrame(const EncodedImage& encoded_image) { |
| default: |
| codec_name = "Unknown"; |
| } |
| - LOG(LS_WARNING) << "Created IVF file " << file_name_ |
| - << " for codec data of type " << codec_name |
| + // TODO(palmkvist): make logging more informative in the absence of a file |
| + // name (or get one) |
| + LOG(LS_WARNING) << "Created IVF file for codec data of type " << codec_name |
| << " at resolution " << width_ << " x " << height_ |
| << ", using " << (using_capture_timestamps_ ? "1" : "90") |
| << "kHz clock resolution."; |
| return true; |
| } |
| -bool IvfFileWriter::WriteFrame(const EncodedImage& encoded_image) { |
| - RTC_DCHECK(file_->is_open()); |
| +bool IvfFileWriter::WriteFrame(const EncodedImage& encoded_image, |
| + VideoCodecType codec_type) { |
| + RTC_DCHECK(file_.IsOpen()); |
| - if (num_frames_ == 0 && !InitFromFirstFrame(encoded_image)) |
| + if (num_frames_ == 0 && !InitFromFirstFrame(encoded_image, codec_type)) |
| return false; |
| + RTC_DCHECK_EQ(codec_type_, codec_type); |
| if ((encoded_image._encodedWidth > 0 || encoded_image._encodedHeight > 0) && |
| (encoded_image._encodedHeight != height_ || |
| @@ -167,9 +166,12 @@ bool IvfFileWriter::WriteFrame(const EncodedImage& encoded_image) { |
| ByteWriter<uint32_t>::WriteLittleEndian( |
| &frame_header[0], static_cast<uint32_t>(encoded_image._length)); |
| ByteWriter<uint64_t>::WriteLittleEndian(&frame_header[4], timestamp); |
| - if (!file_->Write(frame_header, kFrameHeaderSize) || |
| - !file_->Write(encoded_image._buffer, encoded_image._length)) { |
| - LOG(LS_ERROR) << "Unable to write frame to file " << file_name_; |
| + if (file_.Write(frame_header, kFrameHeaderSize) < kFrameHeaderSize || |
| + file_.Write(encoded_image._buffer, encoded_image._length) < |
| + encoded_image._length) { |
| + // TODO(palmkvist): make logging more informative in the absence of a file |
| + // name (or get one) |
| + LOG(LS_ERROR) << "Unable to write frame to file."; |
| return false; |
| } |
| @@ -178,20 +180,16 @@ bool IvfFileWriter::WriteFrame(const EncodedImage& encoded_image) { |
| } |
| bool IvfFileWriter::Close() { |
| - if (!file_->is_open()) |
| + if (!file_.IsOpen()) |
| return false; |
| if (num_frames_ == 0) { |
| - // No frame written to file, close and remove it entirely if possible. |
| - file_->CloseFile(); |
| - if (remove(file_name_.c_str()) != 0) |
| - LOG(LS_WARNING) << "Failed to remove empty IVF file " << file_name_; |
| - |
| + file_.Close(); |
| return true; |
| } |
| bool ret = WriteHeader(); |
| - file_->CloseFile(); |
| + file_.Close(); |
| return ret; |
| } |