diff options
Diffstat (limited to 'virt/virt.cc')
| -rw-r--r-- | virt/virt.cc | 305 |
1 files changed, 305 insertions, 0 deletions
diff --git a/virt/virt.cc b/virt/virt.cc new file mode 100644 index 0000000..ad7aa5b --- /dev/null +++ b/virt/virt.cc @@ -0,0 +1,305 @@ +/*************************************************************************** + virt.cc + ------------------- + begin : Fri Dec 5 2003 + copyright : (C) 2003 by Shie Erlich & Rafi Yanai + email : + ***************************************************************************/ + +/*************************************************************************** + * * + * This program is free software; you can redistribute it and/or modify * + * it under the terms of the GNU General Public License as published by * + * the Free Software Foundation; either version 2 of the License, or * + * (at your option) any later version. * + * * + ***************************************************************************/ + +#include <sys/types.h> +#include <sys/stat.h> +#include <stdlib.h> +#include <unistd.h> + +#include <qfile.h> +#include <kurl.h> +#include <kdebug.h> +#include <klocale.h> +#include <kdeversion.h> +#include <kinstance.h> +#include <kmessagebox.h> + +#include "virt.h" + +using namespace KIO; + +#define VIRT_VFS_DB "virt_vfs.db" +#define VIRT_PROTOCOL "virt" + +#if KDE_IS_VERSION(3,4,0) +extern "C" { int KDE_EXPORT kdemain( int argc, char **argv ); } +#else +extern "C" { int kdemain( int argc, char **argv ); } +#endif + +#define KrDEBUG(X...){\ + FILE* f = fopen("/tmp/kio_virt.log","a+");\ + fprintf(f,X);\ + fclose(f);\ +} + +QDict<KURL::List> VirtProtocol::kioVirtDict; +KConfig* VirtProtocol::kio_virt_db; + +int kdemain( int argc, char **argv ) { + KInstance instance( "kio_virt" ); + + if ( argc != 4 ) { + fprintf( stderr, "Usage: kio_virt protocol domain-socket1 domain-socket2\n" ); + exit( -1 ); + } + + VirtProtocol slave( argv[ 2 ], argv[ 3 ] ); + slave.dispatchLoop(); + + return 0; +} + +VirtProtocol::VirtProtocol( const QCString &pool, const QCString &app ) : SlaveBase( "virt", pool, app ) { + kio_virt_db = new KConfig(VIRT_VFS_DB,false,"data"); +} + +VirtProtocol::~VirtProtocol() { + delete kio_virt_db; +} + +void VirtProtocol::del(KURL const & /*url */, bool /* isFile */ ){ +// KRDEBUG(url.path()); + + messageBox(KIO::SlaveBase::QuestionYesNo, + i18n(""), + i18n("Virtulal delete"), + i18n("remove from virtual space"), + i18n("really delete") + ); + + finished(); +} + +void VirtProtocol::copy( const KURL &src, const KURL &dest, int /* permissions */, bool /* overwrite */ ){ + QString path = dest.path( -1 ).mid( 1 ); + path = path.left(path.findRev("/")); + if ( path.isEmpty() ) path = "/"; + + if( addDir(path) ){ + kioVirtDict[ path ]->append(src); + save(); + } + + finished(); +} + +bool VirtProtocol::addDir(QString& path){ + + if( kioVirtDict[ path ] ) return true; + + QString updir; + if( !path.contains("/") ) updir = "/"; + else updir = path.left(path.findRev("/")); + QString name = path.mid(path.findRev("/")+1); + + if( addDir(updir) ){ + KURL url; + if( updir == "/" ) url = QString("virt:/")+name; + else url = QString("virt:/")+updir+"/"+name; + kioVirtDict[ updir ]->append( url ); + + KURL::List* temp = new KURL::List(); + kioVirtDict.replace( path, temp ); + + return true; + } + return false; +} + +void VirtProtocol::mkdir(const KURL& url,int){ + if( url.protocol() != VIRT_PROTOCOL ){ + redirection(url); + finished(); + return; + } + + QString path = url.path( -1 ).mid( 1 ); + if ( path.isEmpty() ) path = "/"; + + if( kioVirtDict[ path ] ){ + error( KIO::ERR_DIR_ALREADY_EXIST, url.path() ); + return; + } + + addDir(path); + + save(); + + finished(); +} + +void VirtProtocol::listDir( const KURL & url ) { + if( url.protocol() != VIRT_PROTOCOL ){ + redirection(url); + finished(); + return; + } + + load(); + + QString path = url.path( -1 ).mid( 1 ); + if ( path.isEmpty() ) path = "/"; + + KURL::List* urlList = kioVirtDict[ path ]; + if ( !urlList ) { + error(ERR_CANNOT_ENTER_DIRECTORY,url.path()); + return; + } + + UDSEntryList dirList; + KURL::List::iterator it; + for ( it = urlList->begin() ; it != urlList->end() ; ++it ) { + KURL entry_url = *it; + // translate url->UDS_ENTRY + UDSEntry entry; + if( entry_url.protocol() == VIRT_PROTOCOL ){ + local_entry(entry_url,entry); + } else { + UDSAtom atom; + + atom.m_uds = UDS_NAME; + atom.m_str = url.isLocalFile() ? url.path() : entry_url.prettyURL(); + entry.append(atom); + + atom.m_uds = UDS_URL; + atom.m_str = entry_url.url(); + entry.append(atom); + } + + dirList.append(entry); + } + + totalSize(dirList.size()); + listEntries(dirList); + + finished(); +} + +void VirtProtocol::stat( const KURL & url ) { + if( url.protocol() != VIRT_PROTOCOL ){ + redirection(url); + finished(); + return; + } + + UDSEntry entry; + local_entry(url,entry); + + statEntry(entry); + + finished(); +} + +void VirtProtocol::get( const KURL & url ) { + if( url.protocol() != VIRT_PROTOCOL ){ + redirection(url); + finished(); + return; + } + + finished(); +} + +bool VirtProtocol::rewriteURL(const KURL& /* src */, KURL&){ + return true; +} + +bool VirtProtocol::save(){ + lock(); + + KConfig* db = new KConfig(VIRT_VFS_DB,false,"data");; + + db->setGroup("virt_db"); + QDictIterator<KURL::List> it( kioVirtDict ); // See QDictIterator + for( ; it.current(); ++it ){ + KURL::List::iterator url; + QStringList entry; + for ( url = it.current()->begin() ; url != it.current()->end() ; ++url ) { + entry.append( (*url).url() ); + } + db->writeEntry(it.currentKey(),entry); + } + + db->sync(); + delete(db); + + unlock(); + + return true; +} + +bool VirtProtocol::load(){ + lock(); + + KConfig* db = new KConfig(VIRT_VFS_DB,false,"data"); + db->setGroup("virt_db"); + + QMap<QString, QString> map = db->entryMap("virt_db"); + QMap<QString, QString>::Iterator it; + KURL::List* urlList; + for ( it = map.begin(); it != map.end(); ++it ) { + urlList = new KURL::List( db->readListEntry(it.key()) ); + kioVirtDict.replace( it.key(),urlList ); + } + + if( !kioVirtDict["/" ]){ + urlList = new KURL::List(); + kioVirtDict.replace( "/", urlList ); + } + + unlock(); + + delete(db); + + return true; +} + +void VirtProtocol::local_entry(const KURL& url,UDSEntry& entry){ + QString path = url.path( -1 ).mid( 1 ); + if ( path.isEmpty() ) path = "/"; + + UDSAtom atom; + + atom.m_uds = UDS_NAME; + atom.m_str = url.fileName(); + entry.append(atom); + + atom.m_uds = UDS_URL; + atom.m_str = url.url(); + entry.append(atom); + + atom.m_uds = UDS_FILE_TYPE; + atom.m_long = S_IFDIR; + entry.append(atom); + + atom.m_uds = UDS_ACCESS; + atom.m_long = 0700; + entry.append(atom); + + atom.m_uds = UDS_MIME_TYPE; + atom.m_str = "inode/system_directory"; + entry.append(atom); +} + +bool VirtProtocol::lock(){ + return true; +} + +bool VirtProtocol::unlock(){ + return true; +} |