[#3300] revert fix and move poll

Author: Razvan Becheriu

src/bin/dhcp4/ctrl_dhcp4_srv.cc

@@ -450,6 +450,16 @@ ControlledDhcpv4Srv::commandConfigSetHandler(const string&,
         LOG_FATAL(dhcp4_logger, DHCP4_CONFIG_UNRECOVERABLE_ERROR);
     }
 
+    /// Let postponed hook initializations to run.
+    try {
+        getIOService()->poll();
+    } catch (const std::exception& ex) {
+        std::ostringstream err;
+        err << "Error initializing hooks: "
+            << ex.what();
+        return (isc::config::createAnswer(CONTROL_RESULT_ERROR, err.str()));
+    }
+
     return (result);
 }
 
@@ -913,7 +923,7 @@ ControlledDhcpv4Srv::processConfig(isc::data::ConstElementPtr config) {
 
     // Allow DB reconnect on startup. The database connection parameters specify
     // respective details.
-    std::shared_ptr<DbConnectionInitWithRetry> dbr(new DbConnectionInitWithRetry());
+    DbConnectionInitWithRetry retry;
 
     // Single stream instance used in all error clauses
     std::ostringstream err;
@@ -1092,17 +1102,6 @@ ControlledDhcpv4Srv::processConfig(isc::data::ConstElementPtr config) {
         return (isc::config::createAnswer(CONTROL_RESULT_ERROR, err.str()));
     }
 
-    dbr.reset();
-
-    /// Let postponed hook initializations to run.
-    try {
-        ControlledDhcpv4Srv::getInstance()->getIOService()->poll();
-    } catch (const std::exception& ex) {
-        err << "Error initializing hooks: "
-            << ex.what();
-        return (isc::config::createAnswer(CONTROL_RESULT_ERROR, err.str()));
-    }
-
     return (answer);
 }
 

src/bin/dhcp4/tests/hooks_unittest.cc

@@ -4052,7 +4052,7 @@ TEST_F(LoadUnloadDhcpv4SrvTest, startServiceFail) {
     // section which loads the callout library #4, which implements
     // dhcp4_srv_configured callout and a failing start service.
     string config_str =
-        "{"
+        "{ \"Dhcp4\": {"
         "    \"interfaces-config\": {"
         "        \"interfaces\": [ ]"
         "    },"
@@ -4069,13 +4069,13 @@ TEST_F(LoadUnloadDhcpv4SrvTest, startServiceFail) {
         "            \"library\": \"" + std::string(CALLOUT_LIBRARY_4) + "\""
         "        }"
         "    ]"
-        "}";
+        "} }";
 
     ConstElementPtr config = Element::fromJSON(config_str);
 
     // Configure the server.
     ConstElementPtr answer;
-    ASSERT_NO_THROW(answer = srv->processConfig(config));
+    ASSERT_NO_THROW(answer = srv->processCommand("config-set", config));
 
     // Make sure there was an error with expected message.
     int status_code;

src/bin/dhcp6/ctrl_dhcp6_srv.cc

@@ -452,6 +452,16 @@ ControlledDhcpv6Srv::commandConfigSetHandler(const string&,
         LOG_FATAL(dhcp6_logger, DHCP6_CONFIG_UNRECOVERABLE_ERROR);
     }
 
+    /// Let postponed hook initializations to run.
+    try {
+        getIOService()->poll();
+    } catch (const std::exception& ex) {
+        std::ostringstream err;
+        err << "Error initializing hooks: "
+            << ex.what();
+        return (isc::config::createAnswer(CONTROL_RESULT_ERROR, err.str()));
+    }
+
     return (result);
 }
 
@@ -918,7 +928,7 @@ ControlledDhcpv6Srv::processConfig(isc::data::ConstElementPtr config) {
 
     // Allow DB reconnect on startup. The database connection parameters specify
     // respective details.
-    std::shared_ptr<DbConnectionInitWithRetry> dbr(new DbConnectionInitWithRetry());
+    DbConnectionInitWithRetry retry;
 
     // Single stream instance used in all error clauses
     std::ostringstream err;
@@ -1112,17 +1122,6 @@ ControlledDhcpv6Srv::processConfig(isc::data::ConstElementPtr config) {
         return (isc::config::createAnswer(CONTROL_RESULT_ERROR, err.str()));
     }
 
-    dbr.reset();
-
-    /// Let postponed hook initializations to run.
-    try {
-        ControlledDhcpv6Srv::getInstance()->getIOService()->poll();
-    } catch (const std::exception& ex) {
-        err << "Error initializing hooks: "
-            << ex.what();
-        return (isc::config::createAnswer(CONTROL_RESULT_ERROR, err.str()));
-    }
-
     return (answer);
 }
 

src/bin/dhcp6/tests/hooks_unittest.cc

@@ -5846,7 +5846,7 @@ TEST_F(LoadUnloadDhcpv6SrvTest, startServiceFail) {
     // section which loads the callout library #4, which implements
     // dhcp6_srv_configured callout and a failing start service.
     string config_str =
-        "{"
+        "{ \"Dhcp6\": {"
         "    \"interfaces-config\": {"
         "        \"interfaces\": [ ]"
         "    },"
@@ -5864,13 +5864,13 @@ TEST_F(LoadUnloadDhcpv6SrvTest, startServiceFail) {
         "            \"library\": \"" + std::string(CALLOUT_LIBRARY_4) + "\""
         "        }"
         "    ]"
-        "}";
+        "} }";
 
     ConstElementPtr config = Element::fromJSON(config_str);
 
     // Configure the server.
     ConstElementPtr answer;
-    ASSERT_NO_THROW(answer = srv->processConfig(config));
+    ASSERT_NO_THROW(answer = srv->processCommand("config-set", config));
 
     // Make sure there was an error with expected message.
     int status_code;