[#3602] use weak ptr

Author: Razvan Becheriu

src/bin/dhcp4/tests/http_control_socket_unittest.cc

@@ -149,7 +149,10 @@ class BaseCtrlChannelDhcpv4Test : public ::testing::Test {
                                    this, true),
                          TEST_TIMEOUT, IntervalTimer::ONE_SHOT);
         // Run until the client stops the service or an error occurs.
-        io_service->run();
+        try {
+	    io_service->run();
+        } catch (...) {
+        }
         test_timer.cancel();
         if (io_service->stopped()) {
             io_service->restart();

src/bin/dhcp6/tests/http_control_socket_unittest.cc

@@ -187,7 +187,10 @@ class BaseCtrlChannelDhcpv6Test : public HttpCtrlDhcpv6Test {
                                    this, true),
                          TEST_TIMEOUT, IntervalTimer::ONE_SHOT);
         // Run until the client stops the service or an error occurs.
-        io_service->run();
+        try {
+	    io_service->run();
+        } catch (...) {
+        }
         test_timer.cancel();
         if (io_service->stopped()) {
             io_service->restart();

src/lib/http/connection.cc

@@ -68,7 +68,7 @@ SocketCallback::operator()(boost::system::error_code ec, size_t length) {
 HttpConnection::HttpConnection(const asiolink::IOServicePtr& io_service,
                                const HttpAcceptorPtr& acceptor,
                                const TlsContextPtr& tls_context,
-                               HttpConnectionPool& connection_pool,
+                               HttpConnectionPoolPtr connection_pool,
                                const HttpResponseCreatorPtr& response_creator,
                                const HttpAcceptorCallback& callback,
                                const long request_timeout,
@@ -234,23 +234,33 @@ HttpConnection::close() {
 
 void
 HttpConnection::shutdownConnection() {
+    auto connection_pool = connection_pool_.lock();
     try {
         LOG_DEBUG(http_logger, isc::log::DBGLVL_TRACE_BASIC,
                   HTTP_CONNECTION_SHUTDOWN)
             .arg(getRemoteEndpointAddressAsText());
-        connection_pool_.shutdown(shared_from_this());
+        if (connection_pool) {
+            connection_pool->shutdown(shared_from_this());
+        } else {
+            shutdown();
+        }
     } catch (...) {
         LOG_ERROR(http_logger, HTTP_CONNECTION_SHUTDOWN_FAILED);
     }
 }
 
 void
 HttpConnection::stopThisConnection() {
+    auto connection_pool = connection_pool_.lock();
     try {
         LOG_DEBUG(http_logger, isc::log::DBGLVL_TRACE_BASIC,
                   HTTP_CONNECTION_STOP)
             .arg(getRemoteEndpointAddressAsText());
-        connection_pool_.stop(shared_from_this());
+        if (connection_pool) {
+            connection_pool->stop(shared_from_this());
+        } else {
+            close();
+        }
     } catch (...) {
         LOG_ERROR(http_logger, HTTP_CONNECTION_STOP_FAILED);
     }

src/lib/http/connection.h

@@ -245,7 +245,7 @@ class HttpConnection : public boost::enable_shared_from_this<HttpConnection> {
     HttpConnection(const asiolink::IOServicePtr& io_service,
                    const HttpAcceptorPtr& acceptor,
                    const asiolink::TlsContextPtr& tls_context,
-                   HttpConnectionPool& connection_pool,
+                   std::shared_ptr<HttpConnectionPool> connection_pool,
                    const HttpResponseCreatorPtr& response_creator,
                    const HttpAcceptorCallback& callback,
                    const long request_timeout,
@@ -441,7 +441,7 @@ class HttpConnection : public boost::enable_shared_from_this<HttpConnection> {
     HttpAcceptorPtr acceptor_;
 
     /// @brief Connection pool holding this connection.
-    HttpConnectionPool& connection_pool_;
+    std::weak_ptr<HttpConnectionPool> connection_pool_;
 
     /// @brief Pointer to the @ref HttpResponseCreator object used to create
     /// HTTP responses.

src/lib/http/connection_pool.h

@@ -71,6 +71,9 @@ class HttpConnectionPool {
     std::mutex mutex_;
 };
 
+/// @brief Pointer to the @ref HttpConnection.
+typedef std::shared_ptr<HttpConnectionPool> HttpConnectionPoolPtr;
+
 }
 }
 

src/lib/http/listener_impl.cc

@@ -26,7 +26,7 @@ HttpListenerImpl::HttpListenerImpl(const IOServicePtr& io_service,
                                    const long request_timeout,
                                    const long idle_timeout)
     : io_service_(io_service), tls_context_(tls_context), acceptor_(),
-      endpoint_(), connections_(),
+      endpoint_(), connections_(new HttpConnectionPool()),
       creator_factory_(creator_factory),
       request_timeout_(request_timeout), idle_timeout_(idle_timeout),
       use_external_(false) {
@@ -102,7 +102,7 @@ HttpListenerImpl::start() {
 
 void
 HttpListenerImpl::stop() {
-    connections_.stopAll();
+    connections_->stopAll();
     if (use_external_) {
         IfaceMgr::instance().deleteExternalSocket(acceptor_->getNative());
     }
@@ -124,7 +124,7 @@ HttpListenerImpl::accept() {
         conn->addExternalSockets(true);
     }
     // Add this new connection to the pool.
-    connections_.start(conn);
+    connections_->start(conn);
 }
 
 void

src/lib/http/listener_impl.h

@@ -128,7 +128,7 @@ class HttpListenerImpl : public boost::enable_shared_from_this<HttpListenerImpl>
     boost::scoped_ptr<asiolink::TCPEndpoint> endpoint_;
 
     /// @brief Pool of active connections.
-    HttpConnectionPool connections_;
+    HttpConnectionPoolPtr connections_;
 
     /// @brief Pointer to the @ref HttpResponseCreatorFactory.
     HttpResponseCreatorFactoryPtr creator_factory_;
@@ -144,7 +144,6 @@ class HttpListenerImpl : public boost::enable_shared_from_this<HttpListenerImpl>
     bool use_external_;
 };
 
-
 } // end of namespace isc::http
 } // end of namespace isc
 

src/lib/http/tests/connection_pool_unittests.cc

@@ -107,7 +107,7 @@ class HttpConnectionPoolTest : public ::testing::Test {
     HttpConnectionPoolTest()
         : io_service_(new IOService()),
           acceptor_(new HttpAcceptor(io_service_)),
-          connection_pool_(),
+          connection_pool_(new HttpConnectionPool()),
           response_creator_(new TestHttpResponseCreator()) {
         MultiThreadingMgr::instance().setMode(false);
     }
@@ -219,7 +219,7 @@ class HttpConnectionPoolTest : public ::testing::Test {
 
     IOServicePtr io_service_;                   ///< IO service.
     HttpAcceptorPtr acceptor_;                  ///< Test acceptor.
-    HttpConnectionPool connection_pool_;        ///< Test connection pool.
+    HttpConnectionPoolPtr connection_pool_;     ///< Test connection pool.
     HttpResponseCreatorPtr response_creator_;   ///< Test response creator.
 
 };

src/lib/http/tests/http_server_test.h

@@ -125,7 +125,7 @@ class HttpConnectionLongWriteBuffer : public HttpConnection {
     HttpConnectionLongWriteBuffer(const IOServicePtr& io_service,
                                   const HttpAcceptorPtr& acceptor,
                                   const TlsContextPtr& tls_context,
-                                  HttpConnectionPool& connection_pool,
+                                  HttpConnectionPoolPtr connection_pool,
                                   const HttpResponseCreatorPtr& response_creator,
                                   const HttpAcceptorCallback& callback,
                                   const long request_timeout,
@@ -172,7 +172,7 @@ class HttpConnectionTransactionChange : public HttpConnection {
     HttpConnectionTransactionChange(const IOServicePtr& io_service,
                                     const HttpAcceptorPtr& acceptor,
                                     const TlsContextPtr& tls_context,
-                                    HttpConnectionPool& connection_pool,
+                                    HttpConnectionPoolPtr connection_pool,
                                     const HttpResponseCreatorPtr& response_creator,
                                     const HttpAcceptorCallback& callback,
                                     const long request_timeout,