VFS_tcp_export_sessionManager.cpp

Go to the documentation of this file.

 
#include "VFS_tcp_export_sessionManager.h"
 
#include "VFS.h"
 
QMutex VFS_tcp_export_sessionManager::_lock;
QMap<QString, VFS_session *> VFS_tcp_export_sessionManager::_sessions;
QMap<QString, bool> VFS_tcp_export_sessionManager::_requests;
VFS_tcp_export_sessionManager VFS_tcp_export_sessionManager::_instance;
 
VFS_session *VFS_tcp_export_sessionManager::fetchSession(QString id)
{
        QMutexLocker l(&_lock);
 
        if (_sessions.contains(id))
                return _sessions[id];
 
        return nullptr;
}
 
bool VFS_tcp_export_sessionManager::registerSession(QString id, VFS_session *session)
{
        QMutexLocker l(&_lock);
 
        if (_requests.contains(id))
                _requests.remove(id);
 
        if (_sessions.contains(id))
                return false;
                
        _sessions[id] = session;
        
        connect( session, SIGNAL(finished(bool)), &_instance, SLOT(expireSession(bool)) );
        
        return true;
}
 
bool VFS_tcp_export_sessionManager::requestSession(QString id, VFS_tcp_export_client *client)
{
        QMutexLocker l(&_lock);
        
        if (!_requests.contains(id))
        {
                _requests[id] = true;
 
                VFS::LOG( QString("Issuing request for session: '%1'").arg(id), 9 );
 
                VFS_tcp_export_request *r = new VFS_tcp_export_request(client,client->_exportRoot);
                r->_id = POST_ID_SESSION_DATA;
                r->_metadata["sessionid"] = id;
                r->_success = true;     //to force include the metatdata
                r->execute();
                delete r;
                
                return true;
        }
        
        return false;
}
 
void VFS_tcp_export_sessionManager::expireSession(bool)
{
        //printf("would expire session: %p\n",sender());
        
        QObject *o = sender();
        VFS_session *s = dynamic_cast<VFS_session *>(o);
        
        if (s)
        {
                QMutexLocker l(&_lock);
                
                QString key = _sessions.key(s,"");
                
                if (key != "")
                {
                        _sessions.remove(key);
                        _requests.remove(key);
                        s->deleteLater();
                }
                else
                        printf("COULD NOT FIND KEY FOR %p.  Undefined behavior.\n", (void *) s);
        }
        //else
        //      printf("COULD NOT CAST TO VFS_SESSION.  Undefined behavior. %p\n",o);
}