From: Roi Dayan Date: Mon, 1 Feb 2016 09:46:15 +0000 (+0200) Subject: xio: fix compilation X-Git-Tag: v10.0.4~78^2 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=refs%2Fpull%2F7479%2Fhead;p=ceph.git xio: fix compilation Signed-off-by: Roi Dayan --- diff --git a/src/msg/xio/QueueStrategy.cc b/src/msg/xio/QueueStrategy.cc index 2d9806c67970..0ce279b31e9f 100644 --- a/src/msg/xio/QueueStrategy.cc +++ b/src/msg/xio/QueueStrategy.cc @@ -11,6 +11,7 @@ * Foundation. See file COPYING. * */ +#include #include "QueueStrategy.h" #define dout_subsys ceph_subsys_ms #include "common/debug.h" @@ -106,8 +107,10 @@ void QueueStrategy::start() assert(!stop); lock.Lock(); for (int ix = 0; ix < n_threads; ++ix) { + string thread_name = "ms_xio_qs_"; + thread_name.append(std::to_string(ix)); thrd = new QSThread(this); - thrd->create(); + thrd->create(thread_name.c_str()); } lock.Unlock(); } diff --git a/src/msg/xio/XioConnection.h b/src/msg/xio/XioConnection.h index da34d6e5520f..7226ef652125 100644 --- a/src/msg/xio/XioConnection.h +++ b/src/msg/xio/XioConnection.h @@ -265,8 +265,8 @@ public: void send_keepalive() override {} void mark_down() override; int _mark_down(uint32_t flags); - virtual void mark_disposable() override; - int _mark_disposable(uint32_t flags) override; + void mark_disposable() override; + int _mark_disposable(uint32_t flags); const entity_inst_t& get_peer() const { return peer; } @@ -337,7 +337,7 @@ public: bool is_connected() override { return true; } int send_message(Message *m) override; - void send_keepalive()i override {} + void send_keepalive() override {} void mark_down() override {} void mark_disposable() override {} diff --git a/src/msg/xio/XioPortal.h b/src/msg/xio/XioPortal.h index cb711c66d24c..697c62e5c227 100644 --- a/src/msg/xio/XioPortal.h +++ b/src/msg/xio/XioPortal.h @@ -424,11 +424,11 @@ public: /* shift left */ p_vec[(p_ix-1)] = (char*) /* portal->xio_uri.c_str() */ portal->portal_id; - } + } for (p_ix = 0; p_ix < nportals; ++p_ix) { portal = portals[p_ix]; - portal->create(); + portal->create(portal->portal_id); } }