/* * Copyright (C) 2004, Mart Kelder (mart.kde@hccnet.nl) * * 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. * * This program 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 General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program; if not, write to the Free Software * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA */ #include "tdeio_subjects.h" #include "kio.h" #include "tdeio_single_subject.h" #include "tdeio_proto.h" #include "mailsubject.h" #include <tdeio/global.h> #include <tdeio/scheduler.h> #include <kdebug.h> #include <tqptrlist.h> #include <tqvaluelist.h> #include <tqstring.h> KIO_Subjects::KIO_Subjects( TQObject * parent, const char * name ) : TQObject( parent, name ), _protocol( 0 ), _slave( 0 ), _valid( true ) { _jobs = new TQPtrList<KIO_Single_Subject>; _kurl = new KURL; _metadata = new TDEIO::MetaData; _jobs->setAutoDelete( true ); } KIO_Subjects::~KIO_Subjects( ) { delete _jobs; delete _kurl; delete _metadata; _protocol = 0; } void KIO_Subjects::doReadSubjects( KKioDrop *drop ) { TQValueList<KKioDrop::FileInfo>::ConstIterator it; TQValueList<KKioDrop::FileInfo>::ConstIterator end_it = drop->_mailurls->end(); _kio = drop; _protocol = _kio->_protocol; *_kurl = *_kio->_kurl; *_metadata = *_kio->_metadata; if( _jobs->count() > 0 ) kdWarning() << i18n( "Already a slave pending." ) << endl; _jobs->clear( ); //Open connection getConnection( ); //Open jobs for easy item in the list for( it = _kio->_mailurls->begin(); it != end_it; it++ ) startJob( (*it).name, (*it).size ); //close connection for trivial situations (empty list) disConnect( true ); //passing number of subjects for progress bar. _kio->emitReadSubjectsTotalSteps( _jobs->count() ); } void KIO_Subjects::getConnection( ) { KURL kurl = *_kurl; TDEIO::MetaData metadata = *_metadata; if( _slave ) { TDEIO::Scheduler::disconnectSlave( _slave ); _slave = 0; } if( _protocol->connectionBased( ) ) { _protocol->readSubjectConnectKURL( kurl, metadata ); if( kurl.port() == 0 ) kurl.setPort( _protocol->defaultPort( _kio->_ssl ) ); if( ! ( _slave = TDEIO::Scheduler::getConnectedSlave( kurl, metadata ) ) ) { kdWarning() << i18n( "Not able to open a kio-slave for %1." ).arg( _protocol->configName() ); _kio->emitShowPassivePopup( i18n( "Not able to open a kio-slave for %1." ).arg( _protocol->configName() ) ); _valid = false; _kio->emitValidChanged(); _slave = 0; _kio->emitReadSubjectsReady( false ); return; } } } void KIO_Subjects::startJob( const TQString &name, const long size ) { KURL kurl = *_kurl; TDEIO::MetaData metadata = *_metadata; KIO_Single_Subject *subject; kurl = name; _protocol->readSubjectKURL( kurl, metadata ); if( kurl.port() == 0 ) kurl.setPort( _protocol->defaultPort( _kio->_ssl ) ); subject = new KIO_Single_Subject( this, name.latin1(), kurl, metadata, _protocol, _slave, name, size ); connect( subject, TQT_SIGNAL( readSubject( KornMailSubject* ) ), this, TQT_SLOT( slotReadSubject( KornMailSubject* ) ) ); connect( subject, TQT_SIGNAL( finished( KIO_Single_Subject* ) ), this, TQT_SLOT( slotFinished( KIO_Single_Subject* ) ) ); _jobs->append( subject ); } void KIO_Subjects::disConnect( bool result ) { if( _jobs->isEmpty() ) { if( _slave ) { TDEIO::Scheduler::disconnectSlave( _slave ); _slave = 0; } _kio->emitReadSubjectsReady( result ); } } void KIO_Subjects::cancelled( ) { _jobs->clear(); //_slave died in cancelJob with is by called from the destructor of KIO_Single_Subject, //withs is by called by _jobs->clear because autoRemove equals true. _slave = 0; disConnect( false ); } void KIO_Subjects::slotReadSubject( KornMailSubject* subject ) { _valid = true; _kio->emitValidChanged(); subject->setMailDrop( _kio ); _kio->emitReadSubjectsRead( subject ); } void KIO_Subjects::slotFinished( KIO_Single_Subject* item ) { //Remove sender.... I didn't know of the computer gonna like me, but it seems he does :) _jobs->remove( item ); _kio->emitReadSubjectsProgress( _jobs->count( ) ); disConnect( true ); //Only works when all jobs are finished. } #include "tdeio_subjects.moc"