Change Protocol* to ProtocolPtr implemented with shared_ptr

Change-Id: Ic1b6e7dd50ddf011e8700fa65fdb05560df3f32a

diff --git a/src/service/protocol/Protocol.h b/src/service/protocol/Protocol.h
index 7dac7fe0febf79add2492c2077a1f67a3199adb7..9efae80c6c0a87771d1a43d72ed0eb2947618eed 100644 (file)
--- a/src/service/protocol/Protocol.h
+++ b/src/service/protocol/Protocol.h
@@ -23,7 +23,10 @@
 #ifndef SRC_SERVICE_PROTOCOL_PROTOCOL_H_
 #define SRC_SERVICE_PROTOCOL_PROTOCOL_H_
 
+#include <memory>
+
 #include <common.h>
+
 #include <request/Request.h>
 #include <response/CheckResponse.h>
 
@@ -39,6 +42,8 @@ public:
     virtual void appendResponseToBuffer(CheckResponse &&response);
 };
 
+typedef std::shared_ptr<Protocol> ProtocolPtr;
+
 } // namespace Cynara
 
 #endif /* SRC_SERVICE_PROTOCOL_PROTOCOL_H_ */

diff --git a/src/service/request/RequestContext.cpp b/src/service/request/RequestContext.cpp
index 8671f0284ab9562b8e73bc91bb724239f76dba17..fdadea4976fe37e2813e0626410d579f2a43dcf3 100644 (file)
--- a/src/service/request/RequestContext.cpp
+++ b/src/service/request/RequestContext.cpp
@@ -31,7 +31,7 @@ BinaryQueue &RequestContext::resultQueue(int fd) {
     return Cynara::getSocketManager()->descriptor(fd).writeQueue();
 }
 
-Protocol *RequestContext::protocol(int fd) {
+ProtocolPtr RequestContext::protocol(int fd) {
     return Cynara::getSocketManager()->descriptor(fd).protocol();
 }
 

diff --git a/src/service/request/RequestContext.h b/src/service/request/RequestContext.h
index 1d98a3335da42aeca5e5897bfc7a1e73cc1431a3..d026e48b6ace0b5fa4622a1a34f4500ce1ad503d 100644 (file)
--- a/src/service/request/RequestContext.h
+++ b/src/service/request/RequestContext.h
@@ -29,13 +29,11 @@
 
 namespace Cynara {
 
-class Protocol;
-
 class RequestContext {
 
 public:
     static BinaryQueue &resultQueue(int fd);
-    static Protocol *protocol(int fd);
+    static ProtocolPtr protocol(int fd);
 };
 
 } // namespace Cynara

diff --git a/src/service/sockets/Descriptor.cpp b/src/service/sockets/Descriptor.cpp
index cc368bffa94561408a4173ab5ce26cfa6fcce300..2e51ffe485df151d78419c59f350d3d8c112b0b5 100644 (file)
--- a/src/service/sockets/Descriptor.cpp
+++ b/src/service/sockets/Descriptor.cpp
@@ -55,7 +55,7 @@ void Descriptor::clear(void) {
     m_readQueue.clear();
     m_writeQueue.clear();
     m_writeBuffer.clear();
-    m_protocol = nullptr;
+    m_protocol.reset();
 }
 
 } // namespace Cynara

diff --git a/src/service/sockets/Descriptor.h b/src/service/sockets/Descriptor.h
index debb52196fcadf32cae12c2d1cbf4e762697f649..3df54d655c90785f01be7c6c3b50970adb70b338 100644 (file)
--- a/src/service/sockets/Descriptor.h
+++ b/src/service/sockets/Descriptor.h
@@ -23,6 +23,8 @@
 #ifndef SRC_SERVICE_SOCKETS_DESCRIPTOR_H_
 #define SRC_SERVICE_SOCKETS_DESCRIPTOR_H_
 
+#include <memory>
+
 #include <common.h>
 
 #include <protocol/Protocol.h>
@@ -39,7 +41,7 @@ private:
     BinaryQueue m_writeQueue;
     RawBuffer m_writeBuffer;
 
-    Protocol *m_protocol;
+    ProtocolPtr m_protocol;
 
 public:
     Descriptor();
@@ -54,7 +56,7 @@ public:
 
     bool hasDataToWrite(void) const;
 
-    Protocol *protocol(void) {
+    ProtocolPtr protocol(void) {
         return m_protocol;
     }
 
@@ -62,7 +64,7 @@ public:
         return m_writeQueue;
     }
 
-    void setProtocol(Protocol *protocol) {
+    void setProtocol(ProtocolPtr protocol) {
         m_protocol = protocol;
     }
 

diff --git a/src/service/sockets/SocketManager.cpp b/src/service/sockets/SocketManager.cpp
index 0a2a5beb0d3b7fbd194d773eb75328f0e93208d1..1f955c890ab55db857c33044cb2c6f1728650e70 100644 (file)
--- a/src/service/sockets/SocketManager.cpp
+++ b/src/service/sockets/SocketManager.cpp
@@ -69,8 +69,8 @@ void SocketManager::init(void) {
     const mode_t clientSocketUMask(0);
     const mode_t adminSocketUMask(0077);
 
-    createDomainSocket(new ProtocolClient, clientSocketPath, clientSocketUMask);
-    createDomainSocket(new ProtocolAdmin, adminSocketPath, adminSocketUMask);
+    createDomainSocket(ProtocolPtr(new ProtocolClient), clientSocketPath, clientSocketUMask);
+    createDomainSocket(ProtocolPtr(new ProtocolAdmin), adminSocketPath, adminSocketUMask);
     // todo create signal descriptor
     LOGI("SocketManger init done");
 }
@@ -235,7 +235,7 @@ bool SocketManager::handleRead(int fd, const RawBuffer &readbuffer) {
     return true;
 }
 
-void SocketManager::createDomainSocket(Protocol *protocol, const std::string &path, mode_t mask) {
+void SocketManager::createDomainSocket(ProtocolPtr protocol, const std::string &path, mode_t mask) {
     int fd = getSocketFromSystemD(path);
     if (fd == -1)
         fd = createDomainSocketHelp(path, mask);

diff --git a/src/service/sockets/SocketManager.h b/src/service/sockets/SocketManager.h
index 8478a444282918487f65bb83e173f9642e0f7cc2..3c784bc52a07dc6af219b5f0eea85c4b9bb02564 100644 (file)
--- a/src/service/sockets/SocketManager.h
+++ b/src/service/sockets/SocketManager.h
@@ -24,6 +24,7 @@
 #define SRC_SERVICE_SOCKETS_SOCKETMANAGER_H_
 
 #include <vector>
+#include <memory>
 #include <stdio.h>
 
 #include <common.h>
@@ -63,7 +64,7 @@ private:
     void closeSocket(int fd);
     bool handleRead(int fd, const RawBuffer &readbuffer);
 
-    void createDomainSocket(Protocol *protocol, const std::string &path, mode_t mask);
+    void createDomainSocket(ProtocolPtr protocol, const std::string &path, mode_t mask);
     int createDomainSocketHelp(const std::string &path, mode_t mask);
     int getSocketFromSystemD(const std::string &path);