From d4db9493aef2e85091fffa456f90493a11fa18ed Mon Sep 17 00:00:00 2001
From: Gleb Natapov <gleb@cloudius-systems.com>
Date: Tue, 13 Jan 2015 15:13:36 +0200
Subject: [PATCH] core: remove unused smp code

---
 core/reactor.cc | 9 ---------
 core/reactor.hh | 3 ---
 2 files changed, 12 deletions(-)

diff --git a/core/reactor.cc b/core/reactor.cc
index b61640a1e2..450fbc2b80 100644
--- a/core/reactor.cc
+++ b/core/reactor.cc
@@ -913,7 +913,6 @@ size_t smp_message_queue::process_incoming() {
 
 void smp_message_queue::start() {
     _tx.init();
-    _complete_peer = &engine;
 }
 
 /* not yet implemented for OSv. TODO: do the notification like we do class smp. */
@@ -1060,19 +1059,11 @@ smp_message_queue** smp::_qs;
 std::thread::id smp::_tmain;
 unsigned smp::count = 1;
 
-void smp::listen_all(smp_message_queue* qs)
-{
-    for (unsigned i = 0; i < smp::count; i++) {
-        qs[i]._pending_peer = &engine;
-    }
-}
-
 void smp::start_all_queues()
 {
     for (unsigned c = 0; c < count; c++) {
         _qs[c][engine.cpu_id()].start();
     }
-    listen_all(_qs[engine.cpu_id()]);
 }
 
 #ifdef HAVE_DPDK
diff --git a/core/reactor.hh b/core/reactor.hh
index beb9285380..11e60edffd 100644
--- a/core/reactor.hh
+++ b/core/reactor.hh
@@ -389,8 +389,6 @@ class smp_message_queue {
     lf_queue _pending;
     lf_queue _completed;
     size_t _current_queue_length = 0;
-    reactor* _pending_peer;
-    reactor* _complete_peer;
     struct work_item {
         virtual ~work_item() {}
         virtual future<> process() = 0;
@@ -854,7 +852,6 @@ public:
         return got != 0;
     }
 private:
-    static void listen_all(smp_message_queue* qs);
     static void start_all_queues();
     static void pin(unsigned cpu_id);
 public: