| Index: util/file/file_writer.cc
|
| diff --git a/util/file/file_writer.cc b/util/file/file_writer.cc
|
| index 4f833051122ecc6fc88ff9fc48473b8626e6158f..d6ab9e7c11b53e00634d25a7d125c77ddfb36f8a 100644
|
| --- a/util/file/file_writer.cc
|
| +++ b/util/file/file_writer.cc
|
| @@ -19,49 +19,49 @@
|
| #include <limits.h>
|
|
|
| #include "base/logging.h"
|
| +
|
| +#if defined(OS_POSIX)
|
| +#include <sys/uio.h>
|
| +#include <unistd.h>
|
| #include "base/posix/eintr_wrapper.h"
|
| -#include "util/file/file_io.h"
|
| +#endif // OS_POSIX
|
|
|
| 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;
|
| @@ -74,7 +74,9 @@ bool FileWriter::Write(const void* data, size_t size) {
|
| }
|
|
|
| bool FileWriter::WriteIoVec(std::vector<WritableIoVec>* iovecs) {
|
| - DCHECK(fd_.is_valid());
|
| + DCHECK(file_.is_valid());
|
| +
|
| +#if defined(OS_POSIX)
|
|
|
| ssize_t size = 0;
|
| for (const WritableIoVec& iov : *iovecs) {
|
| @@ -94,7 +96,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;
|
| @@ -128,6 +131,15 @@ bool FileWriter::WriteIoVec(std::vector<WritableIoVec>* iovecs) {
|
|
|
| DCHECK_EQ(remaining_iovecs, 0u);
|
|
|
| +#else // !OS_POSIX
|
| +
|
| + for (const WritableIoVec& iov : *iovecs) {
|
| + if (!Write(iov.iov_base, iov.iov_len))
|
| + return false;
|
| + }
|
| +
|
| +#endif // OS_POSIX
|
| +
|
| #ifndef NDEBUG
|
| // The interface says that |iovecs| is not sacred, so scramble it to make sure
|
| // that nobody depends on it.
|
| @@ -137,15 +149,9 @@ bool FileWriter::WriteIoVec(std::vector<WritableIoVec>* iovecs) {
|
| return true;
|
| }
|
|
|
| -off_t FileWriter::Seek(off_t offset, int whence) {
|
| - DCHECK(fd_.is_valid());
|
| -
|
| - off_t rv = lseek(fd_.get(), offset, whence);
|
| - if (rv < 0) {
|
| - PLOG(ERROR) << "lseek";
|
| - }
|
| -
|
| - return rv;
|
| +FileOffset FileWriter::Seek(FileOffset offset, int whence) {
|
| + DCHECK(file_.is_valid());
|
| + return LoggingSeekFile(file_.get(), offset, whence);
|
| }
|
|
|
| } // namespace crashpad
|
|
|