couple things that might help

node/session.cpp

@@ -15,6 +15,7 @@
 #include <node/session.hpp>
 #include <node/node.hpp>
 #include <sstream>
+#include <boost/beast/websocket/error.hpp>
 
 
 using namespace bzn;
@@ -64,13 +65,17 @@ session::start_idle_timeout()
                 return;
             }
 
-            self->start_idle_timeout();
+            if (!self->closing)
+            {
+                self->start_idle_timeout();
+            }
         }));
 }
 
 void
 session::open(std::shared_ptr<bzn::beast::websocket_base> ws_factory)
 {
+    this->opened_session = true;
     this->strand->wrap([self = shared_from_this(), ws_factory]()
     {
         self->record("open");
@@ -120,6 +125,7 @@ session::open(std::shared_ptr<bzn::beast::websocket_base> ws_factory)
 void
 session::accept(std::shared_ptr<bzn::beast::websocket_stream_base> ws)
 {
+    this->accepted_session = true;
     this->strand->wrap([self = shared_from_this(), ws]()
     {
         self->record("accept");
@@ -170,7 +176,7 @@ session::do_read()
 
     auto buffer = std::make_shared<boost::beast::multi_buffer>();
 
-    if (this->reading || !this->is_open())
+    if (this->reading || !this->is_open() || this->closing)
     {
         this->record("do read skipped");
         return;
@@ -182,6 +188,10 @@ session::do_read()
         this->strand->wrap([self = shared_from_this(), buffer](boost::system::error_code ec, auto /*bytes_transferred*/)
         {
             self->record("do read callback");
+            if (self->opened_session)
+            {
+                LOG(debug) << "why are we reading from a session we opened?";
+            }
             self->activity = true;
 
             if(ec)
@@ -193,7 +203,10 @@ session::do_read()
                     self->record("do read callback failed because other than close");
                     LOG(error) << "websocket read failed: " << ec.message();
                 }
-                self->private_close();
+                if (ec != boost::beast::websocket::error::closed)
+                {
+                    self->private_close();
+                }
                 return;
             }
 
@@ -260,7 +273,10 @@ session::do_write()
                 }
 
                 self->write_queue.push_front(msg);
-                self->private_close();
+                if (ec != boost::beast::websocket::error::closed)
+                {
+                    self->private_close();
+                }
                 return;
             }
 
@@ -345,6 +361,8 @@ session::private_close()
                 }
             }));
     }
+
+    this->idle_timer->cancel();
 }
 
 bool

node/session.hpp

@@ -98,6 +98,10 @@ namespace bzn
         std::list<std::string> event_log;
         void record(std::string event);
 
+        bool opened_session = false;
+        bool accepted_session = false;
+
+
 
     };