Rename kioslaves

1 files changed, 1169 insertions, 0 deletions

diff --git a/tdeioslave/floppy/tdeio_floppy.cpp b/tdeioslave/floppy/tdeio_floppy.cpp
new file mode 100644
index 000000000..0e576e472
--- /dev/null
+++ b/tdeioslave/floppy/tdeio_floppy.cpp
@@ -0,0 +1,1169 @@
+/*  This file is part of the KDE project
+
+    Copyright (C) 2000 Alexander Neundorf <neundorf@kde.org>
+
+    This library is free software; you can redistribute it and/or
+    modify it under the terms of the GNU Library General Public
+    License as published by the Free Software Foundation; either
+    version 2 of the License, or (at your option) any later version.
+
+    This library is distributed in the hope that it will be useful,
+    but WITHOUT ANY WARRANTY; without even the implied warranty of
+    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
+    Library General Public License for more details.
+
+    You should have received a copy of the GNU Library General Public License
+    along with this library; see the file COPYING.LIB.  If not, write to
+    the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
+    Boston, MA 02110-1301, USA.
+*/
+
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
+#ifdef HAVE_STRING_H
+#include <string.h>
+#else
+#include <strings.h>
+#endif
+
+#include <errno.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <sys/stat.h>
+#include <time.h>
+#include <sys/time.h>
+#include <sys/types.h>
+
+#include <tqtextstream.h>
+#include <tqcstring.h>
+#include <tqfile.h>
+
+#include "tdeio_floppy.h"
+
+#include <kinstance.h>
+#include <kdebug.h>
+#include <tdeio/global.h>
+#include <klocale.h>
+
+using namespace TDEIO;
+
+extern "C" { KDE_EXPORT int kdemain(int argc, char **argv); }
+
+int kdemain( int argc, char **argv )
+{
+  TDEInstance instance( "tdeio_floppy" );
+
+  if (argc != 4)
+  {
+     fprintf(stderr, "Usage: tdeio_floppy protocol domain-socket1 domain-socket2\n");
+     exit(-1);
+  }
+  kdDebug(7101) << "Floppy: kdemain: starting" << endl;
+
+  FloppyProtocol slave(argv[2], argv[3]);
+  slave.dispatchLoop();
+  return 0;
+}
+
+void getDriveAndPath(const TQString& path, TQString& drive, TQString& rest)
+{
+   drive=TQString::null;
+   rest=TQString::null;
+   TQStringList list=TQStringList::split("/",path);
+   for (TQStringList::Iterator it=list.begin(); it!=list.end(); it++)
+   {
+      if (it==list.begin())
+         drive=(*it)+":";
+      else
+         rest=rest+"/"+(*it);
+   }
+}
+
+FloppyProtocol::FloppyProtocol (const TQCString &pool, const TQCString &app )
+:SlaveBase( "floppy", pool, app )
+,m_mtool(0)
+,m_stdoutBuffer(0)
+,m_stderrBuffer(0)
+,m_stdoutSize(0)
+,m_stderrSize(0)
+{
+   kdDebug(7101)<<"Floppy::Floppy: -"<<pool<<"-"<<endl;
+}
+
+FloppyProtocol::~FloppyProtocol()
+{
+   delete [] m_stdoutBuffer;
+   delete [] m_stderrBuffer;
+   delete m_mtool;
+   m_mtool=0;
+   m_stdoutBuffer=0;
+   m_stderrBuffer=0;
+}
+
+int FloppyProtocol::readStdout()
+{
+   //kdDebug(7101)<<"Floppy::readStdout"<<endl;
+   if (m_mtool==0) return 0;
+
+   char buffer[16*1024];
+   int length=::read(m_mtool->stdoutFD(),buffer,16*1024);
+   if (length<=0) return 0;
+
+   //+1 gives us room for a terminating 0
+   char *newBuffer=new char[length+m_stdoutSize+1];
+   kdDebug(7101)<<"Floppy::readStdout(): length: "<<length<<" m_tsdoutSize: "<<m_stdoutSize<<" +1="<<length+m_stdoutSize+1<<endl;
+   if (m_stdoutBuffer!=0)
+   {
+      memcpy(newBuffer, m_stdoutBuffer, m_stdoutSize);
+   }
+   memcpy(newBuffer+m_stdoutSize, buffer, length);
+   m_stdoutSize+=length;
+   newBuffer[m_stdoutSize]='\0';
+
+   delete [] m_stdoutBuffer;
+   m_stdoutBuffer=newBuffer;
+   //kdDebug(7101)<<"Floppy::readStdout(): -"<<m_stdoutBuffer<<"-"<<endl;
+
+   //kdDebug(7101)<<"Floppy::readStdout ends"<<endl;
+   return length;
+}
+
+int FloppyProtocol::readStderr()
+{
+   //kdDebug(7101)<<"Floppy::readStderr"<<endl;
+   if (m_mtool==0) return 0;
+
+   /*struct timeval tv;
+   tv.tv_sec=0;
+   tv.tv_usec=1000*300;
+   ::select(0,0,0,0,&tv);*/
+
+   char buffer[16*1024];
+   int length=::read(m_mtool->stderrFD(),buffer,16*1024);
+   kdDebug(7101)<<"Floppy::readStderr(): read "<<length<<" bytes"<<endl;
+   if (length<=0) return 0;
+
+   //+1 gives us room for a terminating 0
+   char *newBuffer=new char[length+m_stderrSize+1];
+   memcpy(newBuffer, m_stderrBuffer, m_stderrSize);
+   memcpy(newBuffer+m_stderrSize, buffer, length);
+   m_stderrSize+=length;
+   newBuffer[m_stderrSize]='\0';
+   delete [] m_stderrBuffer;
+   m_stderrBuffer=newBuffer;
+   kdDebug(7101)<<"Floppy::readStderr(): -"<<m_stderrBuffer<<"-"<<endl;
+
+   return length;
+}
+
+void FloppyProtocol::clearBuffers()
+{
+   kdDebug(7101)<<"Floppy::clearBuffers()"<<endl;
+   m_stdoutSize=0;
+   m_stderrSize=0;
+   delete [] m_stdoutBuffer;
+   m_stdoutBuffer=0;
+   delete [] m_stderrBuffer;
+   m_stderrBuffer=0;
+   //kdDebug(7101)<<"Floppy::clearBuffers() ends"<<endl;
+}
+
+void FloppyProtocol::terminateBuffers()
+{
+   //kdDebug(7101)<<"Floppy::terminateBuffers()"<<endl;
+   //append a terminating 0 to be sure
+   if (m_stdoutBuffer!=0)
+   {
+      m_stdoutBuffer[m_stdoutSize]='\0';
+   }
+   if (m_stderrBuffer!=0)
+   {
+      m_stderrBuffer[m_stderrSize]='\0';
+   }
+   //kdDebug(7101)<<"Floppy::terminateBuffers() ends"<<endl;
+}
+
+bool FloppyProtocol::stopAfterError(const KURL& url, const TQString& drive)
+{
+   if (m_stderrSize==0)
+      return true;
+   //m_stderrBuffer[m_stderrSize]='\0';
+
+   TQString outputString(m_stderrBuffer);
+   TQTextIStream output(&outputString);
+   TQString line=output.readLine();
+   kdDebug(7101)<<"line: -"<<line<<"-"<<endl;
+   if (line.find("resource busy") > -1)
+   {
+      error( TDEIO::ERR_SLAVE_DEFINED, i18n("Could not access drive %1.\nThe drive is still busy.\nWait until it is inactive and then try again.").arg(drive));
+   }
+   else if ((line.find("Disk full") > -1) || (line.find("No free cluster") > -1))
+   {
+      error( TDEIO::ERR_SLAVE_DEFINED, i18n("Could not write to file %1.\nThe disk in drive %2 is probably full.").arg(url.prettyURL(),drive));
+   }
+   //file not found
+   else if (line.find("not found") > -1)
+   {
+      error( TDEIO::ERR_DOES_NOT_EXIST, url.prettyURL());
+   }
+   //no disk
+   else if (line.find("not configured") > -1)
+   {
+      error( TDEIO::ERR_SLAVE_DEFINED, i18n("Could not access %1.\nThere is probably no disk in the drive %2").arg(url.prettyURL(),drive));
+   }
+   else if (line.find("No such device") > -1)
+   {
+      error( TDEIO::ERR_SLAVE_DEFINED, i18n("Could not access %1.\nThere is probably no disk in the drive %2 or you do not have enough permissions to access the drive.").arg(url.prettyURL(),drive));
+   }
+   else if (line.find("not supported") > -1)
+   {
+      error( TDEIO::ERR_SLAVE_DEFINED, i18n("Could not access %1.\nThe drive %2 is not supported.").arg(url.prettyURL(),drive));
+   }
+   //not supported or no such drive
+   else if (line.find("Permission denied") > -1)
+   {
+      error( TDEIO::ERR_SLAVE_DEFINED, i18n("Could not access %1.\nMake sure the floppy in drive %2 is a DOS-formatted floppy disk \nand that the permissions of the device file (e.g. /dev/fd0) are set correctly (e.g. rwxrwxrwx).").arg(url.prettyURL(),drive));
+   }
+   else if (line.find("non DOS media") > -1)
+   {
+      error( TDEIO::ERR_SLAVE_DEFINED, i18n("Could not access %1.\nThe disk in drive %2 is probably not a DOS-formatted floppy disk.").arg(url.prettyURL(),drive));
+   }
+   else if (line.find("Read-only") > -1)
+   {
+      error( TDEIO::ERR_SLAVE_DEFINED, i18n("Access denied.\nCould not write to %1.\nThe disk in drive %2 is probably write-protected.").arg(url.prettyURL(),drive));
+   }
+   else if ((outputString.find("already exists") > -1) || (outputString.find("Skipping ") > -1))
+   {
+      error( TDEIO::ERR_FILE_ALREADY_EXIST,url.prettyURL());
+      //return false;
+   }
+   else if (outputString.find("could not read boot sector") > -1)
+   {
+      error( TDEIO::ERR_SLAVE_DEFINED, i18n("Could not read boot sector for %1.\nThere is probably not any disk in drive %2.").arg(url.prettyURL(),drive));
+      //return false;
+   }
+   else
+   {
+      error( TDEIO::ERR_UNKNOWN, outputString);
+   }
+   return true;
+}
+
+void FloppyProtocol::listDir( const KURL& _url)
+{
+   kdDebug(7101)<<"Floppy::listDir() "<<_url.path()<<endl;
+   KURL url(_url);
+   TQString path(url.path());
+
+   if ((path.isEmpty()) || (path=="/"))
+   {
+      url.setPath("/a/");
+      redirection(url);
+      finished();
+      return;
+   }
+   TQString drive;
+   TQString floppyPath;
+   getDriveAndPath(path,drive,floppyPath);
+
+   TQStringList args;
+
+   args<<"mdir"<<"-a"<<(drive+floppyPath);
+   if (m_mtool!=0)
+      delete m_mtool;
+   m_mtool=new Program(args);
+
+   clearBuffers();
+
+   if (!m_mtool->start())
+   {
+      delete m_mtool;
+      m_mtool=0;
+      errorMissingMToolsProgram("mdir");
+      return;
+   }
+
+   int result;
+   bool loopFinished(false);
+   bool errorOccured(false);
+   do
+   {
+      bool stdoutEvent;
+      bool stderrEvent;
+      result=m_mtool->select(1,0,stdoutEvent, stderrEvent);
+      if (stdoutEvent)
+         if (readStdout()==0)
+            loopFinished=true;
+      if (stderrEvent)
+      {
+         if (readStderr()==0)
+            loopFinished=true;
+         else
+            if (stopAfterError(url,drive))
+            {
+               loopFinished=true;
+               errorOccured=true;
+            }
+      }
+   } while (!loopFinished);
+
+   delete m_mtool;
+   m_mtool=0;
+   //now mdir has finished
+   //let's parse the output
+   terminateBuffers();
+
+   if (errorOccured)
+      return;
+
+   TQString outputString(m_stdoutBuffer);
+   TQTextIStream output(&outputString);
+   TQString line;
+
+   int totalNumber(0);
+   int mode(0);
+   UDSEntry entry;
+
+   while (!output.atEnd())
+   {
+      line=output.readLine();
+      kdDebug(7101)<<"Floppy::listDir(): line: -"<<line<<"- length: "<<line.length()<<endl;
+
+      if (mode==0)
+      {
+         if (line.isEmpty())
+         {
+            kdDebug(7101)<<"Floppy::listDir(): switching to mode 1"<<endl;
+            mode=1;
+         }
+      }
+      else if (mode==1)
+      {
+         if (line[0]==' ')
+         {
+            kdDebug(7101)<<"Floppy::listDir(): ende"<<endl;
+            totalSize(totalNumber);
+            break;
+         }
+         entry.clear();
+         StatInfo info=createStatInfo(line);
+         if (info.isValid)
+         {
+            createUDSEntry(info,entry);
+            //kdDebug(7101)<<"Floppy::listDir(): creating UDSEntry"<<endl;
+            listEntry( entry, false);
+            totalNumber++;
+         }
+      }
+   }
+   listEntry( entry, true ); // ready
+   finished();
+   //kdDebug(7101)<<"Floppy::listDir() ends"<<endl;
+}
+
+void FloppyProtocol::errorMissingMToolsProgram(const TQString& name)
+{
+     error(TDEIO::ERR_SLAVE_DEFINED,i18n("Could not start program \"%1\".\nEnsure that the mtools package is installed correctly on your system.").arg(name));
+ }
+
+void FloppyProtocol::createUDSEntry(const StatInfo& info, UDSEntry& entry)
+{
+   UDSAtom atom;
+   atom.m_uds = TDEIO::UDS_NAME;
+   atom.m_str = info.name;
+   entry.append( atom );
+
+   atom.m_uds = TDEIO::UDS_SIZE;
+   atom.m_long = info.size;
+   entry.append(atom);
+
+   atom.m_uds = TDEIO::UDS_MODIFICATION_TIME;
+   atom.m_long = info.time;
+   entry.append( atom );
+
+   atom.m_uds = TDEIO::UDS_ACCESS;
+   atom.m_long=info.mode;
+   entry.append( atom );
+
+   atom.m_uds = TDEIO::UDS_FILE_TYPE;
+   atom.m_long =(info.isDir?S_IFDIR:S_IFREG);
+   entry.append( atom );
+}
+
+StatInfo FloppyProtocol::createStatInfo(const TQString line, bool makeStat, const TQString& dirName)
+{
+   //kdDebug(7101)<<"Floppy::createUDSEntry()"<<endl;
+   TQString name;
+   TQString size;
+   bool isDir(false);
+   TQString day,month, year;
+   TQString hour, minute;
+   StatInfo info;
+
+   if (line.length()==41)
+   {
+      int nameLength=line.find(' ');
+      kdDebug(7101)<<"Floppy::createStatInfo: line find: "<<nameLength <<"= -"<<line<<"-"<<endl;
+      if (nameLength>0)
+      {
+         name=line.mid(0,nameLength);
+         TQString ext=line.mid(9,3);
+         ext=ext.stripWhiteSpace();
+         if (!ext.isEmpty())
+            name+="."+ext;
+      }
+      kdDebug(7101)<<"Floppy::createStatInfo() name 8.3= -"<<name<<"-"<<endl;
+   }
+   else if (line.length()>41)
+   {
+      name=line.mid(42);
+      kdDebug(7101)<<"Floppy::createStatInfo() name vfat: -"<<name<<"-"<<endl;
+   }
+   if ((name==".") || (name==".."))
+   {
+      if (makeStat)
+         name=dirName;
+      else
+      {
+         info.isValid=false;
+         return info;
+      }
+   }
+
+   if (line.mid(13,5)=="<DIR>")
+   {
+      //kdDebug(7101)<<"Floppy::createUDSEntry() isDir"<<endl;
+      size="1024";
+      isDir=true;
+   }
+   else
+   {
+      size=line.mid(13,9);
+      //kdDebug(7101)<<"Floppy::createUDSEntry() size: -"<<size<<"-"<<endl;
+   }
+
+        //TEEKANNE JPG     70796 01-02-2003  17:47  Teekanne.jpg
+   if (line[25]=='-')
+   {
+      month=line.mid(23,2);
+      day=line.mid(26,2);
+      year=line.mid(29,4);
+   }
+   else //SETUP    PKG      1019 1997-09-25  10:31  setup.pkg
+   {
+      year=line.mid(23,4);
+      month=line.mid(28,2);
+      day=line.mid(31,2);
+   }
+   hour=line.mid(35,2);
+   minute=line.mid(38,2);
+   //kdDebug(7101)<<"Floppy::createUDSEntry() day: -"<<day<<"-"<<month<<"-"<<year<<"- -"<<hour<<"-"<<minute<<"-"<<endl;
+
+   if (name.isEmpty())
+   {
+      info.isValid=false;
+      return info;
+   }
+
+   info.name=name;
+   info.size=size.toInt();
+
+   TQDateTime date(TQDate(year.toInt(),month.toInt(),day.toInt()),TQTime(hour.toInt(),minute.toInt()));
+   info.time=date.toTime_t();
+
+   if (isDir)
+      info.mode = S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH| S_IWOTH|S_IWGRP|S_IWUSR  ;
+   else
+      info.mode = S_IRUSR | S_IRGRP | S_IROTH| S_IWOTH|S_IWGRP|S_IWUSR;
+
+   info.isDir=isDir;
+
+   info.isValid=true;
+   //kdDebug(7101)<<"Floppy::createUDSEntry() ends"<<endl;
+   return info;
+}
+
+StatInfo FloppyProtocol::_stat(const KURL& url)
+{
+   StatInfo info;
+
+   TQString path(url.path());
+   TQString drive;
+   TQString floppyPath;
+   getDriveAndPath(path,drive,floppyPath);
+
+   if (floppyPath.isEmpty())
+   {
+      kdDebug(7101)<<"Floppy::_stat(): floppyPath.isEmpty()"<<endl;
+      info.name=path;
+      info.size=1024;
+      info.time=0;
+      info.mode=S_IRUSR | S_IXUSR | S_IRGRP | S_IXGRP | S_IROTH | S_IXOTH| S_IWOTH|S_IWGRP|S_IWUSR;
+      info.isDir=true;
+      info.isValid=true;
+
+      return info;
+   }
+
+   //kdDebug(7101)<<"Floppy::_stat(): delete m_mtool"<<endl;
+   if (m_mtool!=0)
+      delete m_mtool;
+
+   TQStringList args;
+   args<<"mdir"<<"-a"<<(drive+floppyPath);
+
+   //kdDebug(7101)<<"Floppy::_stat(): create m_mtool"<<endl;
+   m_mtool=new Program(args);
+
+   if (!m_mtool->start())
+   {
+      delete m_mtool;
+      m_mtool=0;
+      errorMissingMToolsProgram("mdir");
+      return info;
+   }
+
+
+   clearBuffers();
+
+   int result;
+   bool loopFinished(false);
+   bool errorOccured(false);
+   do
+   {
+      bool stdoutEvent;
+      bool stderrEvent;
+      result=m_mtool->select(1,0,stdoutEvent, stderrEvent);
+      if (stdoutEvent)
+         if (readStdout()==0)
+            loopFinished=true;
+      if (stderrEvent)
+      {
+         if (readStderr()==0)
+            loopFinished=true;
+         else
+            if (stopAfterError(url,drive))
+            {
+               loopFinished=true;
+               errorOccured=true;
+            }
+      }
+   } while (!loopFinished);
+
+   //kdDebug(7101)<<"Floppy::_stat(): delete m_mtool"<<endl;
+   delete m_mtool;
+   m_mtool=0;
+   //now mdir has finished
+   //let's parse the output
+   terminateBuffers();
+
+   if (errorOccured)
+   {
+      info.isValid=false;
+      return info;
+   }
+
+   if (m_stdoutSize==0)
+   {
+      info.isValid=false;
+      error( TDEIO::ERR_COULD_NOT_STAT, url.prettyURL());
+      return info;
+   }
+
+   kdDebug(7101)<<"Floppy::_stat(): parse stuff"<<endl;
+   TQString outputString(m_stdoutBuffer);
+   TQTextIStream output(&outputString);
+   TQString line;
+   for (int lineNumber=0; !output.atEnd(); lineNumber++)
+   {
+      line=output.readLine();
+      if ( (lineNumber<3) || (line.isEmpty()) )
+         continue;
+      StatInfo info=createStatInfo(line,true,url.fileName());
+      if (info.isValid==false)
+         error( TDEIO::ERR_COULD_NOT_STAT, url.prettyURL());
+      return info;
+   }
+   if (info.isValid==false)
+      error( TDEIO::ERR_COULD_NOT_STAT, url.prettyURL());
+   return info;
+}
+
+int FloppyProtocol::freeSpace(const KURL& url)
+{
+   TQString path(url.path());
+   TQString drive;
+   TQString floppyPath;
+   getDriveAndPath(path,drive,floppyPath);
+
+   //kdDebug(7101)<<"Floppy::freeSpace(): delete m_mtool"<<endl;
+   if (m_mtool!=0)
+      delete m_mtool;
+
+   TQStringList args;
+   args<<"mdir"<<"-a"<<drive;
+
+   //kdDebug(7101)<<"Floppy::freeSpace(): create m_mtool"<<endl;
+   m_mtool=new Program(args);
+
+   if (!m_mtool->start())
+   {
+      delete m_mtool;
+      m_mtool=0;
+      errorMissingMToolsProgram("mdir");
+      return -1;
+   }
+
+
+   clearBuffers();
+
+   int result;
+   bool loopFinished(false);
+   bool errorOccured(false);
+   do
+   {
+      bool stdoutEvent;
+      bool stderrEvent;
+      result=m_mtool->select(1,0,stdoutEvent, stderrEvent);
+      if (stdoutEvent)
+         if (readStdout()==0)
+            loopFinished=true;
+      if (stderrEvent)
+      {
+         if (readStderr()==0)
+            loopFinished=true;
+         else
+            if (stopAfterError(url,drive))
+            {
+               loopFinished=true;
+               errorOccured=true;
+            }
+      }
+   } while (!loopFinished);
+
+   //kdDebug(7101)<<"Floppy::freeSpace(): delete m_mtool"<<endl;
+   delete m_mtool;
+   m_mtool=0;
+   //now mdir has finished
+   //let's parse the output
+   terminateBuffers();
+
+   if (errorOccured)
+   {
+      return -1;
+   }
+
+   if (m_stdoutSize==0)
+   {
+      error( TDEIO::ERR_COULD_NOT_STAT, url.prettyURL());
+      return -1;
+   }
+
+   kdDebug(7101)<<"Floppy::freeSpace(): parse stuff"<<endl;
+   TQString outputString(m_stdoutBuffer);
+   TQTextIStream output(&outputString);
+   TQString line;
+   int lineNumber(0);
+   while (!output.atEnd())
+   {
+      line=output.readLine();
+      if (line.find("bytes free")==36)
+      {
+         TQString tmp=line.mid(24,3);
+         tmp=tmp.stripWhiteSpace();
+         tmp+=line.mid(28,3);
+         tmp=tmp.stripWhiteSpace();
+         tmp+=line.mid(32,3);
+         tmp=tmp.stripWhiteSpace();
+
+         return tmp.toInt();
+      }
+      lineNumber++;
+   }
+   return -1;
+}
+
+void FloppyProtocol::stat( const KURL & _url)
+{
+   kdDebug(7101)<<"Floppy::stat() "<<_url.path()<<endl;
+   KURL url(_url);
+   TQString path(url.path());
+
+   if ((path.isEmpty()) || (path=="/"))
+   {
+      url.setPath("/a/");
+      redirection(url);
+      finished();
+      return;
+   }
+   StatInfo info=this->_stat(url);
+   if (info.isValid)
+   {
+      UDSEntry entry;
+      createUDSEntry(info,entry);
+      statEntry( entry );
+      finished();
+      //kdDebug(7101)<<"Floppy::stat(): ends"<<endl;
+      return;
+   }
+   //otherwise the error() was already reported in _stat()
+}
+
+void FloppyProtocol::mkdir( const KURL& url, int)
+{
+   kdDebug(7101)<<"FloppyProtocol::mkdir()"<<endl;
+   TQString path(url.path());
+
+   if ((path.isEmpty()) || (path=="/"))
+   {
+      KURL newUrl(url);
+      newUrl.setPath("/a/");
+      redirection(newUrl);
+      finished();
+      return;
+   }
+   TQString drive;
+   TQString floppyPath;
+   getDriveAndPath(path,drive,floppyPath);
+   if (floppyPath.isEmpty())
+   {
+      finished();
+      return;
+   }
+   if (m_mtool!=0)
+      delete m_mtool;
+   //kdDebug(7101)<<"Floppy::stat(): create args"<<endl;
+   TQStringList args;
+
+   args<<"mmd"<<(drive+floppyPath);
+   kdDebug(7101)<<"Floppy::mkdir(): executing: mmd -"<<(drive+floppyPath)<<"-"<<endl;
+
+   m_mtool=new Program(args);
+   if (!m_mtool->start())
+   {
+      delete m_mtool;
+      m_mtool=0;
+      errorMissingMToolsProgram("mmd");
+      return;
+   }
+
+
+   clearBuffers();
+   int result;
+   bool loopFinished(false);
+   bool errorOccured(false);
+   do
+   {
+      bool stdoutEvent;
+      bool stderrEvent;
+      result=m_mtool->select(1,0,stdoutEvent, stderrEvent);
+      if (stdoutEvent)
+         if (readStdout()==0)
+            loopFinished=true;
+      if (stderrEvent)
+      {
+         if (readStderr()==0)
+            loopFinished=true;
+         else
+            if (stopAfterError(url,drive))
+            {
+               loopFinished=true;
+               errorOccured=true;
+            }
+      }
+   } while (!loopFinished);
+
+   delete m_mtool;
+   m_mtool=0;
+   terminateBuffers();
+   if (errorOccured)
+      return;
+   finished();
+}
+
+void FloppyProtocol::del( const KURL& url, bool isfile)
+{
+   kdDebug(7101)<<"FloppyProtocol::del()"<<endl;
+   TQString path(url.path());
+
+   if ((path.isEmpty()) || (path=="/"))
+   {
+      KURL newUrl(url);
+      newUrl.setPath("/a/");
+      redirection(newUrl);
+      finished();
+      return;
+   }
+   TQString drive;
+   TQString floppyPath;
+   getDriveAndPath(path,drive,floppyPath);
+   if (floppyPath.isEmpty())
+   {
+      finished();
+      return;
+   }
+
+   if (m_mtool!=0)
+      delete m_mtool;
+   //kdDebug(7101)<<"Floppy::stat(): create args"<<endl;
+   TQStringList args;
+   
+   bool usingmdel;
+
+   if (isfile)
+   {
+      args<<"mdel"<<(drive+floppyPath);
+      usingmdel=true;
+   }
+   else
+   {
+      args<<"mrd"<<(drive+floppyPath);
+      usingmdel=false;
+   }
+
+   kdDebug(7101)<<"Floppy::del(): executing: " << (usingmdel ? TQString("mdel") : TQString("mrd") ) << "-"<<(drive+floppyPath)<<"-"<<endl;
+
+   m_mtool=new Program(args);
+   if (!m_mtool->start())
+   {
+      delete m_mtool;
+      m_mtool=0;
+      errorMissingMToolsProgram(usingmdel ? TQString("mdel") : TQString("mrd"));
+      return;
+   }
+
+
+   clearBuffers();
+   int result;
+   bool loopFinished(false);
+   bool errorOccured(false);
+   do
+   {
+      bool stdoutEvent;
+      bool stderrEvent;
+      result=m_mtool->select(1,0,stdoutEvent, stderrEvent);
+      if (stdoutEvent)
+         if (readStdout()==0)
+            loopFinished=true;
+      if (stderrEvent)
+      {
+         if (readStderr()==0)
+            loopFinished=true;
+         else
+            if (stopAfterError(url,drive))
+            {
+               loopFinished=true;
+               errorOccured=true;
+            }
+      }
+   } while (!loopFinished);
+
+   delete m_mtool;
+   m_mtool=0;
+   terminateBuffers();
+   if (errorOccured)
+      return;
+   finished();
+}
+
+void FloppyProtocol::rename( const KURL &src, const KURL &dest, bool _overwrite )
+{
+   TQString srcPath(src.path());
+   TQString destPath(dest.path());
+
+   kdDebug(7101)<<"Floppy::rename() -"<<srcPath<<"- to -"<<destPath<<"-"<<endl;
+
+   if ((srcPath.isEmpty()) || (srcPath=="/"))
+      srcPath="/a/";
+
+   if ((destPath.isEmpty()) || (destPath=="/"))
+      destPath="/a/";
+
+   TQString srcDrive;
+   TQString srcFloppyPath;
+   getDriveAndPath(srcPath,srcDrive,srcFloppyPath);
+   if (srcFloppyPath.isEmpty())
+   {
+      finished();
+      return;
+   }
+
+   TQString destDrive;
+   TQString destFloppyPath;
+   getDriveAndPath(destPath,destDrive,destFloppyPath);
+   if (destFloppyPath.isEmpty())
+   {
+      finished();
+      return;
+   }
+
+   if (m_mtool!=0)
+      delete m_mtool;
+   //kdDebug(7101)<<"Floppy::stat(): create args"<<endl;
+   TQStringList args;
+
+   if (_overwrite)
+      args<<"mren"<<"-o"<<(srcDrive+srcFloppyPath)<<(destDrive+destFloppyPath);
+   else
+      args<<"mren"<<"-D"<<"s"<<(srcDrive+srcFloppyPath)<<(destDrive+destFloppyPath);
+
+   kdDebug(7101)<<"Floppy::move(): executing: mren -"<<(srcDrive+srcFloppyPath)<<"  "<<(destDrive+destFloppyPath)<<endl;
+
+   m_mtool=new Program(args);
+   if (!m_mtool->start())
+   {
+      delete m_mtool;
+      m_mtool=0;
+      errorMissingMToolsProgram("mren");
+      return;
+   }
+
+
+   clearBuffers();
+   int result;
+   bool loopFinished(false);
+   bool errorOccured(false);
+   do
+   {
+      bool stdoutEvent;
+      bool stderrEvent;
+      result=m_mtool->select(1,0,stdoutEvent, stderrEvent);
+      if (stdoutEvent)
+         if (readStdout()==0)
+            loopFinished=true;
+      if (stderrEvent)
+      {
+         if (readStderr()==0)
+            loopFinished=true;
+         else
+            if (stopAfterError(src,srcDrive))
+            {
+               loopFinished=true;
+               errorOccured=true;
+            }
+      }
+   } while (!loopFinished);
+
+   delete m_mtool;
+   m_mtool=0;
+   terminateBuffers();
+   if (errorOccured)
+      return;
+   finished();
+}
+
+void FloppyProtocol::get( const KURL& url )
+{
+   TQString path(url.path());
+   kdDebug(7101)<<"Floppy::get() -"<<path<<"-"<<endl;
+
+   if ((path.isEmpty()) || (path=="/"))
+   {
+      KURL newUrl(url);
+      newUrl.setPath("/a/");
+      redirection(newUrl);
+      finished();
+      return;
+   }
+   StatInfo info=this->_stat(url);
+   //the error was already reported in _stat()
+   if (info.isValid==false)
+      return;
+
+   totalSize( info.size);
+
+   TQString drive;
+   TQString floppyPath;
+   getDriveAndPath(path,drive,floppyPath);
+   if (floppyPath.isEmpty())
+   {
+      finished();
+      return;
+   }
+
+   if (m_mtool!=0)
+      delete m_mtool;
+   //kdDebug(7101)<<"Floppy::stat(): create args"<<endl;
+   TQStringList args;
+   args<<"mcopy"<<(drive+floppyPath)<<"-";
+
+   kdDebug(7101)<<"Floppy::get(): executing: mcopy -"<<(drive+floppyPath)<<"-"<<endl;
+
+   m_mtool=new Program(args);
+   if (!m_mtool->start())
+   {
+      delete m_mtool;
+      m_mtool=0;
+      errorMissingMToolsProgram("mcopy");
+      return;
+   }
+
+   clearBuffers();
+   int result;
+   int bytesRead(0);
+   TQByteArray array;
+   bool loopFinished(false);
+   bool errorOccured(false);
+   do
+   {
+      bool stdoutEvent;
+      bool stderrEvent;
+      result=m_mtool->select(1,0,stdoutEvent, stderrEvent);
+      if (stdoutEvent)
+      {
+         delete [] m_stdoutBuffer;
+         m_stdoutBuffer=0;
+         m_stdoutSize=0;
+         if (readStdout()>0)
+         {
+            kdDebug(7101)<<"Floppy::get(): m_stdoutSize:"<<m_stdoutSize<<endl;
+            bytesRead+=m_stdoutSize;
+            array.setRawData(m_stdoutBuffer, m_stdoutSize);
+            data( array );
+            array.resetRawData(m_stdoutBuffer, m_stdoutSize);
+
+         }
+         else
+         {
+            loopFinished=true;
+         }
+      }
+      if (stderrEvent)
+      {
+         if (readStderr()==0)
+            loopFinished=true;
+         else
+            if (stopAfterError(url,drive))
+            {
+               errorOccured=true;
+               loopFinished=true;
+            }
+      }
+   } while (!loopFinished);
+
+   //kdDebug(7101)<<"Floppy::get(): deleting m_mtool"<<endl;
+   delete m_mtool;
+   m_mtool=0;
+   if (errorOccured)
+      return;
+
+   //kdDebug(7101)<<"Floppy::get(): finishing"<<endl;
+   data( TQByteArray() );
+   finished();
+}
+
+void FloppyProtocol::put( const KURL& url, int , bool overwrite, bool )
+{
+   TQString path(url.path());
+   kdDebug(7101)<<"Floppy::put() -"<<path<<"-"<<endl;
+
+   if ((path.isEmpty()) || (path=="/"))
+   {
+      KURL newUrl(url);
+      newUrl.setPath("/a/");
+      redirection(newUrl);
+      finished();
+      return;
+   }
+   TQString drive;
+   TQString floppyPath;
+   getDriveAndPath(path,drive,floppyPath);
+   if (floppyPath.isEmpty())
+   {
+      finished();
+      return;
+   }
+   int freeSpaceLeft=freeSpace(url);
+   if (freeSpaceLeft==-1)
+      return;
+
+   if (m_mtool!=0)
+      delete m_mtool;
+   //kdDebug(7101)<<"Floppy::stat(): create args"<<endl;
+   TQStringList args;
+   if (overwrite)
+      args<<"mcopy"<<"-o"<<"-"<<(drive+floppyPath);
+   else
+      args<<"mcopy"<<"-s"<<"-"<<(drive+floppyPath);
+
+   kdDebug(7101)<<"Floppy::put(): executing: mcopy -"<<(drive+floppyPath)<<"-"<<endl;
+
+   m_mtool=new Program(args);
+   if (!m_mtool->start())
+   {
+      delete m_mtool;
+      m_mtool=0;
+      errorMissingMToolsProgram("mcopy");
+      return;
+   }
+
+
+   clearBuffers();
+   int result(0);
+   int bytesRead(0);
+   TQByteArray array;
+
+   //from file.cc
+   // Loop until we got 0 (end of data)
+   do
+   {
+      bool stdoutEvent;
+      bool stderrEvent;
+      kdDebug(7101)<<"Floppy::put(): select()..."<<endl;
+      m_mtool->select(0,100,stdoutEvent, stderrEvent);
+      if (stdoutEvent)
+      {
+         if (readStdout()==0)
+            result=0;
+      }
+      if (stderrEvent)
+      {
+         if (readStderr()==0)
+            result=0;
+         else
+            if (stopAfterError(url,drive))
+               result=-1;
+         kdDebug(7101)<<"Floppy::put(): error: result=="<<result<<endl;
+      }
+      else
+      {
+         TQByteArray buffer;
+         dataReq(); // Request for data
+         //kdDebug(7101)<<"Floppy::put(): after dataReq()"<<endl;
+         result = readData( buffer );
+         //kdDebug(7101)<<"Floppy::put(): after readData(), read "<<result<<" bytes"<<endl;
+         if (result > 0)
+         {
+            bytesRead+=result;
+            kdDebug(7101)<<"Floppy::put() bytesRead: "<<bytesRead<<" space: "<<freeSpaceLeft<<endl;
+            if (bytesRead>freeSpaceLeft)
+            {
+               result=0;
+               error( TDEIO::ERR_SLAVE_DEFINED, i18n("Could not write to file %1.\nThe disk in drive %2 is probably full.").arg(url.prettyURL(),drive));
+            }
+            else
+            {
+               //kdDebug(7101)<<"Floppy::put(): writing..."<<endl;
+               result=::write(m_mtool->stdinFD(),buffer.data(), buffer.size());
+               kdDebug(7101)<<"Floppy::put(): after write(), wrote "<<result<<" bytes"<<endl;
+            }
+         }
+      }
+   }
+   while ( result > 0 );
+
+   if (result<0)
+   {
+      perror("writing to stdin");
+      error( TDEIO::ERR_CANNOT_OPEN_FOR_WRITING, url.prettyURL());
+      return;
+   }
+
+   delete m_mtool;
+   m_mtool=0;
+
+   finished();
+}
+