pEpJSONServerAdapter/server/session_registry.cc

84 lines
1.9 KiB
C++
Raw Normal View History

2020-05-14 00:18:58 +02:00
#include "session_registry.hh"
#include <sstream>
#include <pEp/call_with_lock.hh>
#include <pEp/status_to_string.hh>
#include <pEp/Adapter.hh>
2020-05-14 00:18:58 +02:00
// creates a PEP_SESSION if none yet exists for the given thread
PEP_SESSION SessionRegistry::get(std::thread::id tid)
2020-05-14 00:18:58 +02:00
{
Lock L(_mtx);
auto q = m.find(tid);
if(q != m.end())
2020-05-14 00:18:58 +02:00
{
Log.debug("get() returns %p.", (const void*)q->second);
return q->second;
2020-05-14 00:18:58 +02:00
}
PEP_SESSION session = nullptr;
PEP_STATUS status = pEp::call_with_lock(&init, &session, mts, ise, pEp::Adapter::_ensure_passphrase);
2020-05-14 00:18:58 +02:00
if(status != PEP_STATUS_OK)
{
throw std::runtime_error("init() fails: " + pEp::status_to_string(status) );
}
m[tid] = session;
2020-06-25 12:58:54 +02:00
Log.debug("Apply %zu cached config values to new session.", cache.size());
for(const auto& e : cache)
{
Log.debug("\t %s", e.first.c_str());
e.second(session);
}
Log.debug("get() created new session at %p.", (const void*)session);
2020-05-14 00:18:58 +02:00
return session;
}
void SessionRegistry::remove(std::thread::id tid)
{
Lock L(_mtx);
const auto q = m.find(tid);
if(q != m.end())
{
Log.debug("remove() session at %p.", (const void*)q->second);
2020-05-14 00:18:58 +02:00
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);
2020-05-14 00:18:58 +02:00
}
}
2020-05-14 16:21:38 +02:00
2020-06-26 14:05:37 +02:00
void SessionRegistry::add_to_cache(const std::string& fn_name, const std::function<void(PEP_SESSION)>& func)
{
Lock L(_mtx);
2020-06-27 01:54:05 +02:00
Log.debug("add_to_cache(\"%s\")", fn_name.c_str());
2020-06-26 14:05:37 +02:00
cache[fn_name] = func;
}
2020-05-14 16:21:38 +02:00
std::string SessionRegistry::to_string() const
{
Lock L(_mtx);
std::stringstream ss;
ss << m.size() << " session" << (m.size()==1?"":"s") << " in registry" << (m.empty()?".\n":":\n");
for(const auto& e:m)
{
ss << "\t" << e.first << ": " << e.second << "\n";
}
return ss.str();
}