Use shared and weak pointers for ReponseTaker and RequestContext

Change-Id: I711a2c97819d7a363fa1b2d1401e7156554a2e09

diff --git a/src/service/logic/Logic.cpp b/src/service/logic/Logic.cpp
index 9aa2e309c7e44e371c7f59352431da2c6ec9c1e8..3944a8f278219aad685ebb4aa82654001df90eaf 100644 (file)
--- a/src/service/logic/Logic.cpp
+++ b/src/service/logic/Logic.cpp
@@ -26,6 +26,7 @@
 
 #include <main/Cynara.h>
 #include <request/CheckRequest.h>
+#include <request/RequestContext.h>
 #include <response/CheckResponse.h>
 #include <storage/Storage.h>
 
@@ -38,14 +39,14 @@ Logic::Logic() {
 Logic::~Logic() {
 }
 
-void Logic::execute(const RequestContext &context, CheckRequestPtr request) {
+void Logic::execute(RequestContextPtr context, CheckRequestPtr request) {
     PolicyResult result(PredefinedPolicyType::DENY);
     if (check(context, request->key(), result)) {
-        context.returnResponse(CheckResponse(result));
+        context->returnResponse(context, CheckResponse(result));
     }
 }
 
-bool Logic::check(const RequestContext &context UNUSED, const PolicyKey &key,
+bool Logic::check(RequestContextPtr context UNUSED, const PolicyKey &key,
                   PolicyResult& result) {
     result = Cynara::getStorage()->checkPolicy(key);
 

diff --git a/src/service/logic/Logic.h b/src/service/logic/Logic.h
index 362b47c493d92dde91ed1c3a6bf9589cae97efa5..9ef96f4ea7411e69e1fb997c2ff487648ed3b27a 100644 (file)
--- a/src/service/logic/Logic.h
+++ b/src/service/logic/Logic.h
@@ -27,7 +27,6 @@
 #include <types/PolicyResult.h>
 
 #include <request/pointers.h>
-#include <request/RequestContext.h>
 #include <request/RequestTaker.h>
 
 namespace Cynara {
@@ -37,10 +36,10 @@ public:
     Logic();
     virtual ~Logic();
 
-    virtual void execute(const RequestContext &context, CheckRequestPtr request);
+    virtual void execute(RequestContextPtr context, CheckRequestPtr request);
 
 private:
-    bool check(const RequestContext &context, const PolicyKey &key, PolicyResult& result);
+    bool check(RequestContextPtr context, const PolicyKey &key, PolicyResult& result);
 
 };
 

diff --git a/src/service/request/CheckRequest.cpp b/src/service/request/CheckRequest.cpp
index 8bcbf65f12e89a5751794c675aa41356863a6d9f..5473a79564cb3b3fe4dbb4a1fbf1bb405ae6c116 100644 (file)
--- a/src/service/request/CheckRequest.cpp
+++ b/src/service/request/CheckRequest.cpp
@@ -27,7 +27,7 @@
 namespace Cynara {
 
 void CheckRequest::execute(RequestPtr self, RequestTaker &taker,
-                           const RequestContext &context) const {
+                           RequestContextPtr context) const {
     taker.execute(context, std::dynamic_pointer_cast<CheckRequest>(self));
 }
 

diff --git a/src/service/request/CheckRequest.h b/src/service/request/CheckRequest.h
index 54a8acf00983b60897d58c7ec3e3cbe5ef3ed6bd..83f0203f720ee95647fe6317a1d58a16e3c1efe7 100644 (file)
--- a/src/service/request/CheckRequest.h
+++ b/src/service/request/CheckRequest.h
@@ -27,7 +27,6 @@
 
 #include <request/pointers.h>
 #include <request/Request.h>
-#include <request/RequestContext.h>
 #include <request/RequestTaker.h>
 
 namespace Cynara {
@@ -46,7 +45,7 @@ public:
         return m_key;
     }
 
-    virtual void execute(RequestPtr self, RequestTaker &taker, const RequestContext &context) const;
+    virtual void execute(RequestPtr self, RequestTaker &taker, RequestContextPtr context) const;
 };
 
 } // namespace Cynara

diff --git a/src/service/request/Request.h b/src/service/request/Request.h
index 8df08b946c8cf62e503e0fae262e4c4595d51b23..fa76ffaa6362917777d2be73de959501e61e52d6 100644 (file)
--- a/src/service/request/Request.h
+++ b/src/service/request/Request.h
@@ -24,7 +24,7 @@
 #define SRC_SERVICE_REQUEST_REQUEST_H_
 
 #include <request/pointers.h>
-#include <request/RequestContext.h>
+#include <request/pointers.h>
 #include <request/RequestTaker.h>
 
 namespace Cynara {
@@ -34,8 +34,7 @@ public:
     Request() = default;
     virtual ~Request() = default;
 
-    virtual void execute(RequestPtr self, RequestTaker &taker,
-                         const RequestContext &context) const = 0;
+    virtual void execute(RequestPtr self, RequestTaker &taker, RequestContextPtr context) const = 0;
 };
 
 } // namespace Cynara

diff --git a/src/service/request/RequestContext.h b/src/service/request/RequestContext.h
index 55ff9fea4ed402c96051dc32b69037b2e42decb6..d8e957830e6e3c7bb0ece6af94976b0bd3adb295 100644 (file)
--- a/src/service/request/RequestContext.h
+++ b/src/service/request/RequestContext.h
@@ -23,8 +23,12 @@
 #ifndef SRC_SERVICE_REQUEST_REQUESTCONTEXT_H_
 #define SRC_SERVICE_REQUEST_REQUESTCONTEXT_H_
 
+#include <memory>
+
 #include <common.h>
 
+#include <request/pointers.h>
+#include <response/pointers.h>
 #include <response/ResponseTaker.h>
 
 namespace Cynara {
@@ -32,17 +36,23 @@ namespace Cynara {
 class RequestContext {
 private:
     int m_desc;
-    ResponseTaker &m_responseTaker;
+    ResponseTakerWeakPtr m_responseTaker;
     BinaryQueue &m_responseQueue;
 
 public:
-    RequestContext(int desc, ResponseTaker &responseTaker, BinaryQueue &responseQueue)
+    RequestContext(int desc, ResponseTakerPtr responseTaker, BinaryQueue &responseQueue)
         : m_desc(desc), m_responseTaker(responseTaker), m_responseQueue(responseQueue) {
     }
 
     template <class T>
-    void returnResponse(T &&response) const {
-        m_responseTaker.appendResponseToBuffer(m_responseQueue, std::move(response));
+    void returnResponse(RequestContextPtr self, T &&response) const {
+        ResponseTakerPtr taker = m_responseTaker.lock();
+        if (taker)
+            taker->execute(self, std::move(response));
+    }
+
+    BinaryQueue &responseQueue(void) const {
+        return m_responseQueue;
     }
 };
 

diff --git a/src/service/request/RequestTaker.cpp b/src/service/request/RequestTaker.cpp
index e56f4aaf041aafd3e6f3e5a86110ca656caac071..f634ea82e1a441e70d5bb1d119ec118d462fadd0 100644 (file)
--- a/src/service/request/RequestTaker.cpp
+++ b/src/service/request/RequestTaker.cpp
@@ -20,13 +20,15 @@
  * @brief       This file implements RequestTaker class
  */
 
+#include <common.h>
+
 #include <exceptions/NotImplementedException.h>
 
 #include "RequestTaker.h"
 
 namespace Cynara {
 
-void RequestTaker::execute(const RequestContext &context UNUSED, CheckRequestPtr request UNUSED) {
+void RequestTaker::execute(RequestContextPtr context UNUSED, CheckRequestPtr request UNUSED) {
     throw NotImplementedException();
 }
 

diff --git a/src/service/request/RequestTaker.h b/src/service/request/RequestTaker.h
index 5564ece7820f3746778e354b4fe6049c9fc25915..9ebbe3295f638558b1a3b61c780f4aa5e6c280f3 100644 (file)
--- a/src/service/request/RequestTaker.h
+++ b/src/service/request/RequestTaker.h
@@ -24,7 +24,6 @@
 #define SRC_SERVICE_REQUEST_REQUESTTAKER_H_
 
 #include <request/pointers.h>
-#include <request/RequestContext.h>
 
 namespace Cynara {
 
@@ -33,7 +32,7 @@ public:
     RequestTaker() = default;
     virtual ~RequestTaker() = default;
 
-    virtual void execute(const RequestContext &context, CheckRequestPtr request);
+    virtual void execute(RequestContextPtr context, CheckRequestPtr request);
 };
 
 } // namespace Cynara

diff --git a/src/service/request/pointers.h b/src/service/request/pointers.h
index 79f153997fbde35e17f7970af47c3e19b0700cec..7bfc66ebd63a8d09ac51bd7c9b6a70e846824b66 100644 (file)
--- a/src/service/request/pointers.h
+++ b/src/service/request/pointers.h
@@ -27,11 +27,14 @@
 
 namespace Cynara {
 
+class CheckRequest;
+typedef std::shared_ptr<CheckRequest> CheckRequestPtr;
+
 class Request;
 typedef std::shared_ptr<Request> RequestPtr;
 
-class CheckRequest;
-typedef std::shared_ptr<CheckRequest> CheckRequestPtr;
+class RequestContext;
+typedef std::shared_ptr<RequestContext> RequestContextPtr;
 
 } // namespace Cynara
 

diff --git a/src/service/response/ResponseTaker.cpp b/src/service/response/ResponseTaker.cpp
index 9ce248a1d683181a87dba945434aa0018a85cae3..fff97743e070e7cd6a83d2833a0aae52df4fbb21 100644 (file)
--- a/src/service/response/ResponseTaker.cpp
+++ b/src/service/response/ResponseTaker.cpp
@@ -28,8 +28,7 @@
 
 namespace Cynara {
 
-void ResponseTaker::appendResponseToBuffer(BinaryQueue &queue UNUSED,
-                                           CheckResponse &&response UNUSED) {
+void ResponseTaker::execute(RequestContextPtr context UNUSED, CheckResponse &&response UNUSED) {
     throw NotImplementedException();
 }
 

diff --git a/src/service/response/ResponseTaker.h b/src/service/response/ResponseTaker.h
index 771adbc843d60add1cec6029d215a53a6495e760..0c880b69b5568b2c138e854c8df76b9a41ba94b2 100644 (file)
--- a/src/service/response/ResponseTaker.h
+++ b/src/service/response/ResponseTaker.h
@@ -25,6 +25,7 @@
 
 #include <common.h>
 
+#include <request/pointers.h>
 #include <response/CheckResponse.h>
 
 namespace Cynara {
@@ -34,7 +35,7 @@ public:
     ResponseTaker() = default;
     virtual ~ResponseTaker() = default;
 
-    virtual void appendResponseToBuffer(BinaryQueue &queue, CheckResponse &&response);
+    virtual void execute(RequestContextPtr context, CheckResponse &&response);
 };
 
 } // namespace Cynara

diff --git a/src/service/response/pointers.h b/src/service/response/pointers.h
new file mode 100644 (file)
index 0000000..6d12a8b
--- /dev/null
+++ b/src/service/response/pointers.h
@@ -0,0 +1,36 @@
+/*
+ * Copyright (c) 2014 Samsung Electronics Co., Ltd All Rights Reserved
+ *
+ *    Licensed under the Apache License, Version 2.0 (the "License");
+ *    you may not use this file except in compliance with the License.
+ *    You may obtain a copy of the License at
+ *
+ *        http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *    Unless required by applicable law or agreed to in writing, software
+ *    distributed under the License is distributed on an "AS IS" BASIS,
+ *    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *    See the License for the specific language governing permissions and
+ *    limitations under the License.
+ */
+/*
+ * @file        pointers.h
+ * @author      Lukasz Wojciechowski <l.wojciechow@partner.samsung.com>
+ * @version     1.0
+ * @brief       This file defines response classes pointers
+ */
+
+#ifndef SRC_SERVICE_RESPONSE_POINTERS_H_
+#define SRC_SERVICE_RESPONSE_POINTERS_H_
+
+#include <memory>
+
+namespace Cynara {
+
+class ResponseTaker;
+typedef std::shared_ptr<ResponseTaker> ResponseTakerPtr;
+typedef std::weak_ptr<ResponseTaker> ResponseTakerWeakPtr;
+
+} // namespace Cynara
+
+#endif /* SRC_SERVICE_RESPONSE_POINTERS_H_ */

diff --git a/src/service/sockets/Descriptor.cpp b/src/service/sockets/Descriptor.cpp
index 661833d967f1106c8bafab7142268848c6d4cd35..f58d28ea906f0c232915e9d265a57c6b14606bff 100644 (file)
--- a/src/service/sockets/Descriptor.cpp
+++ b/src/service/sockets/Descriptor.cpp
@@ -31,6 +31,10 @@ bool Descriptor::hasDataToWrite(void) const {
     return !(m_writeQueue.empty() && m_writeBuffer.empty());
 }
 
+ResponseTakerPtr Descriptor::responseTaker(void) const {
+    return std::static_pointer_cast<ResponseTaker>(m_protocol);
+}
+
 void Descriptor::pushReadBuffer(const RawBuffer &readbuffer) {
     m_readQueue.appendCopy(readbuffer.data(), readbuffer.size());
 }

diff --git a/src/service/sockets/Descriptor.h b/src/service/sockets/Descriptor.h
index 769abdd9c3f03256207f6d31ca0413ead234b92e..86ee4dbb460f188e10c22b722ece7ecf0487de22 100644 (file)
--- a/src/service/sockets/Descriptor.h
+++ b/src/service/sockets/Descriptor.h
@@ -29,6 +29,7 @@
 
 #include <protocol/Protocol.h>
 #include <request/Request.h>
+#include <response/pointers.h>
 
 namespace Cynara {
 
@@ -60,9 +61,7 @@ public:
         return m_protocol;
     }
 
-    ResponseTaker &responseTaker(void) {
-        return *m_protocol;
-    }
+    ResponseTakerPtr responseTaker(void) const;
 
     BinaryQueue &writeQueue(void) {
         return m_writeQueue;

diff --git a/src/service/sockets/SocketManager.cpp b/src/service/sockets/SocketManager.cpp
index aa7cb51397eeaccb3ac2a4f1f92711fdf5873062..fae4984ca182454bf184b4798a291510d391d5c7 100644 (file)
--- a/src/service/sockets/SocketManager.cpp
+++ b/src/service/sockets/SocketManager.cpp
@@ -227,7 +227,8 @@ bool SocketManager::handleRead(int fd, const RawBuffer &readbuffer) {
             LOGD("request extracted");
 
             //build context
-            RequestContext context(fd, desc.responseTaker(), desc.writeQueue());
+            auto context = std::make_shared<RequestContext>(fd, desc.responseTaker(),
+                                                            desc.writeQueue());
             //pass request to request taker
             req->execute(req, requestTaker(), context);
         }