nc_remove_unittests.cc 79 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872
  1. // Copyright (C) 2013 Internet Systems Consortium, Inc. ("ISC")
  2. //
  3. // Permission to use, copy, modify, and/or distribute this software for any
  4. // purpose with or without fee is hereby granted, provided that the above
  5. // copyright notice and this permission notice appear in all copies.
  6. //
  7. // THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH
  8. // REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY
  9. // AND FITNESS. IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT,
  10. // INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM
  11. // LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE
  12. // OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR
  13. // PERFORMANCE OF THIS SOFTWARE.
  14. #include <d2/d2_cfg_mgr.h>
  15. #include <d2/d2_cfg_mgr.h>
  16. #include <d2/nc_remove.h>
  17. #include <dns/messagerenderer.h>
  18. #include <nc_test_utils.h>
  19. #include <boost/function.hpp>
  20. #include <boost/bind.hpp>
  21. #include <gtest/gtest.h>
  22. using namespace std;
  23. using namespace isc;
  24. using namespace isc::d2;
  25. namespace {
  26. /// @brief Test class derived from NameRemoveTransaction to provide visiblity
  27. // to protected methods.
  28. class NameRemoveStub : public NameRemoveTransaction {
  29. public:
  30. NameRemoveStub(IOServicePtr& io_service,
  31. dhcp_ddns::NameChangeRequestPtr& ncr,
  32. DdnsDomainPtr& forward_domain,
  33. DdnsDomainPtr& reverse_domain)
  34. : NameRemoveTransaction(io_service, ncr, forward_domain,
  35. reverse_domain),
  36. simulate_send_exception_(false),
  37. simulate_build_request_exception_(false) {
  38. }
  39. virtual ~NameRemoveStub() {
  40. }
  41. /// @brief Simulates sending update requests to the DNS server
  42. ///
  43. /// This method simulates the initiation of an asynchronous send of
  44. /// a DNS update request. It overrides the actual sendUpdate method in
  45. /// the base class, thus avoiding an actual send, yet still increments
  46. /// the update attempt count and posts a next event of NOP_EVT.
  47. ///
  48. /// It will also simulate an exception-based failure of sendUpdate, if
  49. /// the simulate_send_exception_ flag is true.
  50. ///
  51. /// @param use_tsig_ Parameter is unused, but present in the base class
  52. /// method.
  53. ///
  54. virtual void sendUpdate(bool /* use_tsig_ = false */) {
  55. if (simulate_send_exception_) {
  56. // Make the flag a one-shot by resetting it.
  57. simulate_send_exception_ = false;
  58. // Transition to failed.
  59. transition(PROCESS_TRANS_FAILED_ST, UPDATE_FAILED_EVT);
  60. return;
  61. }
  62. // Update send attempt count and post a NOP_EVT.
  63. setUpdateAttempts(getUpdateAttempts() + 1);
  64. postNextEvent(StateModel::NOP_EVT);
  65. }
  66. /// @brief Prepares the initial D2UpdateMessage
  67. ///
  68. /// This method overrides the NameChangeTransactio implementation to
  69. /// provide the ability to simulate an exception throw in the build
  70. /// request logic.
  71. /// If the one-shot flag, simulate_build_request_exception_ is true,
  72. /// this method will throw an exception, otherwise it will invoke the
  73. /// base class method, providing normal functionality.
  74. ///
  75. /// For parameter description see the NameChangeTransaction implementation.
  76. virtual D2UpdateMessagePtr prepNewRequest(DdnsDomainPtr domain) {
  77. if (simulate_build_request_exception_) {
  78. simulate_build_request_exception_ = false;
  79. isc_throw (NameRemoveTransactionError,
  80. "Simulated build requests exception");
  81. }
  82. return (NameChangeTransaction::prepNewRequest(domain));
  83. }
  84. /// @brief Simulates receiving a response
  85. ///
  86. /// This method simulates the completion of a DNSClient send. This allows
  87. /// the state handler logic devoted to dealing with IO completion to be
  88. /// fully exercise without requiring any actual IO. The two primary
  89. /// pieces of information gleaned from IO completion are the DNSClient
  90. /// status which indicates whether or not the IO exchange was successful
  91. /// and the rcode, which indicates the server's reaction to the request.
  92. ///
  93. /// This method updates the transaction's DNS status value to that of the
  94. /// given parameter, and then constructs and DNS update response message
  95. /// with the given rcode value. To complete the simulation it then posts
  96. /// a next event of IO_COMPLETED_EVT.
  97. ///
  98. /// @param status simulated DNSClient status
  99. /// @param rcode simulated server response code
  100. void fakeResponse(const DNSClient::Status& status,
  101. const dns::Rcode& rcode) {
  102. // Set the DNS update status. This is normally set in
  103. // DNSClient IO completion handler.
  104. setDnsUpdateStatus(status);
  105. // Construct an empty message with the given Rcode.
  106. D2UpdateMessagePtr msg(new D2UpdateMessage(D2UpdateMessage::OUTBOUND));
  107. msg->setRcode(rcode);
  108. // Set the update response to the message.
  109. setDnsUpdateResponse(msg);
  110. // Post the IO completion event.
  111. postNextEvent(NameChangeTransaction::IO_COMPLETED_EVT);
  112. }
  113. /// @brief Selects the first forward server.
  114. /// Some state handlers require a server to have been selected.
  115. /// This selects a server without going through the state
  116. /// transition(s) to do so.
  117. bool selectFwdServer() {
  118. if (getForwardDomain()) {
  119. initServerSelection(getForwardDomain());
  120. selectNextServer();
  121. return (getCurrentServer());
  122. }
  123. return (false);
  124. }
  125. /// @brief Selects the first reverse server.
  126. /// Some state handlers require a server to have been selected.
  127. /// This selects a server without going through the state
  128. /// transition(s) to do so.
  129. bool selectRevServer() {
  130. if (getReverseDomain()) {
  131. initServerSelection(getReverseDomain());
  132. selectNextServer();
  133. return (getCurrentServer());
  134. }
  135. return (false);
  136. }
  137. /// @brief One-shot flag which will simulate sendUpdate failure if true.
  138. bool simulate_send_exception_;
  139. /// @brief One-shot flag which will simulate an exception when sendUpdate
  140. /// failure if true.
  141. bool simulate_build_request_exception_;
  142. using StateModel::postNextEvent;
  143. using StateModel::setState;
  144. using StateModel::initDictionaries;
  145. using NameRemoveTransaction::defineEvents;
  146. using NameRemoveTransaction::verifyEvents;
  147. using NameRemoveTransaction::defineStates;
  148. using NameRemoveTransaction::verifyStates;
  149. using NameRemoveTransaction::readyHandler;
  150. using NameRemoveTransaction::selectingFwdServerHandler;
  151. using NameRemoveTransaction::getCurrentServer;
  152. using NameRemoveTransaction::removingFwdAddrsHandler;
  153. using NameRemoveTransaction::setDnsUpdateStatus;
  154. using NameRemoveTransaction::removingFwdRRsHandler;
  155. using NameRemoveTransaction::selectingRevServerHandler;
  156. using NameRemoveTransaction::removingRevPtrsHandler;
  157. using NameRemoveTransaction::processRemoveOkHandler;
  158. using NameRemoveTransaction::processRemoveFailedHandler;
  159. using NameRemoveTransaction::buildRemoveFwdAddressRequest;
  160. using NameRemoveTransaction::buildRemoveFwdRRsRequest;
  161. using NameRemoveTransaction::buildRemoveRevPtrsRequest;
  162. };
  163. typedef boost::shared_ptr<NameRemoveStub> NameRemoveStubPtr;
  164. /// @brief Test fixture for testing NameRemoveTransaction
  165. ///
  166. /// Note this class uses NameRemoveStub class to exercise non-public
  167. /// aspects of NameRemoveTransaction.
  168. class NameRemoveTransactionTest : public TransactionTest {
  169. public:
  170. NameRemoveTransactionTest() {
  171. }
  172. virtual ~NameRemoveTransactionTest() {
  173. }
  174. /// @brief Creates a transaction which requests an IPv4 DNS update.
  175. ///
  176. /// The transaction is constructed around a predefined (i.e. "canned")
  177. /// IPv4 NameChangeRequest. The request has both forward and reverse DNS
  178. /// changes requested. Based upon the change mask, the transaction
  179. /// will have either the forward, reverse, or both domains populated.
  180. ///
  181. /// @param change_mask determines which change directions are requested
  182. NameRemoveStubPtr makeTransaction4(int change_mask) {
  183. // Creates IPv4 remove request, forward, and reverse domains.
  184. setupForIPv4Transaction(dhcp_ddns::CHG_REMOVE, change_mask);
  185. // Now create the test transaction as would occur in update manager.
  186. return (NameRemoveStubPtr(new NameRemoveStub(io_service_, ncr_,
  187. forward_domain_,
  188. reverse_domain_)));
  189. }
  190. /// @brief Creates a transaction which requests an IPv6 DNS update.
  191. ///
  192. /// The transaction is constructed around a predefined (i.e. "canned")
  193. /// IPv6 NameChangeRequest. The request has both forward and reverse DNS
  194. /// changes requested. Based upon the change mask, the transaction
  195. /// will have either the forward, reverse, or both domains populated.
  196. ///
  197. /// @param change_mask determines which change directions are requested
  198. NameRemoveStubPtr makeTransaction6(int change_mask) {
  199. // Creates IPv6 remove request, forward, and reverse domains.
  200. setupForIPv6Transaction(dhcp_ddns::CHG_REMOVE, change_mask);
  201. // Now create the test transaction as would occur in update manager.
  202. return (NameRemoveStubPtr(new NameRemoveStub(io_service_, ncr_,
  203. forward_domain_,
  204. reverse_domain_)));
  205. }
  206. /// @brief Create a test transaction at a known point in the state model.
  207. ///
  208. /// Method prepares a new test transaction and sets its state and next
  209. /// event values to those given. This makes the transaction appear to
  210. /// be at that point in the state model without having to transition it
  211. /// through prerequisite states. It also provides the ability to set
  212. /// which change directions are requested: forward change only, reverse
  213. /// change only, or both.
  214. ///
  215. /// @param state value to set as the current state
  216. /// @param event value to post as the next event
  217. /// @param change_mask determines which change directions are requested
  218. /// @param family selects between an IPv4 (AF_INET) and IPv6 (AF_INET6)
  219. /// transaction.
  220. NameRemoveStubPtr prepHandlerTest(unsigned int state, unsigned int event,
  221. unsigned int change_mask
  222. = FWD_AND_REV_CHG,
  223. short family = AF_INET) {
  224. NameRemoveStubPtr name_remove = (family == AF_INET ?
  225. makeTransaction4(change_mask) :
  226. makeTransaction6(change_mask));
  227. name_remove->initDictionaries();
  228. name_remove->postNextEvent(event);
  229. name_remove->setState(state);
  230. return (name_remove);
  231. }
  232. };
  233. /// @brief Tests NameRemoveTransaction construction.
  234. /// This test verifies that:
  235. /// 1. Construction with invalid type of request
  236. /// 2. Valid construction functions properly
  237. TEST(NameRemoveTransaction, construction) {
  238. IOServicePtr io_service(new isc::asiolink::IOService());
  239. const char* msg_str =
  240. "{"
  241. " \"change_type\" : 0 , "
  242. " \"forward_change\" : true , "
  243. " \"reverse_change\" : true , "
  244. " \"fqdn\" : \"example.com.\" , "
  245. " \"ip_address\" : \"192.168.2.1\" , "
  246. " \"dhcid\" : \"0102030405060708\" , "
  247. " \"lease_expires_on\" : \"20130121132405\" , "
  248. " \"lease_length\" : 1300 "
  249. "}";
  250. dhcp_ddns::NameChangeRequestPtr ncr;
  251. DnsServerInfoStoragePtr servers;
  252. DdnsDomainPtr forward_domain;
  253. DdnsDomainPtr reverse_domain;
  254. DdnsDomainPtr empty_domain;
  255. ASSERT_NO_THROW(ncr = dhcp_ddns::NameChangeRequest::fromJSON(msg_str));
  256. ASSERT_NO_THROW(forward_domain.reset(new DdnsDomain("*", "", servers)));
  257. ASSERT_NO_THROW(reverse_domain.reset(new DdnsDomain("*", "", servers)));
  258. // Verify that construction with wrong change type fails.
  259. EXPECT_THROW(NameRemoveTransaction(io_service, ncr,
  260. forward_domain, reverse_domain),
  261. NameRemoveTransactionError);
  262. // Verify that a valid construction attempt works.
  263. ncr->setChangeType(isc::dhcp_ddns::CHG_REMOVE);
  264. EXPECT_NO_THROW(NameRemoveTransaction(io_service, ncr,
  265. forward_domain, reverse_domain));
  266. }
  267. /// @brief Tests event and state dictionary construction and verification.
  268. TEST_F(NameRemoveTransactionTest, dictionaryCheck) {
  269. NameRemoveStubPtr name_remove;
  270. ASSERT_NO_THROW(name_remove = makeTransaction4(FWD_AND_REV_CHG));
  271. // Verify that the event and state dictionary validation fails prior
  272. // dictionary construction.
  273. ASSERT_THROW(name_remove->verifyEvents(), StateModelError);
  274. ASSERT_THROW(name_remove->verifyStates(), StateModelError);
  275. // Construct both dictionaries.
  276. ASSERT_NO_THROW(name_remove->defineEvents());
  277. ASSERT_NO_THROW(name_remove->defineStates());
  278. // Verify both event and state dictionaries now pass validation.
  279. ASSERT_NO_THROW(name_remove->verifyEvents());
  280. ASSERT_NO_THROW(name_remove->verifyStates());
  281. }
  282. /// @brief Tests construction of a DNS update request for removing forward
  283. /// DNS address RRs.
  284. TEST_F(NameRemoveTransactionTest, buildRemoveFwdAddressRequest) {
  285. // Create a IPv4 forward add transaction.
  286. // Verify the request builds without error.
  287. // and then verify the request contents.
  288. NameRemoveStubPtr name_remove;
  289. ASSERT_NO_THROW(name_remove = makeTransaction4(FORWARD_CHG));
  290. ASSERT_NO_THROW(name_remove->buildRemoveFwdAddressRequest());
  291. checkRemoveFwdAddressRequest(*name_remove);
  292. // Create a IPv6 forward add transaction.
  293. // Verify the request builds without error.
  294. // and then verify the request contents.
  295. ASSERT_NO_THROW(name_remove = makeTransaction6(FORWARD_CHG));
  296. ASSERT_NO_THROW(name_remove->buildRemoveFwdAddressRequest());
  297. checkRemoveFwdAddressRequest(*name_remove);
  298. }
  299. /// @brief Tests construction of a DNS update request for removing forward
  300. /// dns RR entries.
  301. TEST_F(NameRemoveTransactionTest, buildRemoveFwdRRsRequest) {
  302. // Create a IPv4 forward replace transaction.
  303. // Verify the request builds without error.
  304. // and then verify the request contents.
  305. NameRemoveStubPtr name_remove;
  306. ASSERT_NO_THROW(name_remove = makeTransaction4(FORWARD_CHG));
  307. ASSERT_NO_THROW(name_remove->buildRemoveFwdRRsRequest());
  308. checkRemoveFwdRRsRequest(*name_remove);
  309. // Create a IPv6 forward replace transaction.
  310. // Verify the request builds without error.
  311. // and then verify the request contents.
  312. ASSERT_NO_THROW(name_remove = makeTransaction6(FORWARD_CHG));
  313. ASSERT_NO_THROW(name_remove->buildRemoveFwdRRsRequest());
  314. checkRemoveFwdRRsRequest(*name_remove);
  315. }
  316. /// @brief Tests the construction of a DNS update request for removing a
  317. /// reverse dns entry.
  318. TEST_F(NameRemoveTransactionTest, buildRemoveRevPtrsRequest) {
  319. // Create a IPv4 reverse replace transaction.
  320. // Verify the request builds without error.
  321. // and then verify the request contents.
  322. NameRemoveStubPtr name_remove;
  323. ASSERT_NO_THROW(name_remove = makeTransaction4(REVERSE_CHG));
  324. ASSERT_NO_THROW(name_remove->buildRemoveRevPtrsRequest());
  325. checkRemoveRevPtrsRequest(*name_remove);
  326. // Create a IPv6 reverse replace transaction.
  327. // Verify the request builds without error.
  328. // and then verify the request contents.
  329. ASSERT_NO_THROW(name_remove = makeTransaction6(REVERSE_CHG));
  330. ASSERT_NO_THROW(name_remove->buildRemoveRevPtrsRequest());
  331. checkRemoveRevPtrsRequest(*name_remove);
  332. }
  333. // Tests the readyHandler functionality.
  334. // It verifies behavior for the following scenarios:
  335. //
  336. // 1. Posted event is START_EVT and request includes only a forward change
  337. // 2. Posted event is START_EVT and request includes both a forward and a
  338. // reverse change
  339. // 3. Posted event is START_EVT and request includes only a reverse change
  340. // 4. Posted event is invalid
  341. //
  342. TEST_F(NameRemoveTransactionTest, readyHandler) {
  343. NameRemoveStubPtr name_remove;
  344. // Create a transaction which includes only a forward change.
  345. ASSERT_NO_THROW(name_remove =
  346. prepHandlerTest(NameChangeTransaction::READY_ST,
  347. StateModel::START_EVT, FORWARD_CHG));
  348. // Run readyHandler.
  349. EXPECT_NO_THROW(name_remove->readyHandler());
  350. // Verify that a request requiring only a forward change, transitions to
  351. // selecting a forward server.
  352. EXPECT_EQ(NameChangeTransaction::SELECTING_FWD_SERVER_ST,
  353. name_remove->getCurrState());
  354. EXPECT_EQ(NameChangeTransaction::SELECT_SERVER_EVT,
  355. name_remove->getNextEvent());
  356. // Create a transaction which includes both a forward and a reverse change.
  357. ASSERT_NO_THROW(name_remove =
  358. prepHandlerTest(NameChangeTransaction::READY_ST,
  359. StateModel::START_EVT, FWD_AND_REV_CHG));
  360. // Run readyHandler.
  361. EXPECT_NO_THROW(name_remove->readyHandler());
  362. // Verify that a request requiring both forward and reverse, starts with
  363. // the forward change by transitioning to selecting a forward server.
  364. EXPECT_EQ(NameChangeTransaction::SELECTING_FWD_SERVER_ST,
  365. name_remove->getCurrState());
  366. EXPECT_EQ(NameChangeTransaction::SELECT_SERVER_EVT,
  367. name_remove->getNextEvent());
  368. // Create and prep a reverse only transaction.
  369. ASSERT_NO_THROW(name_remove =
  370. prepHandlerTest(NameChangeTransaction::READY_ST,
  371. StateModel::START_EVT, REVERSE_CHG));
  372. // Run readyHandler.
  373. EXPECT_NO_THROW(name_remove->readyHandler());
  374. // Verify that a request requiring only a reverse change, transitions to
  375. // selecting a reverse server.
  376. EXPECT_EQ(NameChangeTransaction::SELECTING_REV_SERVER_ST,
  377. name_remove->getCurrState());
  378. EXPECT_EQ(NameChangeTransaction::SELECT_SERVER_EVT,
  379. name_remove->getNextEvent());
  380. // Create and prep transaction, poised to run the handler but with an
  381. // invalid event.
  382. ASSERT_NO_THROW(name_remove =
  383. prepHandlerTest(NameChangeTransaction::READY_ST,
  384. StateModel::NOP_EVT));
  385. // Running the readyHandler should throw.
  386. EXPECT_THROW(name_remove->readyHandler(), NameRemoveTransactionError);
  387. }
  388. // Tests the selectingFwdServerHandler functionality.
  389. // It verifies behavior for the following scenarios:
  390. //
  391. // 1. Posted event is SELECT_SERVER_EVT
  392. // 2. Posted event is SERVER_IO_ERROR_EVT
  393. // 3. Posted event is invalid
  394. //
  395. TEST_F(NameRemoveTransactionTest, selectingFwdServerHandler) {
  396. NameRemoveStubPtr name_remove;
  397. // Create and prep a transaction, poised to run the handler.
  398. ASSERT_NO_THROW(name_remove =
  399. prepHandlerTest(NameChangeTransaction::
  400. SELECTING_FWD_SERVER_ST,
  401. NameChangeTransaction::SELECT_SERVER_EVT));
  402. // Call selectingFwdServerHandler enough times to select all of the
  403. // servers in it's current domain. The first time, it will be with
  404. // next event of SELECT_SERVER_EVT. Thereafter it will be with a next
  405. // event of SERVER_IO_ERROR_EVT.
  406. int num_servers = name_remove->getForwardDomain()->getServers()->size();
  407. for (int i = 0; i < num_servers; ++i) {
  408. // Run selectingFwdServerHandler.
  409. ASSERT_NO_THROW(name_remove->selectingFwdServerHandler())
  410. << " num_servers: " << num_servers
  411. << " selections: " << i;
  412. // Verify that a server was selected.
  413. ASSERT_TRUE(name_remove->getCurrentServer())
  414. << " num_servers: " << num_servers << " selections: " << i;
  415. // Verify that we transitioned correctly.
  416. ASSERT_EQ(NameRemoveTransaction::REMOVING_FWD_ADDRS_ST,
  417. name_remove->getCurrState())
  418. << " num_servers: " << num_servers << " selections: " << i;
  419. ASSERT_EQ(NameChangeTransaction::SERVER_SELECTED_EVT,
  420. name_remove->getNextEvent())
  421. << " num_servers: " << num_servers << " selections: " << i;
  422. // Post a server IO error event. This simulates an IO error occuring
  423. // and a need to select the new server.
  424. ASSERT_NO_THROW(name_remove->postNextEvent(NameChangeTransaction::
  425. SERVER_IO_ERROR_EVT))
  426. << " num_servers: " << num_servers
  427. << " selections: " << i;
  428. }
  429. // We should have exhausted the list of servers. Processing another
  430. // SERVER_IO_ERROR_EVT should transition us to failure.
  431. EXPECT_NO_THROW(name_remove->selectingFwdServerHandler());
  432. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  433. name_remove->getCurrState());
  434. EXPECT_EQ(NameChangeTransaction::NO_MORE_SERVERS_EVT,
  435. name_remove->getNextEvent());
  436. // Create and prep transaction, poised to run the handler but with an
  437. // invalid event.
  438. ASSERT_NO_THROW(name_remove =
  439. prepHandlerTest(NameChangeTransaction::
  440. SELECTING_FWD_SERVER_ST,
  441. StateModel::NOP_EVT));
  442. // Running the handler should throw.
  443. EXPECT_THROW(name_remove->selectingFwdServerHandler(),
  444. NameRemoveTransactionError);
  445. }
  446. // ************************ addingFwdAddrHandler Tests *****************
  447. // Tests that removingFwdAddrsHandler rejects invalid events.
  448. TEST_F(NameRemoveTransactionTest, removingFwdAddrsHandler_InvalidEvent) {
  449. NameRemoveStubPtr name_remove;
  450. // Create and prep a transaction, poised to run the handler but with
  451. // an invalid event.
  452. ASSERT_NO_THROW(name_remove =
  453. prepHandlerTest(NameRemoveTransaction::
  454. REMOVING_FWD_ADDRS_ST,
  455. StateModel::NOP_EVT));
  456. // Running the handler should throw.
  457. EXPECT_THROW(name_remove->removingFwdAddrsHandler(),
  458. NameRemoveTransactionError);
  459. }
  460. // Tests addingFwdAddrsHandler with the following scenario:
  461. //
  462. // The request includes only a forward change.
  463. // Initial posted event is SERVER_SELECTED_EVT.
  464. // The update request is sent without error.
  465. // A server response is received which indicates successful update
  466. //
  467. TEST_F(NameRemoveTransactionTest, removingFwdAddrsHandler_FwdOnlyOK) {
  468. NameRemoveStubPtr name_remove;
  469. // Create and prep a transaction, poised to run the handler.
  470. ASSERT_NO_THROW(name_remove =
  471. prepHandlerTest(NameRemoveTransaction::
  472. REMOVING_FWD_ADDRS_ST,
  473. NameChangeTransaction::
  474. SERVER_SELECTED_EVT, FORWARD_CHG));
  475. // Should not be an update message yet.
  476. D2UpdateMessagePtr update_msg = name_remove->getDnsUpdateRequest();
  477. ASSERT_FALSE(update_msg);
  478. // At this point completion flags should be false.
  479. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  480. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  481. // Run removingFwdAddrsHandler to construct and send the request.
  482. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  483. // Verify that an update message was constructed properly.
  484. checkRemoveFwdAddressRequest(*name_remove);
  485. // Verify that we are still in this state and next event is NOP_EVT.
  486. // This indicates we "sent" the message and are waiting for IO completion.
  487. EXPECT_EQ(NameRemoveTransaction::REMOVING_FWD_ADDRS_ST,
  488. name_remove->getCurrState());
  489. EXPECT_EQ(NameChangeTransaction::NOP_EVT,
  490. name_remove->getNextEvent());
  491. // Simulate receiving a successful update response.
  492. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::NOERROR());
  493. // Run removingFwdAddrsHandler again to process the response.
  494. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  495. // Completion flags should both still be false, as we are only partly
  496. // done with forward updates.
  497. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  498. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  499. // Since we succeeded, we should now attempt to remove any remaining
  500. // forward RRs.
  501. // Verify that we transitioned correctly.
  502. EXPECT_EQ(NameRemoveTransaction::REMOVING_FWD_RRS_ST,
  503. name_remove->getCurrState());
  504. EXPECT_EQ(NameRemoveTransaction::UPDATE_OK_EVT,
  505. name_remove->getNextEvent());
  506. }
  507. // Tests addingFwdAddrsHandler with the following scenario:
  508. //
  509. // The request includes only a forward change.
  510. // Initial posted event is SERVER_SELECTED_EVT.
  511. // The update request is sent without error.
  512. // A server response is received which indicates FQDN is not in use.
  513. //
  514. TEST_F(NameRemoveTransactionTest, removingFwdAddrsHandler_FqdnNotInUse) {
  515. NameRemoveStubPtr name_remove;
  516. // Create and prep a transaction, poised to run the handler.
  517. ASSERT_NO_THROW(name_remove =
  518. prepHandlerTest(NameRemoveTransaction::
  519. REMOVING_FWD_ADDRS_ST,
  520. NameChangeTransaction::
  521. SERVER_SELECTED_EVT, FORWARD_CHG));
  522. // Run removingFwdAddrsHandler to construct and send the request.
  523. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  524. // Simulate receiving a FQDN not in use response.
  525. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::NXDOMAIN());
  526. // Run removingFwdAddrsHandler again to process the response.
  527. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  528. // Completion flags should both still be false, as we are only partly
  529. // done with forward updates.
  530. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  531. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  532. // There was no address RR to remove, but we will still make sure there
  533. // are no other RRs for this FQDN.
  534. // Verify that we transitioned correctly.
  535. EXPECT_EQ(NameRemoveTransaction::REMOVING_FWD_RRS_ST,
  536. name_remove->getCurrState());
  537. EXPECT_EQ(NameRemoveTransaction::UPDATE_OK_EVT,
  538. name_remove->getNextEvent());
  539. }
  540. // Tests removingFwdAddrsHandler with the following scenario:
  541. //
  542. // The request includes a forward and reverse change.
  543. // Initial posted event is SERVER_SELECTED_EVT.
  544. // The update request is sent without error.
  545. // A server response is received which indicates the update was rejected.
  546. //
  547. TEST_F(NameRemoveTransactionTest, removingFwdAddrsHandler_OtherRcode) {
  548. NameRemoveStubPtr name_remove;
  549. // Create and prep a transaction, poised to run the handler.
  550. ASSERT_NO_THROW(name_remove =
  551. prepHandlerTest(NameRemoveTransaction::
  552. REMOVING_FWD_ADDRS_ST,
  553. NameChangeTransaction::
  554. SERVER_SELECTED_EVT));
  555. // Select a server to satisfy log statements.
  556. ASSERT_TRUE(name_remove->selectFwdServer());
  557. // Run removingFwdAddrsHandler to construct and send the request.
  558. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  559. // Simulate receiving server rejection response. Per RFC, anything other
  560. // than no error or FQDN not in use is failure. Arbitrarily choosing
  561. // refused.
  562. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::REFUSED());
  563. // Run removingFwdAddrsHandler again to process the response.
  564. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  565. // Completion flags should still be false.
  566. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  567. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  568. // We should have failed the transaction. Verify that we transitioned
  569. // correctly.
  570. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  571. name_remove->getCurrState());
  572. EXPECT_EQ(NameChangeTransaction::UPDATE_FAILED_EVT,
  573. name_remove->getNextEvent());
  574. }
  575. // Tests removingFwdAddrsHandler with the following scenario:
  576. //
  577. // The request includes a forward and reverse change.
  578. // Initial posted event is SERVER_SELECTED_EVT.
  579. // The update request send times out MAX_UPDATE_TRIES_PER_SERVER times.
  580. //
  581. TEST_F(NameRemoveTransactionTest, removingFwdAddrsHandler_Timeout) {
  582. NameRemoveStubPtr name_remove;
  583. // Create and prep a transaction, poised to run the handler.
  584. // The log message issued when this test succeeds, displays the
  585. // selected server, so we need to select a server before running this
  586. // test.
  587. ASSERT_NO_THROW(name_remove =
  588. prepHandlerTest(NameRemoveTransaction::
  589. REMOVING_FWD_ADDRS_ST,
  590. NameChangeTransaction::
  591. SERVER_SELECTED_EVT));
  592. // Select a server to satisfy log statements.
  593. ASSERT_TRUE(name_remove->selectFwdServer());
  594. // Verify that we can make maximum number of update attempts permitted
  595. // and then transition to selecting a new server.
  596. int max_tries = NameChangeTransaction::MAX_UPDATE_TRIES_PER_SERVER;
  597. for (int i = 1; i <= max_tries; ++i) {
  598. const D2UpdateMessagePtr prev_msg = name_remove->getDnsUpdateRequest();
  599. // Run removingFwdAddrsHandler to send the request.
  600. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  601. const D2UpdateMessagePtr curr_msg = name_remove->getDnsUpdateRequest();
  602. if (i == 1) {
  603. // First time around we should build the message.
  604. EXPECT_FALSE(prev_msg);
  605. EXPECT_TRUE(curr_msg);
  606. } else {
  607. // Subsequent passes should reuse the request. We are only
  608. // looking to check that we have not replaced the pointer value
  609. // with a new pointer. This tests the on_entry() logic which
  610. // clears the request ONLY upon initial entry into the state.
  611. EXPECT_TRUE(prev_msg == curr_msg);
  612. }
  613. // Simulate a server IO timeout.
  614. name_remove->setDnsUpdateStatus(DNSClient::TIMEOUT);
  615. name_remove->postNextEvent(NameChangeTransaction::IO_COMPLETED_EVT);
  616. // Run removingFwdAddrsHandler again to process the response.
  617. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  618. // Completion flags should be false.
  619. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  620. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  621. if (i < max_tries) {
  622. // We should be ready to try again.
  623. EXPECT_EQ(NameRemoveTransaction::REMOVING_FWD_ADDRS_ST,
  624. name_remove->getCurrState());
  625. EXPECT_EQ(NameChangeTransaction::SERVER_SELECTED_EVT,
  626. name_remove->getNextEvent());
  627. } else {
  628. // Server retries should be exhausted, time for a new server.
  629. EXPECT_EQ(NameRemoveTransaction::SELECTING_FWD_SERVER_ST,
  630. name_remove->getCurrState());
  631. EXPECT_EQ(NameChangeTransaction::SERVER_IO_ERROR_EVT,
  632. name_remove->getNextEvent());
  633. }
  634. }
  635. }
  636. // Tests removingFwdAddrsHandler with the following scenario:
  637. //
  638. // The request includes a forward and reverse change.
  639. // Initial posted event is SERVER_SELECTED_EVT.
  640. // The update request is sent but a corrupt response is received, this occurs
  641. // MAX_UPDATE_TRIES_PER_SERVER times.
  642. //
  643. TEST_F(NameRemoveTransactionTest, removingFwdAddrsHandler_InvalidResponse) {
  644. NameRemoveStubPtr name_remove;
  645. // Create and prep a transaction, poised to run the handler.
  646. // The log message issued when this test succeeds, displays the
  647. // selected server, so we need to select a server before running this
  648. // test.
  649. ASSERT_NO_THROW(name_remove =
  650. prepHandlerTest(NameRemoveTransaction::
  651. REMOVING_FWD_ADDRS_ST,
  652. NameChangeTransaction::
  653. SERVER_SELECTED_EVT));
  654. // Select a server to satisfy log statements.
  655. ASSERT_TRUE(name_remove->selectFwdServer());
  656. // Verify that we can make maximum number of update attempts permitted
  657. // and then transition to selecting a new server.
  658. int max_tries = NameChangeTransaction::MAX_UPDATE_TRIES_PER_SERVER;
  659. for (int i = 1; i <= max_tries; ++i) {
  660. // Run removingFwdAddrsHandler to construct send the request.
  661. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  662. // Simulate a corrupt server response.
  663. name_remove->setDnsUpdateStatus(DNSClient::INVALID_RESPONSE);
  664. name_remove->postNextEvent(NameChangeTransaction::IO_COMPLETED_EVT);
  665. // Run removingFwdAddrsHandler again to process the response.
  666. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  667. // Completion flags should be false.
  668. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  669. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  670. if (i < max_tries) {
  671. // We should be ready to try again.
  672. EXPECT_EQ(NameRemoveTransaction::REMOVING_FWD_ADDRS_ST,
  673. name_remove->getCurrState());
  674. EXPECT_EQ(NameChangeTransaction::SERVER_SELECTED_EVT,
  675. name_remove->getNextEvent());
  676. } else {
  677. // Server retries should be exhausted, time for a new server.
  678. EXPECT_EQ(NameRemoveTransaction::SELECTING_FWD_SERVER_ST,
  679. name_remove->getCurrState());
  680. EXPECT_EQ(NameChangeTransaction::SERVER_IO_ERROR_EVT,
  681. name_remove->getNextEvent());
  682. }
  683. }
  684. }
  685. // ************************ removingFwdRRsHandler Tests *****************
  686. // Tests that removingFwdRRsHandler rejects invalid events.
  687. TEST_F(NameRemoveTransactionTest, removingFwdRRsHandler_InvalidEvent) {
  688. NameRemoveStubPtr name_remove;
  689. // Create and prep a transaction, poised to run the handler but with
  690. // an invalid event.
  691. ASSERT_NO_THROW(name_remove =
  692. prepHandlerTest(NameRemoveTransaction::
  693. REMOVING_FWD_RRS_ST,
  694. StateModel::NOP_EVT));
  695. // Running the handler should throw.
  696. EXPECT_THROW(name_remove->removingFwdRRsHandler(),
  697. NameRemoveTransactionError);
  698. }
  699. // Tests removingFwdRRsHandler with the following scenario:
  700. //
  701. // The request includes only a forward change.
  702. // Initial posted event is UPDATE_OK_EVT.
  703. // The update request is sent without error.
  704. // A server response is received which indicates successful update.
  705. //
  706. TEST_F(NameRemoveTransactionTest, removingFwdRRsHandler_FwdOnlyOK) {
  707. NameRemoveStubPtr name_remove;
  708. // Create and prep a transaction, poised to run the handler.
  709. ASSERT_NO_THROW(name_remove =
  710. prepHandlerTest(NameRemoveTransaction::
  711. REMOVING_FWD_ADDRS_ST,
  712. NameChangeTransaction::
  713. UPDATE_OK_EVT, FORWARD_CHG));
  714. // Should not be an update message yet.
  715. D2UpdateMessagePtr update_msg = name_remove->getDnsUpdateRequest();
  716. ASSERT_FALSE(update_msg);
  717. // At this point completion flags should be false.
  718. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  719. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  720. // Run removingFwdRRsHandler to construct and send the request.
  721. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  722. // Verify that an update message was constructed properly.
  723. checkRemoveFwdRRsRequest(*name_remove);
  724. // Verify that we are still in this state and next event is NOP_EVT.
  725. // This indicates we "sent" the message and are waiting for IO completion.
  726. EXPECT_EQ(NameRemoveTransaction::REMOVING_FWD_ADDRS_ST,
  727. name_remove->getCurrState());
  728. EXPECT_EQ(NameChangeTransaction::NOP_EVT,
  729. name_remove->getNextEvent());
  730. // Simulate receiving a successful update response.
  731. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::NOERROR());
  732. // Run removingFwdRRsHandler again to process the response.
  733. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  734. // Forward completion should be true, reverse should be false.
  735. EXPECT_TRUE(name_remove->getForwardChangeCompleted());
  736. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  737. // Since it is a forward only change, we should be done.
  738. // Verify that we transitioned correctly.
  739. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_OK_ST,
  740. name_remove->getCurrState());
  741. EXPECT_EQ(NameChangeTransaction::UPDATE_OK_EVT,
  742. name_remove->getNextEvent());
  743. }
  744. // Tests removingFwdRRsHandler with the following scenario:
  745. //
  746. // The request includes only a forward change.
  747. // Initial posted event is SERVER_SELECTED_EVT.
  748. // The update request is sent without error.
  749. // A server response is received which indicates successful update.
  750. //
  751. TEST_F(NameRemoveTransactionTest, removingFwdRRsHandler_FwdOnlyOK2) {
  752. NameRemoveStubPtr name_remove;
  753. // Create and prep a transaction, poised to run the handler.
  754. ASSERT_NO_THROW(name_remove =
  755. prepHandlerTest(NameRemoveTransaction::
  756. REMOVING_FWD_ADDRS_ST,
  757. NameChangeTransaction::
  758. SERVER_SELECTED_EVT, FORWARD_CHG));
  759. // Run removingFwdRRsHandler to construct and send the request.
  760. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  761. // Simulate receiving a successful update response.
  762. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::NOERROR());
  763. // Run removingFwdRRsHandler again to process the response.
  764. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  765. // Forward completion should be true, reverse should be false.
  766. EXPECT_TRUE(name_remove->getForwardChangeCompleted());
  767. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  768. // Since it is a forward only change, we should be done.
  769. // Verify that we transitioned correctly.
  770. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_OK_ST,
  771. name_remove->getCurrState());
  772. EXPECT_EQ(NameChangeTransaction::UPDATE_OK_EVT,
  773. name_remove->getNextEvent());
  774. }
  775. // Tests removingFwdRRsHandler with the following scenario:
  776. //
  777. // The request includes a forward and reverse change.
  778. // Initial posted event is UPDATE_OK_EVT.
  779. // The update request is sent without error.
  780. // A server response is received which indicates successful update.
  781. //
  782. TEST_F(NameRemoveTransactionTest, removingFwdRRsHandler_FwdAndRevOK) {
  783. NameRemoveStubPtr name_remove;
  784. // Create and prep a transaction, poised to run the handler.
  785. ASSERT_NO_THROW(name_remove =
  786. prepHandlerTest(NameRemoveTransaction::
  787. REMOVING_FWD_ADDRS_ST,
  788. NameChangeTransaction::
  789. UPDATE_OK_EVT, FWD_AND_REV_CHG));
  790. // Run removingFwdRRsHandler to construct and send the request.
  791. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  792. // Simulate receiving a successful update response.
  793. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::NOERROR());
  794. // Run removingFwdRRsHandler again to process the response.
  795. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  796. // Forward change completion should be true, reverse flag should be false.
  797. EXPECT_TRUE(name_remove->getForwardChangeCompleted());
  798. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  799. // Since the request also includes a reverse change we should
  800. // be poised to start it. Verify that we transitioned correctly.
  801. EXPECT_EQ(NameChangeTransaction::SELECTING_REV_SERVER_ST,
  802. name_remove->getCurrState());
  803. EXPECT_EQ(NameChangeTransaction::SELECT_SERVER_EVT,
  804. name_remove->getNextEvent());
  805. }
  806. // Tests removingFwdAddrsHandler with the following scenario:
  807. //
  808. // The request includes a forward and reverse change.
  809. // Initial posted event is UPDATE_OK_EVT.
  810. // The update request is sent without error.
  811. // A server response is received which indicates the FQDN is NOT in use.
  812. //
  813. TEST_F(NameRemoveTransactionTest, removingFwdRRsHandler_FqdnNotInUse) {
  814. NameRemoveStubPtr name_remove;
  815. // Create and prep a transaction, poised to run the handler.
  816. ASSERT_NO_THROW(name_remove =
  817. prepHandlerTest(NameRemoveTransaction::
  818. REMOVING_FWD_ADDRS_ST,
  819. NameChangeTransaction::
  820. UPDATE_OK_EVT, FORWARD_CHG));
  821. // Run removingFwdRRsHandler to construct and send the request.
  822. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  823. // Simulate receiving a FQDN not in use response.
  824. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::NXDOMAIN());
  825. // Run removingFwdRRsHandler again to process the response.
  826. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  827. // Forwad completion flag should be true, reverse should still be false.
  828. EXPECT_TRUE(name_remove->getForwardChangeCompleted());
  829. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  830. // The FQDN is no longer in use, RFC is unclear about this,
  831. // but we will treat this as success.
  832. // Since it is a forward only change, we should be done.
  833. // Verify that we transitioned correctly.
  834. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_OK_ST,
  835. name_remove->getCurrState());
  836. EXPECT_EQ(NameChangeTransaction::UPDATE_OK_EVT,
  837. name_remove->getNextEvent());
  838. }
  839. // Tests removingFwdRRsHandler with the following scenario:
  840. //
  841. // The request includes a forward and reverse change.
  842. // The update request is sent without error.
  843. // A server response is received which indicates the update was rejected.
  844. //
  845. TEST_F(NameRemoveTransactionTest, removingFwdRRsHandler_OtherRcode) {
  846. NameRemoveStubPtr name_remove;
  847. // Create the transaction.
  848. ASSERT_NO_THROW(name_remove =
  849. prepHandlerTest(NameRemoveTransaction::
  850. REMOVING_FWD_ADDRS_ST,
  851. NameChangeTransaction::
  852. UPDATE_OK_EVT, FWD_AND_REV_CHG));
  853. // Select a server to satisfy log statements.
  854. ASSERT_TRUE(name_remove->selectFwdServer());
  855. // Run removingFwdRRsHandler to construct and send the request.
  856. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  857. // Simulate receiving server rejection response. Per RFC, anything other
  858. // than no error is failure (we are also treating FQDN not in use is
  859. // success). Arbitrarily choosing refused.
  860. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::REFUSED());
  861. // Run removingFwdRRsHandler again to process the response.
  862. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  863. // Completion flags should still be false.
  864. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  865. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  866. // We should have failed the transaction. Verifiy that we transitioned
  867. // correctly.
  868. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  869. name_remove->getCurrState());
  870. EXPECT_EQ(NameChangeTransaction::UPDATE_FAILED_EVT,
  871. name_remove->getNextEvent());
  872. }
  873. // Tests removingFwdRRsHandler with the following scenario:
  874. //
  875. // The request includes a forward and reverse change.
  876. // Initial posted event is UPDATE_OK_EVT.
  877. // The update request send times out MAX_UPDATE_TRIES_PER_SERVER times.
  878. //
  879. TEST_F(NameRemoveTransactionTest, removingFwdRRsHandler_Timeout) {
  880. NameRemoveStubPtr name_remove;
  881. // Create the transaction.
  882. ASSERT_NO_THROW(name_remove =
  883. prepHandlerTest(NameRemoveTransaction::
  884. REMOVING_FWD_RRS_ST,
  885. NameChangeTransaction::
  886. UPDATE_OK_EVT, FWD_AND_REV_CHG));
  887. // Select a server to satisfy log statements.
  888. ASSERT_TRUE(name_remove->selectFwdServer());
  889. // Verify that we can make maximum number of update attempts permitted
  890. // and then transition to selecting a new server.
  891. int max_tries = NameChangeTransaction::MAX_UPDATE_TRIES_PER_SERVER;
  892. for (int i = 1; i <= max_tries; ++i) {
  893. const D2UpdateMessagePtr prev_msg = name_remove->getDnsUpdateRequest();
  894. // Run removingFwdRRsHandler to send the request.
  895. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  896. const D2UpdateMessagePtr curr_msg = name_remove->getDnsUpdateRequest();
  897. if (i == 1) {
  898. // First time around we should build the message.
  899. EXPECT_FALSE(prev_msg);
  900. EXPECT_TRUE(curr_msg);
  901. } else {
  902. // Subsequent passes should reuse the request. We are only
  903. // looking to check that we have not replaced the pointer value
  904. // with a new pointer. This tests the on_entry() logic which
  905. // clears the request ONLY upon initial entry into the state.
  906. EXPECT_TRUE(prev_msg == curr_msg);
  907. }
  908. // Simulate a server IO timeout.
  909. name_remove->setDnsUpdateStatus(DNSClient::TIMEOUT);
  910. name_remove->postNextEvent(NameChangeTransaction::IO_COMPLETED_EVT);
  911. // Run removingFwdRRsHandler again to process the response.
  912. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  913. // Completion flags should be false.
  914. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  915. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  916. if (i < max_tries) {
  917. // We should be ready to try again.
  918. EXPECT_EQ(NameRemoveTransaction::REMOVING_FWD_RRS_ST,
  919. name_remove->getCurrState());
  920. EXPECT_EQ(NameChangeTransaction::SERVER_SELECTED_EVT,
  921. name_remove->getNextEvent());
  922. } else {
  923. // Server retries should be exhausted.
  924. // We should abandon the transaction.
  925. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  926. name_remove->getCurrState());
  927. EXPECT_EQ(NameChangeTransaction::SERVER_IO_ERROR_EVT,
  928. name_remove->getNextEvent());
  929. }
  930. }
  931. }
  932. // Tests removingFwdRRsHandler with the following scenario:
  933. //
  934. // The request includes a forward and reverse change.
  935. // Initial posted event is UPDATE_OK_EVT.
  936. // The update request is sent but a corrupt response is received, this occurs
  937. // MAX_UPDATE_TRIES_PER_SERVER times.
  938. //
  939. TEST_F(NameRemoveTransactionTest, removingFwdRRsHandler_InvalidResponse) {
  940. NameRemoveStubPtr name_remove;
  941. // Create the transaction.
  942. ASSERT_NO_THROW(name_remove =
  943. prepHandlerTest(NameRemoveTransaction::
  944. REMOVING_FWD_RRS_ST,
  945. NameChangeTransaction::
  946. UPDATE_OK_EVT, FWD_AND_REV_CHG));
  947. // Select a server to satisfy log statements.
  948. ASSERT_TRUE(name_remove->selectFwdServer());
  949. // Verify that we can make maximum number of update attempts permitted
  950. // and then transition to selecting a new server.
  951. int max_tries = NameChangeTransaction::MAX_UPDATE_TRIES_PER_SERVER;
  952. for (int i = 1; i <= max_tries; ++i) {
  953. const D2UpdateMessagePtr prev_msg = name_remove->getDnsUpdateRequest();
  954. // Run removingFwdRRsHandler to send the request.
  955. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  956. const D2UpdateMessagePtr curr_msg = name_remove->getDnsUpdateRequest();
  957. if (i == 1) {
  958. // First time around we should build the message.
  959. EXPECT_FALSE(prev_msg);
  960. EXPECT_TRUE(curr_msg);
  961. } else {
  962. // Subsequent passes should reuse the request. We are only
  963. // looking to check that we have not replaced the pointer value
  964. // with a new pointer. This tests the on_entry() logic which
  965. // clears the request ONLY upon initial entry into the state.
  966. EXPECT_TRUE(prev_msg == curr_msg);
  967. }
  968. // Simulate a corrupt server response.
  969. name_remove->setDnsUpdateStatus(DNSClient::INVALID_RESPONSE);
  970. name_remove->postNextEvent(NameChangeTransaction::IO_COMPLETED_EVT);
  971. // Run removingFwdRRsHandler again to process the response.
  972. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  973. // Completion flags should be false.
  974. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  975. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  976. if (i < max_tries) {
  977. // We should be ready to try again.
  978. EXPECT_EQ(NameRemoveTransaction::REMOVING_FWD_RRS_ST,
  979. name_remove->getCurrState());
  980. EXPECT_EQ(NameChangeTransaction::SERVER_SELECTED_EVT,
  981. name_remove->getNextEvent());
  982. } else {
  983. // Server retries should be exhausted.
  984. // We should abandon the transaction.
  985. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  986. name_remove->getCurrState());
  987. EXPECT_EQ(NameChangeTransaction::SERVER_IO_ERROR_EVT,
  988. name_remove->getNextEvent());
  989. }
  990. }
  991. }
  992. // Tests the selectingRevServerHandler functionality.
  993. // It verifies behavior for the following scenarios:
  994. //
  995. // 1. Posted event is SELECT_SERVER_EVT
  996. // 2. Posted event is SERVER_IO_ERROR_EVT
  997. // 3. Posted event is invalid
  998. //
  999. TEST_F(NameRemoveTransactionTest, selectingRevServerHandler) {
  1000. NameRemoveStubPtr name_remove;
  1001. // Create and prep a transaction, poised to run the handler.
  1002. ASSERT_NO_THROW(name_remove =
  1003. prepHandlerTest(NameChangeTransaction::
  1004. SELECTING_REV_SERVER_ST,
  1005. NameChangeTransaction::SELECT_SERVER_EVT));
  1006. // Call selectingRevServerHandler enough times to select all of the
  1007. // servers in it's current domain. The first time, it will be with
  1008. // next event of SELECT_SERVER_EVT. Thereafter it will be with a next
  1009. // event of SERVER_IO_ERROR_EVT.
  1010. int num_servers = name_remove->getReverseDomain()->getServers()->size();
  1011. for (int i = 0; i < num_servers; ++i) {
  1012. // Run selectingRevServerHandler.
  1013. ASSERT_NO_THROW(name_remove->selectingRevServerHandler())
  1014. << " num_servers: " << num_servers
  1015. << " selections: " << i;
  1016. // Verify that a server was selected.
  1017. ASSERT_TRUE(name_remove->getCurrentServer())
  1018. << " num_servers: " << num_servers
  1019. << " selections: " << i;
  1020. // Verify that we transitioned correctly.
  1021. ASSERT_EQ(NameRemoveTransaction::REMOVING_REV_PTRS_ST,
  1022. name_remove->getCurrState())
  1023. << " num_servers: " << num_servers << " selections: " << i;
  1024. ASSERT_EQ(NameChangeTransaction::SERVER_SELECTED_EVT,
  1025. name_remove->getNextEvent())
  1026. << " num_servers: " << num_servers << " selections: " << i;
  1027. // Post a server IO error event. This simulates an IO error occuring
  1028. // and a need to select the new server.
  1029. ASSERT_NO_THROW(name_remove->postNextEvent(NameChangeTransaction::
  1030. SERVER_IO_ERROR_EVT))
  1031. << " num_servers: " << num_servers
  1032. << " selections: " << i;
  1033. }
  1034. // We should have exhausted the list of servers. Processing another
  1035. // SERVER_IO_ERROR_EVT should transition us to failure.
  1036. EXPECT_NO_THROW(name_remove->selectingRevServerHandler());
  1037. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  1038. name_remove->getCurrState());
  1039. EXPECT_EQ(NameChangeTransaction::NO_MORE_SERVERS_EVT,
  1040. name_remove->getNextEvent());
  1041. // Create and prep transaction, poised to run the handler but with an
  1042. // invalid event.
  1043. ASSERT_NO_THROW(name_remove =
  1044. prepHandlerTest(NameChangeTransaction::
  1045. SELECTING_REV_SERVER_ST,
  1046. StateModel::NOP_EVT));
  1047. // Running the handler should throw.
  1048. EXPECT_THROW(name_remove->selectingRevServerHandler(),
  1049. NameRemoveTransactionError);
  1050. }
  1051. //************************** removingRevPtrsHandler tests *****************
  1052. // Tests that removingRevPtrsHandler rejects invalid events.
  1053. TEST_F(NameRemoveTransactionTest, removingRevPtrsHandler_InvalidEvent) {
  1054. NameRemoveStubPtr name_remove;
  1055. // Create and prep a transaction, poised to run the handler but with
  1056. // an invalid event.
  1057. ASSERT_NO_THROW(name_remove =
  1058. prepHandlerTest(NameRemoveTransaction::
  1059. REMOVING_REV_PTRS_ST,
  1060. StateModel::NOP_EVT));
  1061. // Running the handler should throw.
  1062. EXPECT_THROW(name_remove->removingRevPtrsHandler(),
  1063. NameRemoveTransactionError);
  1064. }
  1065. // Tests removingRevPtrsHandler with the following scenario:
  1066. //
  1067. // The request includes only a reverse change.
  1068. // Initial posted event is SERVER_SELECTED_EVT.
  1069. // The update request is sent without error.
  1070. // A server response is received which indicates successful update.
  1071. //
  1072. TEST_F(NameRemoveTransactionTest, removingRevPtrsHandler_RevOnlyOK) {
  1073. NameRemoveStubPtr name_remove;
  1074. // Create and prep a transaction, poised to run the handler.
  1075. ASSERT_NO_THROW(name_remove =
  1076. prepHandlerTest(NameRemoveTransaction::
  1077. REMOVING_REV_PTRS_ST,
  1078. NameChangeTransaction::
  1079. SERVER_SELECTED_EVT, REVERSE_CHG));
  1080. // Should not be an update message yet.
  1081. D2UpdateMessagePtr update_msg = name_remove->getDnsUpdateRequest();
  1082. ASSERT_FALSE(update_msg);
  1083. // At this point completion flags should be false.
  1084. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1085. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1086. // Run removingRevPtrsHandler to construct and send the request.
  1087. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1088. // Verify that an update message was constructed properly.
  1089. checkRemoveRevPtrsRequest(*name_remove);
  1090. // Verify that we are still in this state and next event is NOP_EVT.
  1091. // This indicates we "sent" the message and are waiting for IO completion.
  1092. EXPECT_EQ(NameRemoveTransaction::REMOVING_REV_PTRS_ST,
  1093. name_remove->getCurrState());
  1094. EXPECT_EQ(StateModel::NOP_EVT,
  1095. name_remove->getNextEvent());
  1096. // Simulate receiving a successful update response.
  1097. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::NOERROR());
  1098. // Run removingRevPtrsHandler again to process the response.
  1099. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1100. // Forward completion should be false, reverse should be true.
  1101. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1102. EXPECT_TRUE(name_remove->getReverseChangeCompleted());
  1103. // Since it is a reverse change, we should be done.
  1104. // Verify that we transitioned correctly.
  1105. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_OK_ST,
  1106. name_remove->getCurrState());
  1107. EXPECT_EQ(NameChangeTransaction::UPDATE_OK_EVT,
  1108. name_remove->getNextEvent());
  1109. }
  1110. // Tests removingRevPtrsHandler with the following scenario:
  1111. //
  1112. // The request includes only a reverse change.
  1113. // Initial posted event is SERVER_SELECTED_EVT.
  1114. // The update request is sent without error.
  1115. // A server response is received which indicates FQDN is NOT in use.
  1116. //
  1117. TEST_F(NameRemoveTransactionTest, removingRevPtrsHandler_FqdnNotInUse) {
  1118. NameRemoveStubPtr name_remove;
  1119. // Create and prep a transaction, poised to run the handler.
  1120. ASSERT_NO_THROW(name_remove =
  1121. prepHandlerTest(NameRemoveTransaction::
  1122. REMOVING_REV_PTRS_ST,
  1123. NameChangeTransaction::
  1124. SERVER_SELECTED_EVT, REVERSE_CHG));
  1125. // Should not be an update message yet.
  1126. D2UpdateMessagePtr update_msg = name_remove->getDnsUpdateRequest();
  1127. ASSERT_FALSE(update_msg);
  1128. // At this point completion flags should be false.
  1129. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1130. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1131. // Run removingRevPtrsHandler to construct and send the request.
  1132. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1133. // Verify that an update message was constructed properly.
  1134. checkRemoveRevPtrsRequest(*name_remove);
  1135. // Verify that we are still in this state and next event is NOP_EVT.
  1136. // This indicates we "sent" the message and are waiting for IO completion.
  1137. EXPECT_EQ(NameRemoveTransaction::REMOVING_REV_PTRS_ST,
  1138. name_remove->getCurrState());
  1139. EXPECT_EQ(StateModel::NOP_EVT,
  1140. name_remove->getNextEvent());
  1141. // Simulate receiving a FQDN not in use response.
  1142. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::NXDOMAIN());
  1143. // Run removingRevPtrsHandler again to process the response.
  1144. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1145. // Forward completion should be false, reverse should be true.
  1146. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1147. EXPECT_TRUE(name_remove->getReverseChangeCompleted());
  1148. // Since it is a reverse change, we should be done.
  1149. // Verify that we transitioned correctly.
  1150. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_OK_ST,
  1151. name_remove->getCurrState());
  1152. EXPECT_EQ(NameChangeTransaction::UPDATE_OK_EVT,
  1153. name_remove->getNextEvent());
  1154. }
  1155. // Tests removingRevPtrsHandler with the following scenario:
  1156. //
  1157. // The request includes only a reverse change.
  1158. // Initial posted event is SERVER_SELECTED_EVT.
  1159. // The update request is sent without error.
  1160. // A server response is received which indicates the update was rejected.
  1161. //
  1162. TEST_F(NameRemoveTransactionTest, removingRevPtrsHandler_OtherRcode) {
  1163. NameRemoveStubPtr name_remove;
  1164. // Create the transaction.
  1165. ASSERT_NO_THROW(name_remove =
  1166. prepHandlerTest(NameRemoveTransaction::
  1167. REMOVING_REV_PTRS_ST,
  1168. NameChangeTransaction::
  1169. SERVER_SELECTED_EVT, REVERSE_CHG));
  1170. // Select a server to satisfy log statements.
  1171. ASSERT_TRUE(name_remove->selectRevServer());
  1172. // Run removingRevPtrsHandler to construct and send the request.
  1173. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1174. // Simulate receiving server rejection response. Per RFC, anything other
  1175. // than no error is failure. Arbitrarily choosing refused.
  1176. name_remove->fakeResponse(DNSClient::SUCCESS, dns::Rcode::REFUSED());
  1177. // Run removingRevPtrsHandler again to process the response.
  1178. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1179. // Completion flags should still be false.
  1180. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1181. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1182. // We should have failed the transaction. Verify that we transitioned
  1183. // correctly.
  1184. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  1185. name_remove->getCurrState());
  1186. EXPECT_EQ(NameChangeTransaction::UPDATE_FAILED_EVT,
  1187. name_remove->getNextEvent());
  1188. }
  1189. // Tests removingRevPtrsHandler with the following scenario:
  1190. //
  1191. // The request includes only a reverse change.
  1192. // Initial posted event is SERVER_SELECTED_EVT.
  1193. // The update request send times out MAX_UPDATE_TRIES_PER_SERVER times.
  1194. //
  1195. TEST_F(NameRemoveTransactionTest, removingRevPtrsHandler_Timeout) {
  1196. NameRemoveStubPtr name_remove;
  1197. // Create the transaction.
  1198. ASSERT_NO_THROW(name_remove =
  1199. prepHandlerTest(NameRemoveTransaction::
  1200. REMOVING_REV_PTRS_ST,
  1201. NameChangeTransaction::
  1202. SERVER_SELECTED_EVT, REVERSE_CHG));
  1203. // Select a server to satisfy log statements.
  1204. ASSERT_TRUE(name_remove->selectRevServer());
  1205. // Verify that we can make maximum number of update attempts permitted
  1206. // and then transition to selecting a new server.
  1207. int max_tries = NameChangeTransaction::MAX_UPDATE_TRIES_PER_SERVER;
  1208. for (int i = 1; i <= max_tries; ++i) {
  1209. const D2UpdateMessagePtr prev_msg = name_remove->getDnsUpdateRequest();
  1210. // Run removingRevPtrsHandler to send the request.
  1211. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1212. const D2UpdateMessagePtr curr_msg = name_remove->getDnsUpdateRequest();
  1213. if (i == 1) {
  1214. // First time around we should build the message.
  1215. EXPECT_FALSE(prev_msg);
  1216. EXPECT_TRUE(curr_msg);
  1217. } else {
  1218. // Subsequent passes should reuse the request. We are only
  1219. // looking to check that we have not replaced the pointer value
  1220. // with a new pointer. This tests the on_entry() logic which
  1221. // clears the request ONLY upon initial entry into the state.
  1222. EXPECT_TRUE(prev_msg == curr_msg);
  1223. }
  1224. // Simulate a server IO timeout.
  1225. name_remove->setDnsUpdateStatus(DNSClient::TIMEOUT);
  1226. name_remove->postNextEvent(NameChangeTransaction::IO_COMPLETED_EVT);
  1227. // Run removingRevPtrsHandler again to process the response.
  1228. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1229. // Completion flags should be false.
  1230. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1231. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1232. if (i < max_tries) {
  1233. // We should be ready to try again.
  1234. EXPECT_EQ(NameRemoveTransaction::REMOVING_REV_PTRS_ST,
  1235. name_remove->getCurrState());
  1236. EXPECT_EQ(NameChangeTransaction::SERVER_SELECTED_EVT,
  1237. name_remove->getNextEvent());
  1238. } else {
  1239. // Server retries should be exhausted, time for a new server.
  1240. EXPECT_EQ(NameChangeTransaction::SELECTING_REV_SERVER_ST,
  1241. name_remove->getCurrState());
  1242. EXPECT_EQ(NameChangeTransaction::SERVER_IO_ERROR_EVT,
  1243. name_remove->getNextEvent());
  1244. }
  1245. }
  1246. }
  1247. // Tests removingRevPtrsHandler with the following scenario:
  1248. //
  1249. // The request includes only a reverse change.
  1250. // Initial posted event is SERVER_SELECTED_EVT.
  1251. // The update request is sent but a corrupt response is received, this occurs
  1252. // MAX_UPDATE_TRIES_PER_SERVER times.
  1253. //
  1254. TEST_F(NameRemoveTransactionTest, removingRevPtrsHandler_CorruptResponse) {
  1255. NameRemoveStubPtr name_remove;
  1256. // Create the transaction.
  1257. ASSERT_NO_THROW(name_remove =
  1258. prepHandlerTest(NameRemoveTransaction::
  1259. REMOVING_REV_PTRS_ST,
  1260. NameChangeTransaction::
  1261. SERVER_SELECTED_EVT, REVERSE_CHG));
  1262. // Select a server to satisfy log statements.
  1263. ASSERT_TRUE(name_remove->selectRevServer());
  1264. // Verify that we can make maximum number of update attempts permitted
  1265. // and then transition to selecting a new server.
  1266. int max_tries = NameChangeTransaction::MAX_UPDATE_TRIES_PER_SERVER;
  1267. for (int i = 1; i <= max_tries; ++i) {
  1268. const D2UpdateMessagePtr prev_msg = name_remove->getDnsUpdateRequest();
  1269. // Run removingRevPtrsHandler to send the request.
  1270. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1271. const D2UpdateMessagePtr curr_msg = name_remove->getDnsUpdateRequest();
  1272. if (i == 1) {
  1273. // First time around we should build the message.
  1274. EXPECT_FALSE(prev_msg);
  1275. EXPECT_TRUE(curr_msg);
  1276. } else {
  1277. // Subsequent passes should reuse the request. We are only
  1278. // looking to check that we have not replaced the pointer value
  1279. // with a new pointer. This tests the on_entry() logic which
  1280. // clears the request ONLY upon initial entry into the state.
  1281. EXPECT_TRUE(prev_msg == curr_msg);
  1282. }
  1283. // Simulate a server corrupt response.
  1284. name_remove->setDnsUpdateStatus(DNSClient::INVALID_RESPONSE);
  1285. name_remove->postNextEvent(NameChangeTransaction::IO_COMPLETED_EVT);
  1286. // Run removingRevPtrsHandler again to process the response.
  1287. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1288. // Completion flags should be false.
  1289. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1290. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1291. if (i < max_tries) {
  1292. // We should be ready to try again.
  1293. EXPECT_EQ(NameRemoveTransaction::REMOVING_REV_PTRS_ST,
  1294. name_remove->getCurrState());
  1295. EXPECT_EQ(NameChangeTransaction::SERVER_SELECTED_EVT,
  1296. name_remove->getNextEvent());
  1297. } else {
  1298. // Server retries should be exhausted, time for a new server.
  1299. EXPECT_EQ(NameChangeTransaction::SELECTING_REV_SERVER_ST,
  1300. name_remove->getCurrState());
  1301. EXPECT_EQ(NameChangeTransaction::SERVER_IO_ERROR_EVT,
  1302. name_remove->getNextEvent());
  1303. }
  1304. }
  1305. }
  1306. // Tests the processRemoveOkHandler functionality.
  1307. // It verifies behavior for the following scenarios:
  1308. //
  1309. // 1. Posted event is UPDATE_OK_EVT
  1310. // 2. Posted event is invalid
  1311. //
  1312. TEST_F(NameRemoveTransactionTest, processRemoveOkHandler) {
  1313. NameRemoveStubPtr name_remove;
  1314. // Create and prep a transaction, poised to run the handler.
  1315. ASSERT_NO_THROW(name_remove =
  1316. prepHandlerTest(NameChangeTransaction::PROCESS_TRANS_OK_ST,
  1317. NameChangeTransaction::UPDATE_OK_EVT));
  1318. // Run processRemoveOkHandler.
  1319. EXPECT_NO_THROW(name_remove->processRemoveOkHandler());
  1320. // Verify that a server was selected.
  1321. EXPECT_EQ(dhcp_ddns::ST_COMPLETED, name_remove->getNcrStatus());
  1322. // Verify that the model has ended.
  1323. EXPECT_EQ(StateModel::END_ST, name_remove->getCurrState());
  1324. EXPECT_EQ(StateModel::END_EVT, name_remove->getNextEvent());
  1325. // Create and prep transaction, poised to run the handler but with an
  1326. // invalid event.
  1327. ASSERT_NO_THROW(name_remove =
  1328. prepHandlerTest(NameChangeTransaction::PROCESS_TRANS_OK_ST,
  1329. StateModel::NOP_EVT));
  1330. // Running the handler should throw.
  1331. EXPECT_THROW(name_remove->processRemoveOkHandler(),
  1332. NameRemoveTransactionError);
  1333. }
  1334. // Tests the processRemoveFailedHandler functionality.
  1335. // It verifies behavior for the following scenarios:
  1336. //
  1337. // 1. Posted event is UPDATE_FAILED_EVT
  1338. // 2. Posted event is invalid
  1339. //
  1340. TEST_F(NameRemoveTransactionTest, processRemoveFailedHandler) {
  1341. NameRemoveStubPtr name_remove;
  1342. // Create and prep a transaction, poised to run the handler.
  1343. ASSERT_NO_THROW(name_remove =
  1344. prepHandlerTest(NameChangeTransaction::
  1345. PROCESS_TRANS_FAILED_ST,
  1346. NameChangeTransaction::UPDATE_FAILED_EVT));
  1347. // Run processRemoveFailedHandler.
  1348. EXPECT_NO_THROW(name_remove->processRemoveFailedHandler());
  1349. // Verify that a server was selected.
  1350. EXPECT_EQ(dhcp_ddns::ST_FAILED, name_remove->getNcrStatus());
  1351. // Verify that the model has ended. (Remember, the transaction failed NOT
  1352. // the model. The model should have ended normally.)
  1353. EXPECT_EQ(StateModel::END_ST, name_remove->getCurrState());
  1354. EXPECT_EQ(StateModel::END_EVT, name_remove->getNextEvent());
  1355. // Create and prep transaction, poised to run the handler but with an
  1356. // invalid event.
  1357. ASSERT_NO_THROW(name_remove =
  1358. prepHandlerTest(NameChangeTransaction::
  1359. PROCESS_TRANS_FAILED_ST,
  1360. StateModel::NOP_EVT));
  1361. // Running the handler should throw.
  1362. EXPECT_THROW(name_remove->processRemoveFailedHandler(),
  1363. NameRemoveTransactionError);
  1364. }
  1365. // Tests the processRemoveFailedHandler functionality.
  1366. // It verifies behavior for posted event of NO_MORE_SERVERS_EVT.
  1367. TEST_F(NameRemoveTransactionTest, processRemoveFailedHandler_NoMoreServers) {
  1368. NameRemoveStubPtr name_remove;
  1369. // Create and prep a transaction, poised to run the handler.
  1370. ASSERT_NO_THROW(name_remove =
  1371. prepHandlerTest(NameChangeTransaction::
  1372. PROCESS_TRANS_FAILED_ST,
  1373. NameChangeTransaction::
  1374. NO_MORE_SERVERS_EVT));
  1375. // Run processRemoveFailedHandler.
  1376. EXPECT_NO_THROW(name_remove->processRemoveFailedHandler());
  1377. // Verify that a server was selected.
  1378. EXPECT_EQ(dhcp_ddns::ST_FAILED, name_remove->getNcrStatus());
  1379. // Verify that the model has ended. (Remember, the transaction failed NOT
  1380. // the model. The model should have ended normally.)
  1381. EXPECT_EQ(StateModel::END_ST, name_remove->getCurrState());
  1382. EXPECT_EQ(StateModel::END_EVT, name_remove->getNextEvent());
  1383. }
  1384. // Tests the processRemoveFailedHandler functionality.
  1385. // It verifies behavior for posted event of SERVER_IO_ERROR_EVT.
  1386. TEST_F(NameRemoveTransactionTest, processRemoveFailedHandler_ServerIOError) {
  1387. NameRemoveStubPtr name_remove;
  1388. // Create and prep a transaction, poised to run the handler.
  1389. ASSERT_NO_THROW(name_remove =
  1390. prepHandlerTest(NameChangeTransaction::
  1391. PROCESS_TRANS_FAILED_ST,
  1392. NameChangeTransaction::
  1393. SERVER_IO_ERROR_EVT));
  1394. // Run processRemoveFailedHandler.
  1395. EXPECT_NO_THROW(name_remove->processRemoveFailedHandler());
  1396. // Verify that a server was selected.
  1397. EXPECT_EQ(dhcp_ddns::ST_FAILED, name_remove->getNcrStatus());
  1398. // Verify that the model has ended. (Remember, the transaction failed NOT
  1399. // the model. The model should have ended normally.)
  1400. EXPECT_EQ(StateModel::END_ST, name_remove->getCurrState());
  1401. EXPECT_EQ(StateModel::END_EVT, name_remove->getNextEvent());
  1402. }
  1403. // Tests removingFwdAddrsHandler with the following scenario:
  1404. //
  1405. // The request includes only a forward change.
  1406. // Initial posted event is SERVER_SELECTED_EVT.
  1407. // The send update request fails due to an unexpected exception.
  1408. //
  1409. TEST_F(NameRemoveTransactionTest, removingFwdAddrsHandler_sendUpdateException) {
  1410. NameRemoveStubPtr name_remove;
  1411. // Create and prep a transaction, poised to run the handler.
  1412. ASSERT_NO_THROW(name_remove =
  1413. prepHandlerTest(NameRemoveTransaction::
  1414. REMOVING_FWD_ADDRS_ST,
  1415. NameChangeTransaction::
  1416. SERVER_SELECTED_EVT, FORWARD_CHG));
  1417. name_remove->simulate_send_exception_ = true;
  1418. // Run removingFwdAddrsHandler to construct and send the request.
  1419. EXPECT_NO_THROW(name_remove->removingFwdAddrsHandler());
  1420. // Completion flags should be false.
  1421. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1422. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1423. // Since IO exceptions should be gracefully handled, any that occur
  1424. // are unanticipated, and deemed unrecoverable, so the transaction should
  1425. // be transitioned to failure.
  1426. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  1427. name_remove->getCurrState());
  1428. EXPECT_EQ(NameChangeTransaction::UPDATE_FAILED_EVT,
  1429. name_remove->getNextEvent());
  1430. }
  1431. // Tests removingFwdRRsHandler with the following scenario:
  1432. //
  1433. // The request includes only a forward change.
  1434. // Initial posted event is SERVER_SELECTED_EVT.
  1435. // The send update request fails due to an unexpected exception.
  1436. //
  1437. TEST_F(NameRemoveTransactionTest, removingFwdRRsHandler_SendUpdateException) {
  1438. NameRemoveStubPtr name_remove;
  1439. // Create and prep a transaction, poised to run the handler.
  1440. ASSERT_NO_THROW(name_remove =
  1441. prepHandlerTest(NameRemoveTransaction::
  1442. REMOVING_FWD_RRS_ST,
  1443. NameChangeTransaction::
  1444. SERVER_SELECTED_EVT, FORWARD_CHG));
  1445. name_remove->simulate_send_exception_ = true;
  1446. // Run removingFwdRRsHandler to construct and send the request.
  1447. EXPECT_NO_THROW(name_remove->removingFwdRRsHandler());
  1448. // Completion flags should be false.
  1449. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1450. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1451. // Since IO exceptions should be gracefully handled, any that occur
  1452. // are unanticipated, and deemed unrecoverable, so the transaction should
  1453. // be transitioned to failure.
  1454. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  1455. name_remove->getCurrState());
  1456. EXPECT_EQ(NameChangeTransaction::UPDATE_FAILED_EVT,
  1457. name_remove->getNextEvent());
  1458. }
  1459. // Tests removingRevPtrHandler with the following scenario:
  1460. //
  1461. // The request includes only a reverse change.
  1462. // Initial posted event is SERVER_SELECTED_EVT.
  1463. // The send update request fails due to an unexpected exception.
  1464. //
  1465. TEST_F(NameRemoveTransactionTest, removingRevPtrsHandler_SendUpdateException) {
  1466. NameRemoveStubPtr name_remove;
  1467. // Create and prep a transaction, poised to run the handler.
  1468. ASSERT_NO_THROW(name_remove =
  1469. prepHandlerTest(NameRemoveTransaction::
  1470. REMOVING_REV_PTRS_ST,
  1471. NameChangeTransaction::
  1472. SERVER_SELECTED_EVT, REVERSE_CHG));
  1473. name_remove->simulate_send_exception_ = true;
  1474. // Run removingRevPtrsHandler to construct and send the request.
  1475. EXPECT_NO_THROW(name_remove->removingRevPtrsHandler());
  1476. // Completion flags should be false.
  1477. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1478. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1479. // Since IO exceptions should be gracefully handled, any that occur
  1480. // are unanticipated, and deemed unrecoverable, so the transaction should
  1481. // be transitioned to failure.
  1482. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  1483. name_remove->getCurrState());
  1484. EXPECT_EQ(NameChangeTransaction::UPDATE_FAILED_EVT,
  1485. name_remove->getNextEvent());
  1486. }
  1487. // Tests removingFwdAddrsHandler with the following scenario:
  1488. //
  1489. // The request includes only a forward change.
  1490. // Initial posted event is SERVER_SELECTED_EVT.
  1491. // The request build fails due to an unexpected exception.
  1492. //
  1493. TEST_F(NameRemoveTransactionTest,
  1494. removingFwdAddrsHandler_BuildRequestException) {
  1495. NameRemoveStubPtr name_remove;
  1496. // Create and prep a transaction, poised to run the handler.
  1497. ASSERT_NO_THROW(name_remove =
  1498. prepHandlerTest(NameRemoveTransaction::
  1499. REMOVING_FWD_ADDRS_ST,
  1500. NameChangeTransaction::
  1501. SERVER_SELECTED_EVT, FORWARD_CHG));
  1502. // Set the one-shot exception simulation flag.
  1503. name_remove->simulate_build_request_exception_ = true;
  1504. // Run removingFwdAddrsHandler to construct and send the request.
  1505. // This should fail with a build request throw which should be caught
  1506. // in the state handler.
  1507. ASSERT_NO_THROW(name_remove->removingFwdAddrsHandler());
  1508. // Verify we did not attempt to send anything.
  1509. EXPECT_EQ(0, name_remove->getUpdateAttempts());
  1510. // Completion flags should be false.
  1511. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1512. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1513. // Since IO exceptions should be gracefully handled, any that occur
  1514. // are unanticipated, and deemed unrecoverable, so the transaction should
  1515. // be transitioned to failure.
  1516. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  1517. name_remove->getCurrState());
  1518. EXPECT_EQ(NameChangeTransaction::UPDATE_FAILED_EVT,
  1519. name_remove->getNextEvent());
  1520. }
  1521. // Tests removingFwdRRsHandler with the following scenario:
  1522. //
  1523. // The request includes only a forward change.
  1524. // Initial posted event is SERVER_SELECTED_EVT.
  1525. // The request build fails due to an unexpected exception.
  1526. //
  1527. TEST_F(NameRemoveTransactionTest,
  1528. removingFwdRRsHandler_BuildRequestException) {
  1529. NameRemoveStubPtr name_remove;
  1530. // Create and prep a transaction, poised to run the handler.
  1531. ASSERT_NO_THROW(name_remove =
  1532. prepHandlerTest(NameRemoveTransaction::
  1533. REMOVING_FWD_RRS_ST,
  1534. NameChangeTransaction::
  1535. SERVER_SELECTED_EVT, FORWARD_CHG));
  1536. // Set the one-shot exception simulation flag.
  1537. name_remove->simulate_build_request_exception_ = true;
  1538. // Run removingFwdRRsHandler to construct and send the request.
  1539. // This should fail with a build request throw which should be caught
  1540. // in the state handler.
  1541. ASSERT_NO_THROW(name_remove->removingFwdRRsHandler());
  1542. // Verify we did not attempt to send anything.
  1543. EXPECT_EQ(0, name_remove->getUpdateAttempts());
  1544. // Completion flags should be false.
  1545. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1546. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1547. // Since IO exceptions should be gracefully handled, any that occur
  1548. // are unanticipated, and deemed unrecoverable, so the transaction should
  1549. // be transitioned to failure.
  1550. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  1551. name_remove->getCurrState());
  1552. EXPECT_EQ(NameChangeTransaction::UPDATE_FAILED_EVT,
  1553. name_remove->getNextEvent());
  1554. }
  1555. // Tests removingRevPTRsHandler with the following scenario:
  1556. //
  1557. // The request includes only a forward change.
  1558. // Initial posted event is SERVER_SELECTED_EVT.
  1559. // The request build fails due to an unexpected exception.
  1560. //
  1561. TEST_F(NameRemoveTransactionTest,
  1562. removingRevPTRsHandler_BuildRequestException) {
  1563. NameRemoveStubPtr name_remove;
  1564. // Create and prep a transaction, poised to run the handler.
  1565. ASSERT_NO_THROW(name_remove =
  1566. prepHandlerTest(NameRemoveTransaction::
  1567. REMOVING_REV_PTRS_ST,
  1568. NameChangeTransaction::
  1569. SERVER_SELECTED_EVT, FORWARD_CHG));
  1570. // Set the one-shot exception simulation flag.
  1571. name_remove->simulate_build_request_exception_ = true;
  1572. // Run removingRevPtrsHandler to construct and send the request.
  1573. // This should fail with a build request throw which should be caught
  1574. // in the state handler.
  1575. ASSERT_NO_THROW(name_remove->removingRevPtrsHandler());
  1576. // Verify we did not attempt to send anything.
  1577. EXPECT_EQ(0, name_remove->getUpdateAttempts());
  1578. // Completion flags should be false.
  1579. EXPECT_FALSE(name_remove->getForwardChangeCompleted());
  1580. EXPECT_FALSE(name_remove->getReverseChangeCompleted());
  1581. // Since IO exceptions should be gracefully handled, any that occur
  1582. // are unanticipated, and deemed unrecoverable, so the transaction should
  1583. // be transitioned to failure.
  1584. EXPECT_EQ(NameChangeTransaction::PROCESS_TRANS_FAILED_ST,
  1585. name_remove->getCurrState());
  1586. EXPECT_EQ(NameChangeTransaction::UPDATE_FAILED_EVT,
  1587. name_remove->getNextEvent());
  1588. }
  1589. }