VFS_tcp_mount_directory.cpp

Go to the documentation of this file.

 
#include "VFS.h"
#include "VFS_tcp_mount_directory.h"
#include "VFS_tcp_mount.h"
#include "VFS_creator.h"
 
VFS_tcp_mount_directory::VFS_tcp_mount_directory(VFS_tcp_mount *mount)
: VFS_node_interface(mount)
{
}
 
QStringList VFS_tcp_mount_directory::provides()
{
        return QStringList();
}
 
VFS_node *VFS_tcp_mount_directory::create(QString type, QVariantMap env, QDomElement child)
{
        Q_UNUSED(type)
        Q_UNUSED(env)
        Q_UNUSED(child)
 
        return nullptr;
}
 
 
void VFS_tcp_mount_directory::registerDirectory(QJsonObject d)
{
        // Request a lock here so we know that all entries will be completed by this
        // call before another node tries to register its directory.
        QMutexLocker l(&VFS_creator::_pluginsLock);
 
        bool ok=false;
        QJsonObject::iterator it = d.begin();
        while (it != d.end())
        {
                if (!_directory.contains(it.key()))
                {
                        ok = VFS_creator::registerPlugin(it.key(),this);
                        if (!ok)
                        {       //VFS::WARN( QString("Could not register code for '%1' (1).  Skipping.").arg(it.key()),0,className());
                        }
                        else
                        {       VFS::LOG( QString("Registered code for '%1'.").arg(it.key()),9,_remoteNode->className());
                                _directory[it.key()] = true;
                        }
                }
                else
                        VFS::WARN( QString("Could not register code for '%1' (2).  Skipping.").arg(it.key()),0,_remoteNode->className());
                        
                it++;
        }
 
        // emit that the registry has been changed to notify other nodes
        // that they need to re-export the directory to any other upstream mounts
        emit VFS::root()->codeDirectoryUpdated();
}
 
 
void VFS_tcp_mount_directory::unregisterDirectory()
{
        bool ok=false;
        QString k;
        QStringList keys = _directory.keys();
        while (keys.length())
        {
                k = keys.takeFirst();
                ok = VFS_creator::unregisterPlugin(k);
                if (!ok)
                {       VFS::WARN( QString("Could not unregister code for '%1'.").arg(k),0,_remoteNode->className());
                }
                else
                {       _directory.remove(k);
                        VFS::LOG( QString("Unregistered code for '%1'.").arg(k),9,_remoteNode->className());
                }
        }
}