Removed the last commit..

Tracking of memory in use should be done through the share ptr's destructor

Author: smasherprog

include/WS_Lite.h

@@ -167,8 +167,6 @@ namespace WS_LITE {
         virtual bool is_v4() const = 0;
         virtual bool is_v6() const = 0;
         virtual bool is_loopback() const = 0;
-        // this will return the amount of data queued up but has not yet been submitted to the OS to be sent
-        virtual size_t get_DataPending() const = 0;
         virtual void send(const WSMessage &msg, bool compressmessage) = 0;
         // send a close message and close the socket
         virtual void close(unsigned short code = 1000, const std::string &msg = "") = 0;
@@ -188,8 +186,6 @@ namespace WS_LITE {
         virtual void set_WriteTimeout(std::chrono::seconds seconds) = 0;
         // get the current write timeout in seconds
         virtual std::chrono::seconds get_WriteTimeout() = 0;
-        // this will return the amount of data queued up but has not yet been submitted to the OS to be sent
-        virtual size_t get_DataPending() const = 0;
     };
     class WS_LITE_EXTERN IWSListener_Configuration {
       public:

include/internal/DataStructures.h

@@ -104,7 +104,6 @@ namespace WS_LITE {
         std::chrono::seconds WriteTimeout = std::chrono::seconds(30);
         size_t MaxPayload = 1024 * 1024 * 20; // 20 MB
         bool TLSEnabled = false;
-        size_t DataPending = 0;
 
         std::function<void(const std::shared_ptr<IWSocket> &, const std::unordered_map<std::string, std::string> &)> onConnection;
         std::function<void(const std::shared_ptr<IWSocket> &, const WSMessage &)> onMessage;
@@ -164,7 +163,6 @@ namespace WS_LITE {
                     sendclosemessage<isServer>(p, self, code, msg);
             }
         }
-        virtual size_t get_DataPending() const override { return DataPending; }
         void canceltimers()
         {
             std::error_code ec;
@@ -189,7 +187,6 @@ namespace WS_LITE {
         asio::basic_waitable_timer<std::chrono::steady_clock> write_deadline;
         asio::strand strand;
         std::deque<SendQueueItem> SendMessageQueue;
-        size_t DataPending = 0;
     };
 
 } // namespace WS_LITE

include/internal/WebSocketProtocol.h

@@ -202,8 +202,6 @@ namespace WS_LITE {
                 if (msg.code == OpCode::CLOSE) {
                     socket->SocketStatus_ = SocketStatus::CLOSING;
                 }
-                socket->DataPending += msg.len;
-                socket->Parent->DataPending += msg.len;
                 socket->SendMessageQueue.emplace_back(SendQueueItem{msg, compressmessage});
                 SL::WS_LITE::startwrite<isServer>(parent, socket);
             }
@@ -257,10 +255,7 @@ namespace WS_LITE {
                                   return handleclose(parent, socket, 1002, "write header failed " + ec.message());
                               }
                               assert(msg.len == bytes_transferred);
-                              socket->DataPending -= msg.len;
-                              socket->Parent->DataPending -= msg.len;
                               startwrite<isServer>(parent, socket);
-
                           }));
     }
 
@@ -557,7 +552,6 @@ namespace WS_LITE {
         virtual std::chrono::seconds get_ReadTimeout() override;
         virtual void set_WriteTimeout(std::chrono::seconds seconds) override;
         virtual std::chrono::seconds get_WriteTimeout() override;
-        virtual size_t get_DataPending() const override { return Impl_->DataPending; }
     };
     class WSListener : public IWSHub {
         std::shared_ptr<WSContextImpl> Impl_;
@@ -571,7 +565,6 @@ namespace WS_LITE {
         virtual std::chrono::seconds get_ReadTimeout() override;
         virtual void set_WriteTimeout(std::chrono::seconds seconds) override;
         virtual std::chrono::seconds get_WriteTimeout() override;
-        virtual size_t get_DataPending() const override { return Impl_->DataPending; }
     };
 
     class WSListener_Configuration : public IWSListener_Configuration {