blob: e1e91aa3d88c7b50b93538c0896b6c3fcf42de04 [file] [log] [blame]
/****************************************************************************
**
** Copyright (C) 2011 Nokia Corporation and/or its subsidiary(-ies).
** All rights reserved.
** Contact: Nokia Corporation (qt-info@nokia.com)
**
** This file is part of the Qt3Support module of the Qt Toolkit.
**
** $QT_BEGIN_LICENSE:LGPL$
** GNU Lesser General Public License Usage
** This file may be used under the terms of the GNU Lesser General Public
** License version 2.1 as published by the Free Software Foundation and
** appearing in the file LICENSE.LGPL included in the packaging of this
** file. Please review the following information to ensure the GNU Lesser
** General Public License version 2.1 requirements will be met:
** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.
**
** In addition, as a special exception, Nokia gives you certain additional
** rights. These rights are described in the Nokia Qt LGPL Exception
** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.
**
** GNU General Public License Usage
** Alternatively, this file may be used under the terms of the GNU General
** Public License version 3.0 as published by the Free Software Foundation
** and appearing in the file LICENSE.GPL included in the packaging of this
** file. Please review the following information to ensure the GNU General
** Public License version 3.0 requirements will be met:
** http://www.gnu.org/copyleft/gpl.html.
**
** Other Usage
** Alternatively, this file may be used in accordance with the terms and
** conditions contained in a signed written agreement between you and Nokia.
**
**
**
**
**
** $QT_END_LICENSE$
**
****************************************************************************/
#include "q3localfs.h"
#ifndef QT_NO_NETWORKPROTOCOL
#include "qfileinfo.h"
#include "qfile.h"
#include "q3url.h"
#include "qurlinfo.h"
#include "qapplication.h"
#include "q3urloperator.h"
#include "qpointer.h"
#include "q3valuelist.h"
QT_BEGIN_NAMESPACE
//#define QLOCALFS_DEBUG
/*!
\class Q3LocalFs
\brief The Q3LocalFs class is an implementation of a
QNetworkProtocol that works on the local file system.
\compat
This class is derived from QNetworkProtocol. Q3LocalFs is not
normally used directly, but rather through a QUrlOperator, for
example:
\snippet doc/src/snippets/code/src_qt3support_network_q3localfs.cpp 0
This code will only work if the Q3LocalFs class is registered; to
register the class, you must call qInitNetworkProtocols() before
using a QUrlOperator with Q3LocalFs.
If you really need to use Q3LocalFs directly, don't forget
to set its QUrlOperator with setUrl().
\sa Q3NetworkProtocol, Q3UrlOperator
*/
/*!
Constructor.
*/
Q3LocalFs::Q3LocalFs()
: Q3NetworkProtocol()
{
}
static int convertPermissions(QFileInfo *fi)
{
int p = 0;
if ( fi->permission( QFileInfo::ReadOwner ) )
p |= QUrlInfo::ReadOwner;
if ( fi->permission( QFileInfo::WriteOwner ) )
p |= QUrlInfo::WriteOwner;
if ( fi->permission( QFileInfo::ExeOwner ) )
p |= QUrlInfo::ExeOwner;
if ( fi->permission( QFileInfo::ReadGroup ) )
p |= QUrlInfo::ReadGroup;
if ( fi->permission( QFileInfo::WriteGroup ) )
p |= QUrlInfo::WriteGroup;
if ( fi->permission( QFileInfo::ExeGroup ) )
p |= QUrlInfo::ExeGroup;
if ( fi->permission( QFileInfo::ReadOther ) )
p |= QUrlInfo::ReadOther;
if ( fi->permission( QFileInfo::WriteOther ) )
p |= QUrlInfo::WriteOther;
if ( fi->permission( QFileInfo::ExeOther ) )
p |= QUrlInfo::ExeOther;
return p;
}
/*!
\reimp
*/
void Q3LocalFs::operationListChildren( Q3NetworkOperation *op )
{
#ifdef QLOCALFS_DEBUG
qDebug( "Q3LocalFs: operationListChildren" );
#endif
op->setState( StInProgress );
dir = QDir( url()->path() );
dir.setNameFilter( url()->nameFilter() );
dir.setMatchAllDirs( true );
if ( !dir.isReadable() ) {
QString 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;
}
QFileInfoList filist = dir.entryInfoList(QDir::All | QDir::Hidden | QDir::System);
if ( filist.isEmpty() ) {
QString 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 );
Q3ValueList<QUrlInfo> infos;
for (int i = 0; i < filist.size(); ++i) {
QFileInfo fi = filist.at(i);
infos << QUrlInfo( 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 Q3LocalFs::operationMkDir( Q3NetworkOperation *op )
{
#ifdef QLOCALFS_DEBUG
qDebug( "Q3LocalFs: operationMkDir" );
#endif
op->setState( StInProgress );
QString dirname = op->arg( 0 );
dir = QDir( url()->path() );
if ( dir.mkdir( dirname ) ) {
QFileInfo fi( dir, dirname );
QUrlInfo 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 {
QString 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 Q3LocalFs::operationRemove( Q3NetworkOperation *op )
{
#ifdef QLOCALFS_DEBUG
qDebug( "Q3LocalFs: operationRemove" );
#endif
op->setState( StInProgress );
QString name = Q3Url( op->arg( 0 ) ).path();
bool deleted = false;
dir = QDir( url()->path() );
QFileInfo 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 {
QString 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 Q3LocalFs::operationRename( Q3NetworkOperation *op )
{
#ifdef QLOCALFS_DEBUG
qDebug( "Q3LocalFs: operationRename" );
#endif
op->setState( StInProgress );
QString oldname = op->arg( 0 );
QString newname = op->arg( 1 );
dir = QDir( url()->path() );
if ( dir.rename( oldname, newname ) ) {
op->setState( StDone );
emit itemChanged( op );
emit finished( op );
} else {
QString 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 Q3LocalFs::operationGet( Q3NetworkOperation *op )
{
#ifdef QLOCALFS_DEBUG
qDebug( "Q3LocalFs: operationGet" );
#endif
op->setState( StInProgress );
QString from = Q3Url( op->arg( 0 ) ).path();
QFile f( from );
if ( !f.open( IO_ReadOnly ) ) {
#ifdef QLOCALFS_DEBUG
qDebug( "Q3LocalFs: could not open %s", from.latin1() );
#endif
QString msg = tr( "Could not open\n%1" ).arg( from );
op->setState( StFailed );
op->setProtocolDetail( msg );
op->setErrorCode( (int)ErrGet );
emit finished( op );
return;
}
QByteArray 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 QLOCALFS_DEBUG
qDebug( "Q3LocalFs: got all %d bytes at once", f.size() );
#endif
} else {
s.resize( blockSize );
int remaining = f.size();
QPointer<QObject> 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;
}
qApp->processEvents();
}
if ( !that )
return;
#ifdef QLOCALFS_DEBUG
qDebug( "Q3LocalFs: 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 Q3LocalFs::operationPut( Q3NetworkOperation *op )
{
#ifdef QLOCALFS_DEBUG
qDebug( "Q3LocalFs: operationPut" );
#endif
op->setState( StInProgress );
QString to = Q3Url( op->arg( 0 ) ).path();
QFile f( to );
if ( !f.open( IO_WriteOnly ) ) {
QString msg = tr( "Could not write\n%1" ).arg( to );
op->setState( StFailed );
op->setProtocolDetail( msg );
op->setErrorCode( (int)ErrPut );
emit finished( op );
return;
}
QByteArray 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;
QPointer<QObject> that = this;
qApp->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 Q3LocalFs::supportedOperations() const
{
return OpListChildren | OpMkDir | OpRemove | OpRename | OpGet | OpPut;
}
/*!
\internal
*/
int Q3LocalFs::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;
}
QT_END_NAMESPACE
#endif // QT_NO_NETWORKPROTOCOL