iot-dsa-v2
diff --git a/‎src/broker/broker.cc
Copy file name to clipboardExpand all lines: src/broker/broker.cc
+1Lines changed: 1 addition & 0 deletions b/‎src/broker/broker.cc
Copy file name to clipboardExpand all lines: src/broker/broker.cc
+1Lines changed: 1 addition & 0 deletions
diff --git a/‎src/broker/v1/v1_session_manager.cc
Copy file name to clipboardExpand all lines: src/broker/v1/v1_session_manager.cc
+2-1Lines changed: 2 additions & 1 deletion b/‎src/broker/v1/v1_session_manager.cc
Copy file name to clipboardExpand all lines: src/broker/v1/v1_session_manager.cc
+2-1Lines changed: 2 additions & 1 deletion
diff --git a/‎src/sdk/core/editable_strand.cc
Copy file name to clipboardExpand all lines: src/sdk/core/editable_strand.cc
+1Lines changed: 1 addition & 0 deletions b/‎src/sdk/core/editable_strand.cc
Copy file name to clipboardExpand all lines: src/sdk/core/editable_strand.cc
+1Lines changed: 1 addition & 0 deletions
diff --git a/‎src/sdk/core/session.h
Copy file name to clipboardExpand all lines: src/sdk/core/session.h
+3-1Lines changed: 3 additions & 1 deletion b/‎src/sdk/core/session.h
Copy file name to clipboardExpand all lines: src/sdk/core/session.h
+3-1Lines changed: 3 additions & 1 deletion
@@ -113,6 +113,7 @@ void DsBroker::init(ref_<Module>&& default_module) {
 void DsBroker::destroy_impl() {
   _upstream->destroy();
   modules->destroy();
+  _v1_manager->destroy();
   _v1_manager.reset();
 
   if (_tcp_server != nullptr) {
 
@@ -27,6 +27,7 @@ void V1SessionManager::destroy_impl() {
   }
   _sessions.clear();
   _state_manager.reset();
+  _shared_ptr.reset();
 }
 
 void V1SessionManager::on_conn(const string_& dsid, const string_& token,
@@ -103,4 +104,4 @@ void V1SessionManager::on_ws(shared_ptr_<Websocket>&& ws, const string_& dsid,
 
   ws->destroy();
 }
-}  // namespace dsa
+}  // namespace dsa
@@ -74,6 +74,7 @@ void EditableStrand::destroy_impl() {
   _stream_acceptor.reset();
   _client_manager.reset();
   _authorizer.reset();
+  _storage.reset();
 
   {
     std::lock_guard<std::mutex> lock(_inject_mutex);
 
@@ -66,6 +66,8 @@ class BaseSession : public DestroyableRef<BaseSession> {
 
   virtual bool is_connected() const = 0;
   virtual string_ map_pub_path(const string_ &path) = 0;
+
+  virtual ~BaseSession() = default;
 };
 
 // maintain request and response streams
@@ -206,4 +208,4 @@ class Session final : public BaseSession {
 
 }  // namespace dsa
 
-#endif  // DSA_SDK_SESSION_H
+#endif  // DSA_SDK_SESSION_H
Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,7 @@ void V1SessionManager::destroy_impl() {`
`27`	`27`	`}`
`28`	`28`	`_sessions.clear();`
`29`	`29`	`_state_manager.reset();`
	`30`	`+ _shared_ptr.reset();`
`30`	`31`	`}`
`31`	`32`
`32`	`33`	`void V1SessionManager::on_conn(const string_& dsid, const string_& token,`
`@@ -103,4 +104,4 @@ void V1SessionManager::on_ws(shared_ptr_<Websocket>&& ws, const string_& dsid,`
`103`	`104`
`104`	`105`	`ws->destroy();`
`105`	`106`	`}`
`106`		`-} // namespace dsa`
	`107`	`+} // namespace dsa`
Original file line number	Diff line number	Diff line change
`@@ -74,6 +74,7 @@ void EditableStrand::destroy_impl() {`
`74`	`74`	`_stream_acceptor.reset();`
`75`	`75`	`_client_manager.reset();`
`76`	`76`	`_authorizer.reset();`
	`77`	`+ _storage.reset();`
`77`	`78`
`78`	`79`	`{`
`79`	`80`	`std::lock_guard<std::mutex> lock(_inject_mutex);`