Merge "Releasing reader_ memory for KSyncSockTcpSession." into R5.0

Juniper · Jul 26, 2018 · 3d2a830 · 3d2a830
2 parents 972353b + 7bd3259
commit 3d2a830
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/src/ksync/ksync_sock.h b/src/ksync/ksync_sock.h
@@ -629,6 +629,7 @@ class KSyncSockTcpSession : public TcpSession {
 public:
     KSyncSockTcpSession(TcpServer *server, Socket *sock,
                         bool async_ready = false);
+    virtual ~KSyncSockTcpSession();
 protected:
     virtual void OnRead(Buffer buffer);
 private:

diff --git a/src/ksync/ksync_sock_tcp.cc b/src/ksync/ksync_sock_tcp.cc
@@ -296,6 +296,12 @@ KSyncSockTcpSession::KSyncSockTcpSession(TcpServer *server, Socket *sock,
                        boost::bind(&KSyncSockTcp::ReceiveMsg, tcp_ptr, _1, _2));
 }
 
+KSyncSockTcpSession::~KSyncSockTcpSession() {
+    if (reader_) {
+        delete reader_;
+    }
+}
+
 void KSyncSockTcpSession::OnRead(Buffer buffer) {
     reader_->OnRead(buffer);
 }