pEp.foundation
/
pEpJSONServerAdapter
10
2
Fork 4
Code Issues 1 Pull Requests Releases 1 Wiki Activity

add logging and for_each() to SessionRegistry

JSON-155
Roker 2020-06-23 21:33:50 +02:00
parent a9d75e1fe4
commit 209ab659b2
2 changed files with 26 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
server/session_registry.cc
View File

@ -2,6 +2,12 @@
#include <sstream>
#include <pEp/call_with_lock.hh>
#include <pEp/status_to_string.hh>
#include "logger.hh"
namespace
{
Logger Log("SR");
}
// creates a PEP_SESSION if none yet exists for the given thread
@ -12,6 +18,7 @@ PEP_SESSION SessionRegistry::get(std::thread::id tid)
auto q = m.find(tid);
if(q != m.end())
{
Log.debug("get() returns %p.", (const void*)q->second);
return q->second;
}
@ -22,6 +29,7 @@ PEP_SESSION SessionRegistry::get(std::thread::id tid)
throw std::runtime_error("init() fails: " + pEp::status_to_string(status) );
}
m[tid] = session;
Log.debug("get() created new session at %p.", (const void*)session);
return session;
}
@ -32,8 +40,22 @@ void SessionRegistry::remove(std::thread::id tid)
const auto q = m.find(tid);
if(q != m.end())
{
Log.debug("remove() session at %p.", (const void*)q->second);
pEp::call_with_lock(&release, q->second);
m.erase(q);
}else{
Log.info("remove(): no session for this thread!");
}
}
void SessionRegistry::for_each(void(*function)(PEP_SESSION))
{
Lock L(_mtx);
Log.debug("for_each() on %zu session.", m.size());
for(const auto& e : m)
{
function(e.second);
}
}

4
server/session_registry.hh
View File

@ -21,6 +21,10 @@ public:
std::size_t size() const { return m.size(); }
bool empty() const { return m.empty(); }
// calls the given function (which might be a lambda or std::function<> or std::bind thingy)
// on each stored session.
void for_each(void(*function)(PEP_SESSION));
std::string to_string() const;
private: