From 6cf321ceb470eb8d1673330a981be146d61a30f0 Mon Sep 17 00:00:00 2001 From: Brad Arant Date: Wed, 9 Feb 2022 14:46:52 +0000 Subject: [PATCH] Work son subscriptions. --- Socket.cpp | 1 - SubscriptionManager.cpp | 3 ++- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/Socket.cpp b/Socket.cpp index c065148..c372090 100644 --- a/Socket.cpp +++ b/Socket.cpp @@ -173,7 +173,6 @@ namespace core { reset = false; // if(!needsToWrite()) delete this; - } } diff --git a/SubscriptionManager.cpp b/SubscriptionManager.cpp index 93455b6..f315d7d 100644 --- a/SubscriptionManager.cpp +++ b/SubscriptionManager.cpp @@ -17,7 +17,7 @@ namespace core { countSubscribed += (*subscription).second->unsubscribe(session); if((*subscription).second->owner == &session) { subscription = subscriptions.erase(subscription); - delete (*subscription).second; +// delete (*subscription).second; ++countPublished; } else ++subscription; @@ -54,6 +54,7 @@ namespace core { } else if(request[0].equals("unsubscribe")) { subscription->unsubscribe(session); } else if(request[0].equals("event")) { +// coreutils::Log(coreutils::LOG_DEBUG_2) << "request: [" << request << "]."; if(subscription->owner == &session) { std::stringstream out; subscription->process(request, out);