Merge "libsnapshot: chunk iov writes" into main
This commit is contained in:
commit
6bee318285
1 changed files with 17 additions and 3 deletions
|
@ -717,13 +717,27 @@ bool CowWriterV3::WriteOperation(std::span<const CowOperationV3> ops,
|
|||
return false;
|
||||
}
|
||||
if (!data.empty()) {
|
||||
const auto ret = pwritev(fd_, data.data(), data.size(), next_data_pos_);
|
||||
if (ret != total_data_size) {
|
||||
int total_written = 0;
|
||||
int i = 0;
|
||||
while (i < data.size()) {
|
||||
int chunk = std::min(static_cast<int>(data.size() - i), IOV_MAX);
|
||||
|
||||
const auto ret = pwritev(fd_, data.data() + i, chunk, next_data_pos_ + total_written);
|
||||
if (ret < 0) {
|
||||
PLOG(ERROR) << "write failed chunk size of: " << chunk
|
||||
<< " at offset: " << next_data_pos_ + total_written << " " << errno;
|
||||
return false;
|
||||
}
|
||||
total_written += ret;
|
||||
i += chunk;
|
||||
}
|
||||
if (total_written != total_data_size) {
|
||||
PLOG(ERROR) << "write failed for data of size: " << data.size()
|
||||
<< " at offset: " << next_data_pos_ << " " << ret;
|
||||
<< " at offset: " << next_data_pos_ << " " << errno;
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
header_.op_count += ops.size();
|
||||
next_data_pos_ += total_data_size;
|
||||
|
||||
|
|
Loading…
Reference in a new issue