summaryrefslogtreecommitdiffstats
path: root/virt
diff options
context:
space:
mode:
Diffstat (limited to 'virt')
-rw-r--r--virt/Makefile.am17
-rw-r--r--virt/virt.cc305
-rw-r--r--virt/virt.h55
-rw-r--r--virt/virt.protocol19
4 files changed, 396 insertions, 0 deletions
diff --git a/virt/Makefile.am b/virt/Makefile.am
new file mode 100644
index 0000000..5df86c7
--- /dev/null
+++ b/virt/Makefile.am
@@ -0,0 +1,17 @@
+## Makefile.am of kdebase/kioslave/tar
+
+INCLUDES = $(all_includes)
+AM_LDFLAGS = $(all_libraries) $(KDE_RPATH)
+METASOURCES = AUTO
+
+kde_module_LTLIBRARIES = kio_virt.la
+
+kio_virt_la_SOURCES = virt.cc
+kio_virt_la_LIBADD = $(LIB_KSYCOCA)
+kio_virt_la_LDFLAGS = $(all_libraries) -module $(KDE_PLUGIN)
+
+noinst_HEADERS = virt.h
+
+kdelnk_DATA = virt.protocol
+kdelnkdir = $(kde_servicesdir)
+
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;
+}
diff --git a/virt/virt.h b/virt/virt.h
new file mode 100644
index 0000000..04443de
--- /dev/null
+++ b/virt/virt.h
@@ -0,0 +1,55 @@
+/***************************************************************************
+ virt.h
+ -------------------
+ 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. *
+ * *
+ ***************************************************************************/
+
+#ifndef _VIRT_H
+#define _VIRT_H
+
+#include <sys/types.h>
+#include <qdict.h>
+#include <kconfig.h>
+#include <kio/slavebase.h>
+
+class VirtProtocol : public KIO::SlaveBase {
+public:
+ VirtProtocol( const QCString &pool, const QCString &app );
+ virtual ~VirtProtocol();
+
+ virtual void listDir ( const KURL & url );
+ virtual void stat ( const KURL & url );
+ virtual void get ( const KURL & url );
+ virtual void mkdir(const KURL& url,int permissions);
+ virtual void copy( const KURL &src, const KURL &dest, int permissions, bool overwrite );
+ virtual void del (KURL const & url, bool isFile);
+
+protected:
+ bool lock();
+ bool unlock();
+ bool save();
+ bool load();
+
+ void local_entry(const KURL& url,KIO::UDSEntry& entry);
+ bool addDir(QString& path);
+
+
+ static QDict<KURL::List> kioVirtDict;
+ static KConfig* kio_virt_db;
+
+ bool rewriteURL(const KURL&, KURL&);
+
+};
+
+#endif
diff --git a/virt/virt.protocol b/virt/virt.protocol
new file mode 100644
index 0000000..474a2d7
--- /dev/null
+++ b/virt/virt.protocol
@@ -0,0 +1,19 @@
+[Protocol]
+exec=kio_virt
+protocol=virt
+input=filesystem
+output=filesystem
+listing=Name,Type,Size,Date,AccessDate,Access,Owner,Group,Link
+reading=true
+writing=true
+makedir=true
+deleting=true
+linking=true
+moving=true
+Icon=system
+maxInstances=4
+copyFromFile=true
+#TODO DocPath=kioslave/virt.html
+Class=:local
+#deleteRecursive=true
+#fileNameUsedForCopying=Name