X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Ftest%2Fmon%2FMonMap.cc;fp=src%2Fceph%2Fsrc%2Ftest%2Fmon%2FMonMap.cc;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=84d8b2691befd199dccb921998581a758c3a8c19;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/test/mon/MonMap.cc b/src/ceph/src/test/mon/MonMap.cc deleted file mode 100644 index 84d8b26..0000000 --- a/src/ceph/src/test/mon/MonMap.cc +++ /dev/null @@ -1,220 +0,0 @@ -// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- -// vim: ts=8 sw=2 smarttab -/* - * Ceph - scalable distributed file system - * - * Copyright (C) 2016 SUSE LINUX GmbH - * - * This is free software; you can redistribute it and/or - * modify it under the terms of the GNU Lesser General Public - * License version 2.1, as published by the Free Software - * Foundation. See file COPYING. - * - */ -#include "mon/MonMap.h" -#include "common/ceph_context.h" -#include "common/dns_resolve.h" -#include "test/common/dns_messages.h" - -#include "common/debug.h" -#include "gmock/gmock.h" -#include "gtest/gtest.h" - -#include - -#define TEST_DEBUG 20 - -#define dout_subsys ceph_subsys_mon - - -using ::testing::Return; -using ::testing::_; -using ::testing::SetArrayArgument; -using ::testing::DoAll; -using ::testing::StrEq; - - -class MonMapTest : public ::testing::Test { - protected: - virtual void SetUp() { - g_ceph_context->_conf->subsys.set_log_level(dout_subsys, TEST_DEBUG); - } - - virtual void TearDown() { - DNSResolver::get_instance(nullptr); - } -}; - -TEST_F(MonMapTest, build_initial_config_from_dns) { - - MockResolvHWrapper *resolvH = new MockResolvHWrapper(); - DNSResolver::get_instance(resolvH); - - int len = sizeof(ns_search_msg_ok_payload); - int lena = sizeof(ns_query_msg_mon_a_payload); - int lenb = sizeof(ns_query_msg_mon_b_payload); - int lenc = sizeof(ns_query_msg_mon_c_payload); - - using ::testing::InSequence; - { - InSequence s; - -#ifdef HAVE_RES_NQUERY - EXPECT_CALL(*resolvH, res_nsearch(_, StrEq("_cephmon._tcp"), C_IN, T_SRV, _, _)) - .WillOnce(DoAll(SetArrayArgument<4>(ns_search_msg_ok_payload, - ns_search_msg_ok_payload+len), Return(len))); - - EXPECT_CALL(*resolvH, res_nquery(_,StrEq("mon.a.ceph.com"), C_IN, T_A,_,_)) - .WillOnce(DoAll(SetArrayArgument<4>(ns_query_msg_mon_a_payload, - ns_query_msg_mon_a_payload+lena), Return(lena))); - - EXPECT_CALL(*resolvH, res_nquery(_, StrEq("mon.c.ceph.com"), C_IN, T_A,_,_)) - .WillOnce(DoAll(SetArrayArgument<4>(ns_query_msg_mon_c_payload, - ns_query_msg_mon_c_payload+lenc), Return(lenc))); - - EXPECT_CALL(*resolvH, res_nquery(_,StrEq("mon.b.ceph.com"), C_IN, T_A, _,_)) - .WillOnce(DoAll(SetArrayArgument<4>(ns_query_msg_mon_b_payload, - ns_query_msg_mon_b_payload+lenb), Return(lenb))); -#else - EXPECT_CALL(*resolvH, res_search(StrEq("_cephmon._tcp"), C_IN, T_SRV, _, _)) - .WillOnce(DoAll(SetArrayArgument<3>(ns_search_msg_ok_payload, - ns_search_msg_ok_payload+len), Return(len))); - - EXPECT_CALL(*resolvH, res_query(StrEq("mon.a.ceph.com"), C_IN, T_A,_,_)) - .WillOnce(DoAll(SetArrayArgument<3>(ns_query_msg_mon_a_payload, - ns_query_msg_mon_a_payload+lena), Return(lena))); - - EXPECT_CALL(*resolvH, res_query(StrEq("mon.c.ceph.com"), C_IN, T_A,_,_)) - .WillOnce(DoAll(SetArrayArgument<3>(ns_query_msg_mon_c_payload, - ns_query_msg_mon_c_payload+lenc), Return(lenc))); - - EXPECT_CALL(*resolvH, res_query(StrEq("mon.b.ceph.com"), C_IN, T_A, _,_)) - .WillOnce(DoAll(SetArrayArgument<3>(ns_query_msg_mon_b_payload, - ns_query_msg_mon_b_payload+lenb), Return(lenb))); -#endif - } - - - - CephContext *cct = (new CephContext(CEPH_ENTITY_TYPE_MON))->get(); - cct->_conf->set_val("mon_dns_srv_name", "cephmon", false); - MonMap monmap; - int r = monmap.build_initial(cct, std::cerr); - - ASSERT_EQ(r, 0); - ASSERT_EQ(monmap.mon_addr.size(), (unsigned int)3); - map::iterator it = monmap.mon_addr.find("mon.a"); - ASSERT_NE(it, monmap.mon_addr.end()); - std::ostringstream os; - os << it->second; - ASSERT_EQ(os.str(), "192.168.1.11:6789/0"); - os.str(""); - it = monmap.mon_addr.find("mon.b"); - ASSERT_NE(it, monmap.mon_addr.end()); - os << it->second; - ASSERT_EQ(os.str(), "192.168.1.12:6789/0"); - os.str(""); - it = monmap.mon_addr.find("mon.c"); - ASSERT_NE(it, monmap.mon_addr.end()); - os << it->second; - ASSERT_EQ(os.str(), "192.168.1.13:6789/0"); -} - -TEST_F(MonMapTest, build_initial_config_from_dns_fail) { - MockResolvHWrapper *resolvH = new MockResolvHWrapper(); - DNSResolver::get_instance(resolvH); - - -#ifdef HAVE_RES_NQUERY - EXPECT_CALL(*resolvH, res_nsearch(_, StrEq("_ceph-mon._tcp"), C_IN, T_SRV, _, _)) - .WillOnce(Return(0)); -#else - EXPECT_CALL(*resolvH, res_search(StrEq("_ceph-mon._tcp"), C_IN, T_SRV, _, _)) - .WillOnce(Return(0)); -#endif - - CephContext *cct = (new CephContext(CEPH_ENTITY_TYPE_MON))->get(); - // using default value of mon_dns_srv_name option - MonMap monmap; - int r = monmap.build_initial(cct, std::cerr); - - ASSERT_EQ(r, -ENOENT); - ASSERT_EQ(monmap.mon_addr.size(), (unsigned int)0); - -} - -TEST_F(MonMapTest, build_initial_config_from_dns_with_domain) { - - MockResolvHWrapper *resolvH = new MockResolvHWrapper(); - DNSResolver::get_instance(resolvH); - - int len = sizeof(ns_search_msg_ok_payload); - int lena = sizeof(ns_query_msg_mon_a_payload); - int lenb = sizeof(ns_query_msg_mon_b_payload); - int lenc = sizeof(ns_query_msg_mon_c_payload); - - using ::testing::InSequence; - { - InSequence s; - -#ifdef HAVE_RES_NQUERY - EXPECT_CALL(*resolvH, res_nsearch(_, StrEq("_cephmon._tcp.ceph.com"), C_IN, T_SRV, _, _)) - .WillOnce(DoAll(SetArrayArgument<4>(ns_search_msg_ok_payload, - ns_search_msg_ok_payload+len), Return(len))); - - EXPECT_CALL(*resolvH, res_nquery(_,StrEq("mon.a.ceph.com"), C_IN, T_A,_,_)) - .WillOnce(DoAll(SetArrayArgument<4>(ns_query_msg_mon_a_payload, - ns_query_msg_mon_a_payload+lena), Return(lena))); - - EXPECT_CALL(*resolvH, res_nquery(_, StrEq("mon.c.ceph.com"), C_IN, T_A,_,_)) - .WillOnce(DoAll(SetArrayArgument<4>(ns_query_msg_mon_c_payload, - ns_query_msg_mon_c_payload+lenc), Return(lenc))); - - EXPECT_CALL(*resolvH, res_nquery(_,StrEq("mon.b.ceph.com"), C_IN, T_A, _,_)) - .WillOnce(DoAll(SetArrayArgument<4>(ns_query_msg_mon_b_payload, - ns_query_msg_mon_b_payload+lenb), Return(lenb))); -#else - EXPECT_CALL(*resolvH, res_search(StrEq("_cephmon._tcp.ceph.com"), C_IN, T_SRV, _, _)) - .WillOnce(DoAll(SetArrayArgument<3>(ns_search_msg_ok_payload, - ns_search_msg_ok_payload+len), Return(len))); - - EXPECT_CALL(*resolvH, res_query(StrEq("mon.a.ceph.com"), C_IN, T_A,_,_)) - .WillOnce(DoAll(SetArrayArgument<3>(ns_query_msg_mon_a_payload, - ns_query_msg_mon_a_payload+lena), Return(lena))); - - EXPECT_CALL(*resolvH, res_query(StrEq("mon.c.ceph.com"), C_IN, T_A,_,_)) - .WillOnce(DoAll(SetArrayArgument<3>(ns_query_msg_mon_c_payload, - ns_query_msg_mon_c_payload+lenc), Return(lenc))); - - EXPECT_CALL(*resolvH, res_query(StrEq("mon.b.ceph.com"), C_IN, T_A, _,_)) - .WillOnce(DoAll(SetArrayArgument<3>(ns_query_msg_mon_b_payload, - ns_query_msg_mon_b_payload+lenb), Return(lenb))); -#endif - } - - - - CephContext *cct = (new CephContext(CEPH_ENTITY_TYPE_MON))->get(); - cct->_conf->set_val("mon_dns_srv_name", "cephmon_ceph.com", false); - MonMap monmap; - int r = monmap.build_initial(cct, std::cerr); - - ASSERT_EQ(r, 0); - ASSERT_EQ(monmap.mon_addr.size(), (unsigned int)3); - map::iterator it = monmap.mon_addr.find("mon.a"); - ASSERT_NE(it, monmap.mon_addr.end()); - std::ostringstream os; - os << it->second; - ASSERT_EQ(os.str(), "192.168.1.11:6789/0"); - os.str(""); - it = monmap.mon_addr.find("mon.b"); - ASSERT_NE(it, monmap.mon_addr.end()); - os << it->second; - ASSERT_EQ(os.str(), "192.168.1.12:6789/0"); - os.str(""); - it = monmap.mon_addr.find("mon.c"); - ASSERT_NE(it, monmap.mon_addr.end()); - os << it->second; - ASSERT_EQ(os.str(), "192.168.1.13:6789/0"); -} -