import 15.2.0 Octopus source

[ceph.git] / ceph / src / seastar / include / seastar / net / arp.hh

diff --git a/ceph/src/seastar/include/seastar/net/arp.hh b/ceph/src/seastar/include/seastar/net/arp.hh
index 83d7f084f4c02a5ad2c0c18d4ff3cebc386ee5d5..51f540b80e5427600a462f1393a4a3a1a970e078 100644 (file)
--- a/ceph/src/seastar/include/seastar/net/arp.hh
+++ b/ceph/src/seastar/include/seastar/net/arp.hh
@@ -26,7 +26,6 @@
 #include <seastar/core/reactor.hh>
 #include <seastar/core/byteorder.hh>
 #include <seastar/net/ethernet.hh>
-#include <seastar/core/print.hh>
 #include <unordered_map>
 
 namespace seastar {
@@ -52,7 +51,6 @@ public:
 class arp {
     interface* _netif;
     l3_protocol _proto;
-    subscription<packet, ethernet_address> _rx_packets;
     std::unordered_map<uint16_t, arp_for_protocol*> _arp_for_protocol;
     circular_buffer<l3_protocol::l3packet> _packetq;
 private:
@@ -220,14 +218,16 @@ arp_for<L3>::lookup(const l3addr& paddr) {
 
     if (first_request) {
         res._timeout_timer.set_callback([paddr, this, &res] {
-            send_query(paddr);
+            // FIXME: future is discarded
+            (void)send_query(paddr);
             for (auto& w : res._waiters) {
                 w.set_exception(arp_timeout_error());
             }
             res._waiters.clear();
         });
         res._timeout_timer.arm_periodic(std::chrono::seconds(1));
-        send_query(paddr);
+        // FIXME: future is discarded
+        (void)send_query(paddr);
     }
 
     if (res._waiters.size() >= max_waiters) {