]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
crimson/osd: adapt to the new interface of seastar::make_file_output_stream().
authorRadoslaw Zarzynski <rzarzyns@redhat.com>
Wed, 5 Aug 2020 15:40:14 +0000 (11:40 -0400)
committerRadoslaw Zarzynski <rzarzyns@redhat.com>
Thu, 6 Aug 2020 22:00:07 +0000 (18:00 -0400)
Signed-off-by: Radoslaw Zarzynski <rzarzyns@redhat.com>
src/crimson/common/buffer_io.cc

index 0e436d98b59a0a37867034adaef2092793fcfeb5..86edf7a6f52691469576945d954f80255f76cb8a 100644 (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();
+        });
       });
     });
   });