mirrors/scylladb
1
0
Fork 0
mirror of https://github.com/scylladb/scylladb.git synced 2026-04-21 17:10:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

core: remove unused smp code

Browse Source
This commit is contained in:
Gleb Natapov
2015-01-13 15:13:36 +02:00
committed by Avi Kivity
parent 4c46f4db8c
commit d4db9493ae
2 changed files with 0 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
core/reactor.cc
View File

@@ -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

3
core/reactor.hh
View File

@@ -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: