summaryrefslogtreecommitdiff
path: root/src/AbstractDiskWriter.cc
diff options
context:
space:
mode:
authorTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:39:47 +0900
committerTatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>2015-12-27 18:40:08 +0900
commitb1132d6b10cd3791b9529d7031d723fd0e2d8215 (patch)
tree9ce465b42bf09372118335c7c619bb2b41869eaf /src/AbstractDiskWriter.cc
parent4abad2f64c9ff80144a61c5a9c2bea144852b883 (diff)
make clang-format using clang-format-3.6
Diffstat (limited to 'src/AbstractDiskWriter.cc')
-rw-r--r--src/AbstractDiskWriter.cc385
1 files changed, 191 insertions, 194 deletions
diff --git a/src/AbstractDiskWriter.cc b/src/AbstractDiskWriter.cc
index e3ce6d6b..931ee88a 100644
--- a/src/AbstractDiskWriter.cc
+++ b/src/AbstractDiskWriter.cc
@@ -36,7 +36,7 @@
#include <unistd.h>
#ifdef HAVE_MMAP
-# include <sys/mman.h>
+#include <sys/mman.h>
#endif // HAVE_MMAP
#include <fcntl.h>
@@ -57,24 +57,22 @@
namespace aria2 {
AbstractDiskWriter::AbstractDiskWriter(const std::string& filename)
- : filename_(filename),
- fd_(A2_BAD_FD),
+ : filename_(filename),
+ fd_(A2_BAD_FD),
#ifdef __MINGW32__
- mapView_(0),
-#else // !__MINGW32__
+ mapView_(0),
+#else // !__MINGW32__
#endif // !__MINGW32__
- readOnly_(false),
- enableMmap_(false),
- mapaddr_(nullptr),
- maplen_(0)
-
-{}
+ readOnly_(false),
+ enableMmap_(false),
+ mapaddr_(nullptr),
+ maplen_(0)
-AbstractDiskWriter::~AbstractDiskWriter()
{
- closeFile();
}
+AbstractDiskWriter::~AbstractDiskWriter() { closeFile(); }
+
namespace {
// Returns error code depending on the platform. For MinGW32, return
// the value of GetLastError(). Otherwise, return errno.
@@ -82,7 +80,7 @@ int fileError()
{
#ifdef __MINGW32__
return GetLastError();
-#else // !__MINGW32__
+#else // !__MINGW32__
return errno;
#endif // !__MINGW32__
}
@@ -96,18 +94,15 @@ std::string fileStrerror(int errNum)
{
#ifdef __MINGW32__
static char buf[256];
- if(FormatMessage(FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS,
- 0,
- errNum,
- // Default language
- MAKELANGID(LANG_ENGLISH, SUBLANG_ENGLISH_US),
- (LPTSTR) &buf,
- sizeof(buf),
- 0) == 0) {
+ if (FormatMessage(FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS,
+ 0, errNum,
+ // Default language
+ MAKELANGID(LANG_ENGLISH, SUBLANG_ENGLISH_US), (LPTSTR)&buf,
+ sizeof(buf), 0) == 0) {
snprintf(buf, sizeof(buf), "File I/O error %x", errNum);
}
return buf;
-#else // !__MINGW32__
+#else // !__MINGW32__
return util::safeStrerror(errNum);
#endif // !__MINGW32__
}
@@ -117,17 +112,19 @@ void AbstractDiskWriter::openFile(int64_t totalLength)
{
try {
openExistingFile(totalLength);
- } catch(RecoverableException& e) {
- if(
+ }
+ catch (RecoverableException& e) {
+ if (
#ifdef __MINGW32__
- e.getErrNum() == ERROR_FILE_NOT_FOUND ||
- e.getErrNum() == ERROR_PATH_NOT_FOUND
-#else // !__MINGW32__
- e.getErrNum() == ENOENT
+ e.getErrNum() == ERROR_FILE_NOT_FOUND ||
+ e.getErrNum() == ERROR_PATH_NOT_FOUND
+#else // !__MINGW32__
+ e.getErrNum() == ENOENT
#endif // !__MINGW32__
- ) {
+ ) {
initAndOpenFile(totalLength);
- } else {
+ }
+ else {
throw;
}
}
@@ -136,34 +133,35 @@ void AbstractDiskWriter::openFile(int64_t totalLength)
void AbstractDiskWriter::closeFile()
{
#if defined(HAVE_MMAP) || defined(__MINGW32__)
- if(mapaddr_) {
+ if (mapaddr_) {
int errNum = 0;
#ifdef __MINGW32__
- if(!UnmapViewOfFile(mapaddr_)) {
+ if (!UnmapViewOfFile(mapaddr_)) {
errNum = GetLastError();
}
CloseHandle(mapView_);
mapView_ = INVALID_HANDLE_VALUE;
-#else // !__MINGW32__
- if(munmap(mapaddr_, maplen_) == -1) {
+#else // !__MINGW32__
+ if (munmap(mapaddr_, maplen_) == -1) {
errNum = errno;
}
#endif // !__MINGW32__
- if(errNum != 0) {
+ if (errNum != 0) {
int errNum = fileError();
- A2_LOG_ERROR(fmt("Unmapping file %s failed: %s",
- filename_.c_str(), fileStrerror(errNum).c_str()));
- } else {
+ A2_LOG_ERROR(fmt("Unmapping file %s failed: %s", filename_.c_str(),
+ fileStrerror(errNum).c_str()));
+ }
+ else {
A2_LOG_INFO(fmt("Unmapping file %s succeeded", filename_.c_str()));
}
mapaddr_ = nullptr;
maplen_ = 0;
}
#endif // HAVE_MMAP || defined __MINGW32__
- if(fd_ != A2_BAD_FD) {
+ if (fd_ != A2_BAD_FD) {
#ifdef __MINGW32__
CloseHandle(fd_);
-#else // !__MINGW32__
+#else // !__MINGW32__
close(fd_);
#endif // !__MINGW32__
fd_ = A2_BAD_FD;
@@ -180,29 +178,32 @@ HANDLE openFileWithFlags(const std::string& filename, int flags,
DWORD sharedMode = FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE;
DWORD creationDisp = 0;
- if(flags & O_RDWR) {
+ if (flags & O_RDWR) {
desiredAccess = GENERIC_READ | GENERIC_WRITE;
- } else if(flags & O_WRONLY) {
+ }
+ else if (flags & O_WRONLY) {
desiredAccess = GENERIC_WRITE;
- } else {
+ }
+ else {
desiredAccess = GENERIC_READ;
}
- if(flags & O_CREAT) {
- if(flags & O_TRUNC) {
+ if (flags & O_CREAT) {
+ if (flags & O_TRUNC) {
creationDisp |= CREATE_ALWAYS;
- } else {
+ }
+ else {
creationDisp |= CREATE_NEW;
}
- } else {
+ }
+ else {
creationDisp |= OPEN_EXISTING;
}
hn = CreateFileW(utf8ToWChar(filename).c_str(), desiredAccess, sharedMode,
/* lpSecurityAttributes */ 0, creationDisp,
FILE_ATTRIBUTE_NORMAL, /* hTemplateFile */ 0);
- if(hn == INVALID_HANDLE_VALUE) {
+ if (hn == INVALID_HANDLE_VALUE) {
int errNum = GetLastError();
- throw DL_ABORT_EX3(errNum, fmt(EX_FILE_OPEN,
- filename.c_str(),
+ throw DL_ABORT_EX3(errNum, fmt(EX_FILE_OPEN, filename.c_str(),
fileStrerror(errNum).c_str()),
errCode);
}
@@ -213,9 +214,10 @@ int openFileWithFlags(const std::string& filename, int flags,
error_code::Value errCode)
{
int fd;
- while((fd = a2open(utf8ToWChar(filename).c_str(), flags, OPEN_MODE)) == -1
- && errno == EINTR);
- if(fd < 0) {
+ while ((fd = a2open(utf8ToWChar(filename).c_str(), flags, OPEN_MODE)) == -1 &&
+ errno == EINTR)
+ ;
+ if (fd < 0) {
int errNum = errno;
throw DL_ABORT_EX3(errNum, fmt(EX_FILE_OPEN, filename.c_str(),
util::safeStrerror(errNum).c_str()),
@@ -233,9 +235,10 @@ int openFileWithFlags(const std::string& filename, int flags,
void AbstractDiskWriter::openExistingFile(int64_t totalLength)
{
int flags = O_BINARY;
- if(readOnly_) {
+ if (readOnly_) {
flags |= O_RDONLY;
- } else {
+ }
+ else {
flags |= O_RDWR;
}
fd_ = openFileWithFlags(filename_, flags, error_code::FILE_OPEN_ERROR);
@@ -245,32 +248,38 @@ void AbstractDiskWriter::createFile(int addFlags)
{
assert(!filename_.empty());
util::mkdirs(File(filename_).getDirname());
- fd_ = openFileWithFlags(filename_, O_CREAT|O_RDWR|O_TRUNC|O_BINARY|addFlags,
+ fd_ = openFileWithFlags(filename_,
+ O_CREAT | O_RDWR | O_TRUNC | O_BINARY | addFlags,
error_code::FILE_CREATE_ERROR);
}
ssize_t AbstractDiskWriter::writeDataInternal(const unsigned char* data,
size_t len, int64_t offset)
{
- if(mapaddr_) {
+ if (mapaddr_) {
memcpy(mapaddr_ + offset, data, len);
return len;
- } else {
+ }
+ else {
ssize_t writtenLength = 0;
seek(offset);
- while((size_t)writtenLength < len) {
+ while ((size_t)writtenLength < len) {
#ifdef __MINGW32__
DWORD nwrite;
- if(WriteFile(fd_, data+writtenLength, len-writtenLength, &nwrite, 0)) {
+ if (WriteFile(fd_, data + writtenLength, len - writtenLength, &nwrite,
+ 0)) {
writtenLength += nwrite;
- } else {
+ }
+ else {
return -1;
}
-#else // !__MINGW32__
+#else // !__MINGW32__
ssize_t ret = 0;
- while((ret = write(fd_, data+writtenLength, len-writtenLength)) == -1 &&
- errno == EINTR);
- if(ret == -1) {
+ while ((ret = write(fd_, data + writtenLength, len - writtenLength)) ==
+ -1 &&
+ errno == EINTR)
+ ;
+ if (ret == -1) {
return -1;
}
writtenLength += ret;
@@ -283,25 +292,28 @@ ssize_t AbstractDiskWriter::writeDataInternal(const unsigned char* data,
ssize_t AbstractDiskWriter::readDataInternal(unsigned char* data, size_t len,
int64_t offset)
{
- if(mapaddr_) {
+ if (mapaddr_) {
if (offset >= maplen_) {
return 0;
}
auto readlen = std::min(maplen_ - offset, static_cast<int64_t>(len));
memcpy(data, mapaddr_ + offset, readlen);
return readlen;
- } else {
+ }
+ else {
seek(offset);
#ifdef __MINGW32__
DWORD nread;
- if(ReadFile(fd_, data, len, &nread, 0)) {
+ if (ReadFile(fd_, data, len, &nread, 0)) {
return nread;
- } else {
+ }
+ else {
return -1;
}
-#else // !__MINGW32__
+#else // !__MINGW32__
ssize_t ret = 0;
- while((ret = read(fd_, data, len)) == -1 && errno == EINTR);
+ while ((ret = read(fd_, data, len)) == -1 && errno == EINTR)
+ ;
return ret;
#endif // !__MINGW32__
}
@@ -313,45 +325,46 @@ void AbstractDiskWriter::seek(int64_t offset)
#ifdef __MINGW32__
LARGE_INTEGER fileLength;
fileLength.QuadPart = offset;
- if(SetFilePointerEx(fd_, fileLength, 0, FILE_BEGIN) == 0)
-#else // !__MINGW32__
- if(a2lseek(fd_, offset, SEEK_SET) == (a2_off_t)-1)
+ if (SetFilePointerEx(fd_, fileLength, 0, FILE_BEGIN) == 0)
+#else // !__MINGW32__
+ if (a2lseek(fd_, offset, SEEK_SET) == (a2_off_t)-1)
#endif // !__MINGW32__
- {
- int errNum = fileError();
- throw DL_ABORT_EX2(fmt(EX_FILE_SEEK, filename_.c_str(),
- fileStrerror(errNum).c_str()),
- error_code::FILE_IO_ERROR);
- }
+ {
+ int errNum = fileError();
+ throw DL_ABORT_EX2(
+ fmt(EX_FILE_SEEK, filename_.c_str(), fileStrerror(errNum).c_str()),
+ error_code::FILE_IO_ERROR);
+ }
}
void AbstractDiskWriter::ensureMmapWrite(size_t len, int64_t offset)
{
#if defined(HAVE_MMAP) || defined(__MINGW32__)
- if(enableMmap_) {
- if(mapaddr_) {
- if(static_cast<int64_t>(len + offset) > maplen_) {
+ if (enableMmap_) {
+ if (mapaddr_) {
+ if (static_cast<int64_t>(len + offset) > maplen_) {
int errNum = 0;
#ifdef __MINGW32__
- if(!UnmapViewOfFile(mapaddr_)) {
+ if (!UnmapViewOfFile(mapaddr_)) {
errNum = GetLastError();
}
CloseHandle(mapView_);
mapView_ = INVALID_HANDLE_VALUE;
-#else // !__MINGW32__
- if(munmap(mapaddr_, maplen_) == -1) {
+#else // !__MINGW32__
+ if (munmap(mapaddr_, maplen_) == -1) {
errNum = errno;
}
#endif // !__MINGW32__
- if(errNum != 0) {
- A2_LOG_ERROR(fmt("Unmapping file %s failed: %s",
- filename_.c_str(), fileStrerror(errNum).c_str()));
+ if (errNum != 0) {
+ A2_LOG_ERROR(fmt("Unmapping file %s failed: %s", filename_.c_str(),
+ fileStrerror(errNum).c_str()));
}
mapaddr_ = nullptr;
maplen_ = 0;
enableMmap_ = false;
}
- } else {
+ }
+ else {
int64_t filesize = size();
if (filesize == 0) {
@@ -362,37 +375,37 @@ void AbstractDiskWriter::ensureMmapWrite(size_t len, int64_t offset)
}
int errNum = 0;
- if(static_cast<int64_t>(len + offset) <= filesize) {
+ if (static_cast<int64_t>(len + offset) <= filesize) {
#ifdef __MINGW32__
- mapView_ = CreateFileMapping(fd_, 0, PAGE_READWRITE,
- filesize >> 32, filesize & 0xffffffffu,
- 0);
- if(mapView_) {
- mapaddr_ = reinterpret_cast<unsigned char*>
- (MapViewOfFile(mapView_, FILE_MAP_WRITE, 0, 0, 0));
- if(!mapaddr_) {
+ mapView_ = CreateFileMapping(fd_, 0, PAGE_READWRITE, filesize >> 32,
+ filesize & 0xffffffffu, 0);
+ if (mapView_) {
+ mapaddr_ = reinterpret_cast<unsigned char*>(
+ MapViewOfFile(mapView_, FILE_MAP_WRITE, 0, 0, 0));
+ if (!mapaddr_) {
errNum = GetLastError();
CloseHandle(mapView_);
mapView_ = INVALID_HANDLE_VALUE;
}
- } else {
+ }
+ else {
errNum = GetLastError();
}
-#else // !__MINGW32__
- mapaddr_ = reinterpret_cast<unsigned char*>
- (mmap(nullptr, filesize, PROT_READ | PROT_WRITE, MAP_SHARED, fd_, 0));
- if(!mapaddr_) {
+#else // !__MINGW32__
+ mapaddr_ = reinterpret_cast<unsigned char*>(mmap(
+ nullptr, filesize, PROT_READ | PROT_WRITE, MAP_SHARED, fd_, 0));
+ if (!mapaddr_) {
errNum = errno;
}
#endif // !__MINGW32__
- if(mapaddr_) {
+ if (mapaddr_) {
A2_LOG_DEBUG(fmt("Mapping file %s succeeded, length=%" PRId64 "",
- filename_.c_str(),
- static_cast<uint64_t>(filesize)));
+ filename_.c_str(), static_cast<uint64_t>(filesize)));
maplen_ = filesize;
- } else {
- A2_LOG_WARN(fmt("Mapping file %s failed: %s",
- filename_.c_str(), fileStrerror(errNum).c_str()));
+ }
+ else {
+ A2_LOG_WARN(fmt("Mapping file %s failed: %s", filename_.c_str(),
+ fileStrerror(errNum).c_str()));
enableMmap_ = false;
}
}
@@ -401,158 +414,142 @@ void AbstractDiskWriter::ensureMmapWrite(size_t len, int64_t offset)
#endif // HAVE_MMAP || __MINGW32__
}
-void AbstractDiskWriter::writeData(const unsigned char* data, size_t len, int64_t offset)
+void AbstractDiskWriter::writeData(const unsigned char* data, size_t len,
+ int64_t offset)
{
ensureMmapWrite(len, offset);
- if(writeDataInternal(data, len, offset) < 0) {
+ if (writeDataInternal(data, len, offset) < 0) {
int errNum = fileError();
- if(
- // If the error indicates disk full situation, throw
- // DownloadFailureException and abort download instantly.
+ if (
+// If the error indicates disk full situation, throw
+// DownloadFailureException and abort download instantly.
#ifdef __MINGW32__
- errNum == ERROR_DISK_FULL || errNum == ERROR_HANDLE_DISK_FULL
-#else // !__MINGW32__
- errNum == ENOSPC
+ errNum == ERROR_DISK_FULL || errNum == ERROR_HANDLE_DISK_FULL
+#else // !__MINGW32__
+ errNum == ENOSPC
#endif // !__MINGW32__
- ) {
- throw DOWNLOAD_FAILURE_EXCEPTION3
- (errNum, fmt(EX_FILE_WRITE, filename_.c_str(),
- fileStrerror(errNum).c_str()),
- error_code::NOT_ENOUGH_DISK_SPACE);
- } else {
- throw DL_ABORT_EX3
- (errNum, fmt(EX_FILE_WRITE, filename_.c_str(),
- fileStrerror(errNum).c_str()),
- error_code::FILE_IO_ERROR);
+ ) {
+ throw DOWNLOAD_FAILURE_EXCEPTION3(
+ errNum,
+ fmt(EX_FILE_WRITE, filename_.c_str(), fileStrerror(errNum).c_str()),
+ error_code::NOT_ENOUGH_DISK_SPACE);
+ }
+ else {
+ throw DL_ABORT_EX3(errNum, fmt(EX_FILE_WRITE, filename_.c_str(),
+ fileStrerror(errNum).c_str()),
+ error_code::FILE_IO_ERROR);
}
}
}
-ssize_t AbstractDiskWriter::readData(unsigned char* data, size_t len, int64_t offset)
+ssize_t AbstractDiskWriter::readData(unsigned char* data, size_t len,
+ int64_t offset)
{
ssize_t ret;
- if((ret = readDataInternal(data, len, offset)) < 0) {
+ if ((ret = readDataInternal(data, len, offset)) < 0) {
int errNum = fileError();
- throw DL_ABORT_EX3
- (errNum, fmt(EX_FILE_READ, filename_.c_str(),
- fileStrerror(errNum).c_str()),
- error_code::FILE_IO_ERROR);
+ throw DL_ABORT_EX3(errNum, fmt(EX_FILE_READ, filename_.c_str(),
+ fileStrerror(errNum).c_str()),
+ error_code::FILE_IO_ERROR);
}
return ret;
}
void AbstractDiskWriter::truncate(int64_t length)
{
- if(fd_ == A2_BAD_FD) {
+ if (fd_ == A2_BAD_FD) {
throw DL_ABORT_EX("File not yet opened.");
}
#ifdef __MINGW32__
// Since mingw32's ftruncate cannot handle over 2GB files, we use
// SetEndOfFile instead.
seek(length);
- if(SetEndOfFile(fd_) == 0)
-#else // !__MINGW32__
- if(a2ftruncate(fd_, length) == -1)
+ if (SetEndOfFile(fd_) == 0)
+#else // !__MINGW32__
+ if (a2ftruncate(fd_, length) == -1)
#endif // !__MINGW32__
- {
- int errNum = fileError();
- throw DL_ABORT_EX2(fmt("File truncation failed. cause: %s",
- fileStrerror(errNum).c_str()),
- error_code::FILE_IO_ERROR);
- }
+ {
+ int errNum = fileError();
+ throw DL_ABORT_EX2(
+ fmt("File truncation failed. cause: %s", fileStrerror(errNum).c_str()),
+ error_code::FILE_IO_ERROR);
+ }
}
void AbstractDiskWriter::allocate(int64_t offset, int64_t length, bool sparse)
{
- if(fd_ == A2_BAD_FD) {
+ if (fd_ == A2_BAD_FD) {
throw DL_ABORT_EX("File not yet opened.");
}
- if(sparse) {
+ if (sparse) {
#ifdef __MINGW32__
DWORD bytesReturned;
- if(!DeviceIoControl(fd_, FSCTL_SET_SPARSE, 0, 0, 0, 0,
- &bytesReturned, 0)) {
+ if (!DeviceIoControl(fd_, FSCTL_SET_SPARSE, 0, 0, 0, 0, &bytesReturned,
+ 0)) {
A2_LOG_WARN(fmt("Making file sparse failed or pending: %s",
fileStrerror(GetLastError()).c_str()));
}
#endif // __MINGW32__
- truncate(offset+length);
+ truncate(offset + length);
return;
}
-#ifdef HAVE_SOME_FALLOCATE
-# ifdef __MINGW32__
- truncate(offset+length);
-# elif defined(__APPLE__) && defined(__MACH__)
+#ifdef HAVE_SOME_FALLOCATE
+#ifdef __MINGW32__
+ truncate(offset + length);
+#elif defined(__APPLE__) && defined(__MACH__)
auto toalloc = offset + length - size();
while (toalloc > 0) {
fstore_t fstore = {
- F_ALLOCATECONTIG | F_ALLOCATEALL,
- F_PEOFPOSMODE,
- 0,
- // Allocate in 1GB chunks or else some OSX versions may choke.
- std::min(toalloc, (int64_t)1<<30),
- 0
- };
+ F_ALLOCATECONTIG | F_ALLOCATEALL, F_PEOFPOSMODE, 0,
+ // Allocate in 1GB chunks or else some OSX versions may choke.
+ std::min(toalloc, (int64_t)1 << 30), 0};
if (fcntl(fd_, F_PREALLOCATE, &fstore) == -1) {
// Retry non-contig.
fstore.fst_flags = F_ALLOCATEALL;
if (fcntl(fd_, F_PREALLOCATE, &fstore) == -1) {
int err = errno;
- throw DL_ABORT_EX3(err,
- fmt("fcntl(F_PREALLOCATE) of %" PRId64 " failed. cause: %s",
- fstore.fst_length, util::safeStrerror(err).c_str()),
- error_code::FILE_IO_ERROR);
+ throw DL_ABORT_EX3(
+ err, fmt("fcntl(F_PREALLOCATE) of %" PRId64 " failed. cause: %s",
+ fstore.fst_length, util::safeStrerror(err).c_str()),
+ error_code::FILE_IO_ERROR);
}
}
toalloc -= fstore.fst_bytesalloc;
}
// This forces the allocation on disk.
ftruncate(fd_, offset + length);
-# elif HAVE_FALLOCATE
+#elif HAVE_FALLOCATE
// For linux, we use fallocate to detect file system supports
// fallocate or not.
int r;
- while((r = fallocate(fd_, 0, offset, length)) == -1 && errno == EINTR);
+ while ((r = fallocate(fd_, 0, offset, length)) == -1 && errno == EINTR)
+ ;
int errNum = errno;
- if(r == -1) {
- throw DL_ABORT_EX3(errNum,
- fmt("fallocate failed. cause: %s",
- util::safeStrerror(errNum).c_str()),
+ if (r == -1) {
+ throw DL_ABORT_EX3(errNum, fmt("fallocate failed. cause: %s",
+ util::safeStrerror(errNum).c_str()),
error_code::FILE_IO_ERROR);
}
-# elif HAVE_POSIX_FALLOCATE
+#elif HAVE_POSIX_FALLOCATE
int r = posix_fallocate(fd_, offset, length);
- if(r != 0) {
- throw DL_ABORT_EX3(r,
- fmt("posix_fallocate failed. cause: %s",
- util::safeStrerror(r).c_str()),
+ if (r != 0) {
+ throw DL_ABORT_EX3(r, fmt("posix_fallocate failed. cause: %s",
+ util::safeStrerror(r).c_str()),
error_code::FILE_IO_ERROR);
}
-# else
-# error "no *_fallocate function available."
-# endif
+#else
+#error "no *_fallocate function available."
+#endif
#endif // HAVE_SOME_FALLOCATE
}
-int64_t AbstractDiskWriter::size()
-{
- return File(filename_).size();
-}
+int64_t AbstractDiskWriter::size() { return File(filename_).size(); }
-void AbstractDiskWriter::enableReadOnly()
-{
- readOnly_ = true;
-}
+void AbstractDiskWriter::enableReadOnly() { readOnly_ = true; }
-void AbstractDiskWriter::disableReadOnly()
-{
- readOnly_ = false;
-}
+void AbstractDiskWriter::disableReadOnly() { readOnly_ = false; }
-void AbstractDiskWriter::enableMmap()
-{
- enableMmap_ = true;
-}
+void AbstractDiskWriter::enableMmap() { enableMmap_ = true; }
void AbstractDiskWriter::dropCache(int64_t len, int64_t offset)
{