| Index: util/file/file_writer.cc
|
| diff --git a/util/file/file_writer.cc b/util/file/file_writer.cc
|
| index 4f833051122ecc6fc88ff9fc48473b8626e6158f..2b965f82cc131b0fe209a35cd75ac3d9010aa68f 100644
|
| --- a/util/file/file_writer.cc
|
| +++ b/util/file/file_writer.cc
|
| @@ -20,48 +20,43 @@
|
|
|
| #include "base/logging.h"
|
| #include "base/posix/eintr_wrapper.h"
|
| -#include "util/file/file_io.h"
|
|
|
| namespace crashpad {
|
|
|
| +#if defined(OS_POSIX)
|
| // Ensure type compatibility between WritableIoVec and iovec.
|
| static_assert(sizeof(WritableIoVec) == sizeof(iovec), "WritableIoVec size");
|
| static_assert(offsetof(WritableIoVec, iov_base) == offsetof(iovec, iov_base),
|
| "WritableIoVec base offset");
|
| static_assert(offsetof(WritableIoVec, iov_len) == offsetof(iovec, iov_len),
|
| "WritableIoVec len offset");
|
| +#endif // OS_POSIX
|
|
|
| -FileWriter::FileWriter() : fd_() {
|
| +FileWriter::FileWriter() : file_() {
|
| }
|
|
|
| FileWriter::~FileWriter() {
|
| }
|
|
|
| -bool FileWriter::Open(const base::FilePath& path, int oflag, mode_t mode) {
|
| - CHECK(!fd_.is_valid());
|
| -
|
| - DCHECK((oflag & O_WRONLY) || (oflag & O_RDWR));
|
| -
|
| - fd_.reset(HANDLE_EINTR(open(path.value().c_str(), oflag, mode)));
|
| - if (!fd_.is_valid()) {
|
| - PLOG(ERROR) << "open " << path.value();
|
| - return false;
|
| - }
|
| -
|
| - return true;
|
| +bool FileWriter::Open(const base::FilePath& path,
|
| + FileWriteMode write_mode,
|
| + bool world_readable) {
|
| + CHECK(!file_.is_valid());
|
| + file_.reset(LoggingOpenFileForWrite(path, write_mode, world_readable));
|
| + return file_.is_valid();
|
| }
|
|
|
| void FileWriter::Close() {
|
| - CHECK(fd_.is_valid());
|
| + CHECK(file_.is_valid());
|
|
|
| - fd_.reset();
|
| + file_.reset();
|
| }
|
|
|
| bool FileWriter::Write(const void* data, size_t size) {
|
| - DCHECK(fd_.is_valid());
|
| + DCHECK(file_.is_valid());
|
|
|
| // TODO(mark): Write no more than SSIZE_MAX bytes in a single call.
|
| - ssize_t written = WriteFile(fd_.get(), data, size);
|
| + ssize_t written = WriteFile(file_.get(), data, size);
|
| if (written < 0) {
|
| PLOG(ERROR) << "write";
|
| return false;
|
| @@ -73,8 +68,10 @@ bool FileWriter::Write(const void* data, size_t size) {
|
| return true;
|
| }
|
|
|
| +#if defined(OS_POSIX)
|
| +
|
| bool FileWriter::WriteIoVec(std::vector<WritableIoVec>* iovecs) {
|
| - DCHECK(fd_.is_valid());
|
| + DCHECK(file_.is_valid());
|
|
|
| ssize_t size = 0;
|
| for (const WritableIoVec& iov : *iovecs) {
|
| @@ -94,7 +91,8 @@ bool FileWriter::WriteIoVec(std::vector<WritableIoVec>* iovecs) {
|
| while (size > 0) {
|
| size_t writev_iovec_count =
|
| std::min(remaining_iovecs, implicit_cast<size_t>(IOV_MAX));
|
| - ssize_t written = HANDLE_EINTR(writev(fd_.get(), iov, writev_iovec_count));
|
| + ssize_t written =
|
| + HANDLE_EINTR(writev(file_.get(), iov, writev_iovec_count));
|
| if (written < 0) {
|
| PLOG(ERROR) << "writev";
|
| return false;
|
| @@ -137,15 +135,21 @@ bool FileWriter::WriteIoVec(std::vector<WritableIoVec>* iovecs) {
|
| return true;
|
| }
|
|
|
| -off_t FileWriter::Seek(off_t offset, int whence) {
|
| - DCHECK(fd_.is_valid());
|
| +#else
|
|
|
| - off_t rv = lseek(fd_.get(), offset, whence);
|
| - if (rv < 0) {
|
| - PLOG(ERROR) << "lseek";
|
| +bool FileWriter::WriteIoVec(std::vector<WritableIoVec>* iovecs) {
|
| + for (const WritableIoVec& iov : *iovecs) {
|
| + if (!Write(iov.iov_base, iov.iov_len))
|
| + return false;
|
| }
|
| + return true;
|
| +}
|
| +
|
| +#endif // OS_POSIX
|
|
|
| - return rv;
|
| +FileOffset FileWriter::Seek(FileOffset offset, int whence) {
|
| + DCHECK(file_.is_valid());
|
| + return LoggingSeekFile(file_.get(), offset, whence);
|
| }
|
|
|
| } // namespace crashpad
|
|
|