25'ten fazla konu seçemezsiniz
Konular bir harf veya rakamla başlamalı, kısa çizgiler ('-') içerebilir ve en fazla 35 karakter uzunluğunda olabilir.
122 satır
3.3 KiB
122 satır
3.3 KiB
/* This file is part of the KDE project
|
|
Copyright (C) 2001 Carsten Pfeiffer <pfeiffer@kde.org>
|
|
|
|
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, version 2.
|
|
|
|
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; see the file COPYING. If not, write to
|
|
the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
|
|
Boston, MA 02110-1301, USA.
|
|
*/
|
|
|
|
#include <kstaticdeleter.h>
|
|
#include <tdeio/scheduler.h>
|
|
|
|
#include "loader.h"
|
|
|
|
Loader *Loader::s_self = 0L;
|
|
|
|
KStaticDeleter<Loader> sd;
|
|
|
|
Loader * Loader::self()
|
|
{
|
|
if ( !s_self )
|
|
s_self = sd.setObject( new Loader() );
|
|
|
|
return s_self;
|
|
}
|
|
|
|
Loader::Loader() : TQObject()
|
|
{
|
|
}
|
|
|
|
Loader::~Loader()
|
|
{
|
|
disconnect( this, TQT_SIGNAL( finished( const KURL&, const TQByteArray& )));
|
|
|
|
DownloadIterator it = m_downloads.begin();
|
|
for ( ; it != m_downloads.end(); ++it ) {
|
|
it.key()->kill();
|
|
delete it.data();
|
|
}
|
|
|
|
s_self = 0L;
|
|
}
|
|
|
|
void Loader::requestDownload( const KURL& url )
|
|
{
|
|
DownloadIterator it = m_downloads.begin();
|
|
for ( ; it != m_downloads.end(); ++it ) {
|
|
if ( it.key()->url() == url )
|
|
return;
|
|
}
|
|
|
|
TDEIO::TransferJob *job = TDEIO::get( url, false, false );
|
|
TDEIO::Scheduler::scheduleJob(job);
|
|
|
|
connect( job , TQT_SIGNAL( data( TDEIO::Job *, const TQByteArray& )),
|
|
TQT_SLOT( slotData( TDEIO::Job *, const TQByteArray& )));
|
|
connect( job , TQT_SIGNAL( result( TDEIO::Job * )),
|
|
TQT_SLOT( slotResult( TDEIO::Job * )));
|
|
|
|
Download *d = new Download();
|
|
m_downloads.insert( job, d );
|
|
}
|
|
|
|
void Loader::slotData( TDEIO::Job *job, const TQByteArray& data )
|
|
{
|
|
DownloadIterator it = m_downloads.find( static_cast<TDEIO::TransferJob*>(job) );
|
|
if ( it != m_downloads.end() ) {
|
|
TQBuffer& buffer = it.data()->m_buffer;
|
|
if ( !buffer.isOpen() )
|
|
buffer.open( IO_ReadWrite );
|
|
if ( !buffer.isOpen() ) {
|
|
tqDebug("********* EEK, can't open buffer for thumbnail download!");
|
|
return;
|
|
}
|
|
|
|
buffer.writeBlock( data.data(), data.size() );
|
|
}
|
|
}
|
|
|
|
void Loader::slotResult( TDEIO::Job *job )
|
|
{
|
|
TDEIO::TransferJob *tjob = static_cast<TDEIO::TransferJob*>( job );
|
|
|
|
DownloadIterator it = m_downloads.find( tjob );
|
|
if ( it != m_downloads.end() ) {
|
|
Download *d = it.data();
|
|
|
|
if ( job->error() != 0 )
|
|
emit finished( tjob->url(), TQByteArray() );
|
|
else
|
|
emit finished( tjob->url(), d->m_buffer.buffer() );
|
|
|
|
delete d;
|
|
m_downloads.remove( it );
|
|
}
|
|
}
|
|
|
|
|
|
// ### simultaneous downloads with multiple views? reference count downloads!
|
|
void Loader::removeDownload( const KURL& url )
|
|
{
|
|
DownloadIterator it = m_downloads.begin();
|
|
for ( ; it != m_downloads.end(); ++it ) {
|
|
if ( it.key()->url() == url ) {
|
|
it.key()->kill();
|
|
delete it.data();
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
|
|
#include "loader.moc"
|