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; |
} |