RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-03-06 16:28:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

crimson/osd: adapt to the new interface of seastar::make_file_output_stream().

Browse Source 
Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>
This commit is contained in:
Radoslaw Zarzynski 2020-08-05 11:40:14 -04:00
parent d483c52375
commit c155464f6a
1 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
src/crimson/common/buffer_io.cc
View File

@ -22,16 +22,19 @@ seastar::future<> write_file(ceph::buffer::list&& bl,
foo.create_permissions = permissions;
return seastar::open_file_dma(fn, flags, foo).then(
[bl=std::move(bl)](seastar::file f) {
return seastar::do_with(seastar::make_file_output_stream(f),
std::move(f),
std::move(bl),
[](seastar::output_stream<char>& out,
seastar::file& f,
ceph::buffer::list& bl) {
return seastar::do_for_each(bl.buffers(), [&out](auto& buf) {
return out.write(buf.c_str(), buf.length());
}).then([&out] {
return out.close();
return seastar::make_file_output_stream(f).then(
[bl=std::move(bl), f=std::move(f)](seastar::output_stream<char> out) {
return seastar::do_with(std::move(out),
std::move(f),
std::move(bl),
[](seastar::output_stream<char>& out,
seastar::file& f,
ceph::buffer::list& bl) {
return seastar::do_for_each(bl.buffers(), [&out](auto& buf) {
return out.write(buf.c_str(), buf.length());
}).then([&out] {
return out.close();
});
});
});
});