test/crimson: test messenger only on designated core

Messenger/Connection are not implemented properly to be a cross-core
service, and the related use cases are not defined yet.

Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>

diff --git a/src/test/crimson/test_messenger.cc b/src/test/crimson/test_messenger.cc
index c216afdebf0f1a03c77938b494fb6ea41fcf91af..83bd2a051d09707339ac8ad213a8f35b7cd33bf9 100644 (file)
--- a/src/test/crimson/test_messenger.cc
+++ b/src/test/crimson/test_messenger.cc
@@ -67,7 +67,7 @@ static seastar::future<> test_echo(unsigned rounds,
                              const std::string& lname,
                              const uint64_t nonce,
                              const entity_addr_t& addr) {
-        auto&& fut = crimson::net::Messenger::create(name, lname, nonce);
+        auto&& fut = crimson::net::Messenger::create(name, lname, nonce, 0);
         return fut.then([this, addr](crimson::net::Messenger *messenger) {
             return container().invoke_on_all([messenger](auto& server) {
                 server.msgr = messenger->get_local_shard();
@@ -156,7 +156,7 @@ static seastar::future<> test_echo(unsigned rounds,
       seastar::future<> init(const entity_name_t& name,
                              const std::string& lname,
                              const uint64_t nonce) {
-        return crimson::net::Messenger::create(name, lname, nonce)
+        return crimson::net::Messenger::create(name, lname, nonce, 0)
           .then([this](crimson::net::Messenger *messenger) {
             return container().invoke_on_all([messenger](auto& client) {
                 client.msgr = messenger->get_local_shard();