import quincy beta 17.1.0

[ceph.git] / ceph / src / seastar / src / net / stack.cc

diff --git a/ceph/src/seastar/src/net/stack.cc b/ceph/src/seastar/src/net/stack.cc
index dc626d251cfe4292fa79d9af5731ae56fd279fdf..a4e1633c3a0fa39f2086087959901dca800cf4ef 100644 (file)
--- a/ceph/src/seastar/src/net/stack.cc
+++ b/ceph/src/seastar/src/net/stack.cc
@@ -97,8 +97,10 @@ input_stream<char> connected_socket::input(connected_socket_input_stream_config
 }
 
 output_stream<char> connected_socket::output(size_t buffer_size) {
+    output_stream_options opts;
+    opts.batch_flushes = true;
     // TODO: allow user to determine buffer size etc
-    return output_stream<char>(_csi->sink(), buffer_size, false, true);
+    return output_stream<char>(_csi->sink(), buffer_size, opts);
 }
 
 void connected_socket::set_nodelay(bool nodelay) {
@@ -127,6 +129,10 @@ int connected_socket::get_sockopt(int level, int optname, void* data, size_t len
     return _csi->get_sockopt(level, optname, data, len);
 }
 
+socket_address connected_socket::local_address() const noexcept {
+    return _csi->local_address();
+}
+
 void connected_socket::shutdown_output() {
     _csi->shutdown_output();
 }