summaryrefslogtreecommitdiffstats
path: root/experimental/tqtinterface/qt4/src/kernel/tqlocalfs.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'experimental/tqtinterface/qt4/src/kernel/tqlocalfs.cpp')
-rw-r--r--experimental/tqtinterface/qt4/src/kernel/tqlocalfs.cpp407
1 files changed, 407 insertions, 0 deletions
diff --git a/experimental/tqtinterface/qt4/src/kernel/tqlocalfs.cpp b/experimental/tqtinterface/qt4/src/kernel/tqlocalfs.cpp
new file mode 100644
index 000000000..c26c9f410
--- /dev/null
+++ b/experimental/tqtinterface/qt4/src/kernel/tqlocalfs.cpp
@@ -0,0 +1,407 @@
+/****************************************************************************
+**
+** Implementation of TQLocalFs class
+**
+** Created : 950429
+**
+** Copyright (C) 2010 Timothy Pearson and (C) 1992-2008 Trolltech ASA.
+**
+** This file is part of the kernel module of the TQt GUI Toolkit.
+**
+** This file may be used under the terms of the GNU General
+** Public License versions 2.0 or 3.0 as published by the Free
+** Software Foundation and appearing in the files LICENSE.GPL2
+** and LICENSE.GPL3 included in the packaging of this file.
+** Alternatively you may (at your option) use any later version
+** of the GNU General Public License if such license has been
+** publicly approved by Trolltech ASA (or its successors, if any)
+** and the KDE Free TQt Foundation.
+**
+** Please review the following information to ensure GNU General
+** Public Licensing requirements will be met:
+** http://trolltech.com/products/qt/licenses/licensing/opensource/.
+** If you are unsure which license is appropriate for your use, please
+** review the following information:
+** http://trolltech.com/products/qt/licenses/licensing/licensingoverview
+** or contact the sales department at sales@trolltech.com.
+**
+** This file may be used under the terms of the Q Public License as
+** defined by Trolltech ASA and appearing in the file LICENSE.TQPL
+** included in the packaging of this file. Licensees holding valid TQt
+** Commercial licenses may use this file in accordance with the TQt
+** Commercial License Agreement provided with the Software.
+**
+** This file is provided "AS IS" with NO WARRANTY OF ANY KIND,
+** INCLUDING THE WARRANTIES OF DESIGN, MERCHANTABILITY AND FITNESS FOR
+** A PARTICULAR PURPOSE. Trolltech reserves all rights not granted
+** herein.
+**
+**********************************************************************/
+
+#include "tqlocalfs.h"
+
+#ifndef TQT_NO_NETWORKPROTOCOL
+
+#include "tqfileinfo.h"
+#include "tqfile.h"
+#include "tqurlinfo.h"
+#include "tqapplication.h"
+#include "tqurloperator.h"
+#include "tqguardedptr.h"
+
+//#define TQLOCALFS_DEBUG
+
+
+/*!
+ \class TQLocalFs tqlocalfs.h
+ \brief The TQLocalFs class is an implementation of a
+ TQNetworkProtocol that works on the local file system.
+\if defined(commercial)
+ It is part of the <a href="commercialeditions.html">TQt Enterprise Edition</a>.
+\endif
+
+ \module network
+
+ \ingroup io
+
+ This class is derived from TQNetworkProtocol. TQLocalFs is not
+ normally used directly, but rather through a TQUrlOperator, for
+ example:
+ \code
+ TQUrlOperator op( "file:///tmp" );
+ op.listChildren(); // Asks the server to provide a directory listing
+ \endcode
+
+ This code will only work if the TQLocalFs class is registered; to
+ register the class, you must call qInitNetworkProtocols() before
+ using a TQUrlOperator with TQLocalFs.
+
+ If you really need to use TQLocalFs directly, don't forget
+ to set its TQUrlOperator with setUrl().
+
+ \sa \link network.html TQt Network Documentation \endlink TQNetworkProtocol, TQUrlOperator
+*/
+
+/*!
+ Constructor.
+*/
+
+TQLocalFs::TQLocalFs()
+ : TQNetworkProtocol()
+{
+}
+
+static int convertPermissions(TQFileInfo *fi)
+{
+ int p = 0;
+ if ( fi->permission( TQFileInfo::ReadOwner ) )
+ p |= TQUrlInfo::ReadOwner;
+ if ( fi->permission( TQFileInfo::WriteOwner ) )
+ p |= TQUrlInfo::WriteOwner;
+ if ( fi->permission( TQFileInfo::ExeOwner ) )
+ p |= TQUrlInfo::ExeOwner;
+ if ( fi->permission( TQFileInfo::ReadGroup ) )
+ p |= TQUrlInfo::ReadGroup;
+ if ( fi->permission( TQFileInfo::WriteGroup ) )
+ p |= TQUrlInfo::WriteGroup;
+ if ( fi->permission( TQFileInfo::ExeGroup ) )
+ p |= TQUrlInfo::ExeGroup;
+ if ( fi->permission( TQFileInfo::ReadOther ) )
+ p |= TQUrlInfo::ReadOther;
+ if ( fi->permission( TQFileInfo::WriteOther ) )
+ p |= TQUrlInfo::WriteOther;
+ if ( fi->permission( TQFileInfo::ExeOther ) )
+ p |= TQUrlInfo::ExeOther;
+ return p;
+}
+
+/*!
+ \reimp
+*/
+
+void TQLocalFs::operationListChildren( TQNetworkOperation *op )
+{
+#ifdef TQLOCALFS_DEBUG
+ qDebug( "TQLocalFs: operationListChildren" );
+#endif
+ op->setState( StInProgress );
+
+ dir = TQDir( url()->path() );
+ dir.setNameFilter( url()->nameFilter() );
+ dir.setMatchAllDirs( TRUE );
+ if ( !dir.isReadable() ) {
+ TQString msg = tr( "Could not read directory\n%1" ).arg( url()->path() );
+ op->setState( StFailed );
+ op->setProtocolDetail( msg );
+ op->setErrorCode( (int)ErrListChildren );
+ emit finished( op );
+ return;
+ }
+
+ const TQFileInfoList *filist = dir.entryInfoList( TQDir::All | TQDir::Hidden | TQDir::System );
+ if ( !filist ) {
+ TQString msg = tr( "Could not read directory\n%1" ).arg( url()->path() );
+ op->setState( StFailed );
+ op->setProtocolDetail( msg );
+ op->setErrorCode( (int)ErrListChildren );
+ emit finished( op );
+ return;
+ }
+
+ emit start( op );
+
+ TQFileInfoListIterator it( *filist );
+ TQFileInfo *fi;
+ TQValueList<TQUrlInfo> infos;
+ while ( ( fi = it.current() ) != 0 ) {
+ ++it;
+ infos << TQUrlInfo( fi->fileName(), convertPermissions(fi), fi->owner(), fi->group(),
+ fi->size(), fi->lastModified(), fi->lastRead(), fi->isDir(), fi->isFile(),
+ fi->isSymLink(), fi->isWritable(), fi->isReadable(), fi->isExecutable() );
+ }
+ emit newChildren( infos, op );
+ op->setState( StDone );
+ emit finished( op );
+}
+
+/*!
+ \reimp
+*/
+
+void TQLocalFs::operationMkDir( TQNetworkOperation *op )
+{
+#ifdef TQLOCALFS_DEBUG
+ qDebug( "TQLocalFs: operationMkDir" );
+#endif
+ op->setState( StInProgress );
+ TQString dirname = op->arg( 0 );
+
+ dir = TQDir( url()->path() );
+ if ( dir.mkdir( dirname ) ) {
+ TQFileInfo fi( dir, dirname );
+ TQUrlInfo inf( fi.fileName(), convertPermissions(&fi), fi.owner(), fi.group(),
+ fi.size(), fi.lastModified(), fi.lastRead(), fi.isDir(), fi.isFile(),
+ fi.isSymLink(), fi.isWritable(), fi.isReadable(), fi.isExecutable() );
+ emit newChild( inf, op );
+ op->setState( StDone );
+ emit createdDirectory( inf, op );
+ emit finished( op );
+ } else {
+ TQString msg = tr( "Could not create directory\n%1" ).arg( dirname );
+ op->setState( StFailed );
+ op->setProtocolDetail( msg );
+ op->setErrorCode( (int)ErrMkDir );
+ emit finished( op );
+ }
+}
+
+/*!
+ \reimp
+*/
+
+void TQLocalFs::operationRemove( TQNetworkOperation *op )
+{
+#ifdef TQLOCALFS_DEBUG
+ qDebug( "TQLocalFs: operationRemove" );
+#endif
+ op->setState( StInProgress );
+ TQString name = TQUrl( op->arg( 0 ) ).path();
+ bool deleted = FALSE;
+
+ dir = TQDir( url()->path() );
+
+ TQFileInfo fi( dir, name );
+ if ( fi.isDir() ) {
+ if ( dir.rmdir( name ) )
+ deleted = TRUE;
+ }
+
+ if ( deleted || dir.remove( name ) ) {
+ op->setState( StDone );
+ emit removed( op );
+ emit finished( op );
+ } else {
+ TQString msg = tr( "Could not remove file or directory\n%1" ).arg( name );
+ op->setState( StFailed );
+ op->setProtocolDetail( msg );
+ op->setErrorCode( (int)ErrRemove );
+ emit finished( op );
+ }
+}
+
+/*!
+ \reimp
+*/
+
+void TQLocalFs::operationRename( TQNetworkOperation *op )
+{
+#ifdef TQLOCALFS_DEBUG
+ qDebug( "TQLocalFs: operationRename" );
+#endif
+ op->setState( StInProgress );
+ TQString oldname = op->arg( 0 );
+ TQString newname = op->arg( 1 );
+
+ dir = TQDir( url()->path() );
+ if ( dir.rename( oldname, newname ) ) {
+ op->setState( StDone );
+ emit itemChanged( op );
+ emit finished( op );
+ } else {
+ TQString msg = tr( "Could not rename\n%1\nto\n%2" ).arg( oldname ).arg( newname );
+ op->setState( StFailed );
+ op->setProtocolDetail( msg );
+ op->setErrorCode( (int)ErrRename );
+ emit finished( op );
+ }
+}
+
+/*!
+ \reimp
+*/
+
+void TQLocalFs::operationGet( TQNetworkOperation *op )
+{
+#ifdef TQLOCALFS_DEBUG
+ qDebug( "TQLocalFs: operationGet" );
+#endif
+ op->setState( StInProgress );
+ TQString from = TQUrl( op->arg( 0 ) ).path();
+
+ TQFile f( from );
+ if ( !f.open( IO_ReadOnly ) ) {
+#ifdef TQLOCALFS_DEBUG
+ qDebug( "TQLocalFs: could not open %s", from.latin1() );
+#endif
+ TQString msg = tr( "Could not open\n%1" ).arg( from );
+ op->setState( StFailed );
+ op->setProtocolDetail( msg );
+ op->setErrorCode( (int)ErrGet );
+ emit finished( op );
+ return;
+ }
+
+ TQByteArray s;
+ emit dataTransferProgress( 0, f.size(), op );
+ if ( f.size() != 0 ) {
+ int blockSize = calcBlockSize( f.size() );
+ if ( (int)f.size() < blockSize ) {
+ s.resize( f.size() );
+ f.readBlock( s.data(), f.size() );
+ emit data( s, op );
+ emit dataTransferProgress( f.size(), f.size(), op );
+#ifdef TQLOCALFS_DEBUG
+ qDebug( "TQLocalFs: got all %d bytes at once", f.size() );
+#endif
+ } else {
+ s.resize( blockSize );
+ int remaining = f.size();
+ TQGuardedPtr<TQObject> that = this;
+ while ( that && remaining > 0 ) {
+ if ( operationInProgress() != op )
+ return;
+ if ( remaining >= blockSize ) {
+ f.readBlock( s.data(), blockSize );
+ emit data( s, op );
+ emit dataTransferProgress( f.size() - remaining, f.size(), op );
+ remaining -= blockSize;
+ } else {
+ s.resize( remaining );
+ f.readBlock( s.data(), remaining );
+ emit data( s, op );
+ emit dataTransferProgress( f.size() - remaining, f.size(), op );
+ remaining -= remaining;
+ }
+ tqApp->processEvents();
+ }
+ if (!that)
+ return;
+#ifdef TQLOCALFS_DEBUG
+ qDebug( "TQLocalFs: got all %d bytes step by step", f.size() );
+#endif
+ emit dataTransferProgress( f.size(), f.size(), op );
+ }
+ }
+ op->setState( StDone );
+ f.close();
+ emit finished( op );
+}
+
+/*!
+ \reimp
+*/
+
+void TQLocalFs::operationPut( TQNetworkOperation *op )
+{
+#ifdef TQLOCALFS_DEBUG
+ qDebug( "TQLocalFs: operationPut" );
+#endif
+ op->setState( StInProgress );
+ TQString to = TQUrl( op->arg( 0 ) ).path();
+
+ TQFile f( to );
+ if ( !f.open( IO_WriteOnly ) ) {
+ TQString msg = tr( "Could not write\n%1" ).arg( to );
+ op->setState( StFailed );
+ op->setProtocolDetail( msg );
+ op->setErrorCode( (int)ErrPut );
+ emit finished( op );
+ return;
+ }
+
+ TQByteArray ba( op->rawArg( 1 ) );
+ emit dataTransferProgress( 0, ba.size(), op );
+ int blockSize = calcBlockSize( ba.size() );
+ if ( (int)ba.size() < blockSize ) {
+ f.writeBlock( ba.data(), ba.size() );
+ emit dataTransferProgress( ba.size(), ba.size(), op );
+ } else {
+ int i = 0;
+ while ( i + blockSize < (int)ba.size() - 1 ) {
+ if ( operationInProgress() != op )
+ return;
+ f.writeBlock( &ba.data()[ i ], blockSize );
+ f.flush();
+ emit dataTransferProgress( i + blockSize, ba.size(), op );
+ i += blockSize;
+ TQGuardedPtr<TQObject> that = this;
+ tqApp->processEvents();
+ if (!that)
+ return;
+ }
+ if ( i < (int)ba.size() - 1 )
+ f.writeBlock( &ba.data()[ i ], ba.size() - i );
+ emit dataTransferProgress( ba.size(), ba.size(), op );
+ }
+ op->setState( StDone );
+ f.close();
+ emit finished( op );
+}
+
+/*!
+ \reimp
+*/
+
+int TQLocalFs::supportedOperations() const
+{
+ return OpListChildren | OpMkDir | OpRemove | OpRename | OpGet | OpPut;
+}
+
+/*!
+ \internal
+*/
+
+int TQLocalFs::calcBlockSize( int totalSize ) const
+{
+ if ( totalSize == 0 )
+ return 1024;
+ int s = totalSize / 100;
+ // we want a block size between 1KB and 1MB
+ if ( s < 1024 )
+ s = 1024;
+ if ( s > 1048576 )
+ s = 1048576;
+ return s;
+}
+
+#endif // TQT_NO_NETWORKPROTOCOL
generated by cgit v1.2.1 (git 2.18.0) at 2024-11-09 06:05:25 +0000