#include <VP1HttpGetFile.h>

Inheritance diagram for VP1HttpGetFile:

Collaboration diagram for VP1HttpGetFile:

Classes
class	Imp

Signals
void	downloadSuccessful (const QString &urltofile, const QString &localtargetfile, const QString &data)
void	downloadFailed (const QString &error, const QString &urltofile, const QString &localtargetfile, const QString &data)

Public Member Functions
	VP1HttpGetFile (QObject *parent=0)
virtual	~VP1HttpGetFile ()
void	setMaxNumberOfPendingDownloads (unsigned)
unsigned	maxNumberOfPendingDownloads () const
unsigned	numberOfPendingDownloads () const
bool	isDownloading (const QString &urltofile) const
bool	isDownloadingTo (const QString &localtargetfile) const
QString	startDownload (const QString &urltofile, const QString &localtargetfile, const QString &md5sum="", const QString &data="")

Private Slots
void	downloadThreadFinished ()
void	downloadThreadTerminated ()

Private Attributes
Imp *	m_d

Detailed Description

Definition at line 25 of file VP1HttpGetFile.h.

Constructor & Destructor Documentation

◆ VP1HttpGetFile()

VP1HttpGetFile::VP1HttpGetFile ( QObject * parent = 0 )

Definition at line 32 of file VP1HttpGetFile.cxx.

  : QObject(parent), m_d(new Imp)
{
}

◆ ~VP1HttpGetFile()

VP1HttpGetFile::~VP1HttpGetFile ( )

virtual

Definition at line 38 of file VP1HttpGetFile.cxx.

{
  m_d->dead = true;
  for( VP1HttpGetFile_DownloadThread * thread : m_d->activeDownloadThreads) {
    thread->blockSignals(true);
    QString urltofile = thread->urltofile();
    QString localtargetfile = thread->localtargetfile();
    QString data = thread->data();
    emit downloadFailed( "VP1HttpGetFile object deleted before download finished", urltofile, localtargetfile, data );
    thread->terminate();
    thread->wait();
    thread->deleteLater();
  }
  delete m_d;
}

Member Function Documentation

◆ downloadFailed

void VP1HttpGetFile::downloadFailed	(	const QString &	error,
		const QString &	urltofile,
		const QString &	localtargetfile,
		const QString &	data )

signal

◆ downloadSuccessful

void VP1HttpGetFile::downloadSuccessful	(	const QString &	urltofile,
		const QString &	localtargetfile,
		const QString &	data )

signal

◆ downloadThreadFinished

void VP1HttpGetFile::downloadThreadFinished ( )

privateslot

Definition at line 94 of file VP1HttpGetFile.cxx.

{
  if (m_d->dead)
    return;
  VP1HttpGetFile_DownloadThread * thread = dynamic_cast<VP1HttpGetFile_DownloadThread *>(sender());
  if (!thread)
    return;
  m_d->activeDownloadThreads.removeAll(thread);
  const QString urltofile = thread->urltofile();
  const QString localtargetfile = thread->localtargetfile();
  const QString data = thread->data();
  const bool errors = thread->errors();
  const QString errorString = thread->errorString();
  thread->wait();
  thread->deleteLater();
  if (errors)
    emit downloadFailed( errorString, urltofile, localtargetfile, data );
  else
    emit downloadSuccessful( urltofile, localtargetfile, data );
}

◆ downloadThreadTerminated

void VP1HttpGetFile::downloadThreadTerminated ( )

privateslot

Definition at line 116 of file VP1HttpGetFile.cxx.

{
  if (m_d->dead)
    return;
  VP1HttpGetFile_DownloadThread * thread = dynamic_cast<VP1HttpGetFile_DownloadThread *>(sender());
  if (!thread)
    return;
  m_d->activeDownloadThreads.removeAll(thread);
  const QString urltofile = thread->urltofile();
  const QString localtargetfile = thread->localtargetfile();
  const QString data = thread->data();
  thread->wait();
  thread->deleteLater();
  emit downloadFailed( "Download thread terminated", urltofile, localtargetfile, data );
 
  //NB: As always when threads are terminated, we might get memory
  //leaks, but it usually only happens if the VP1HttpGetFile instance
  //is deleted prematurely (e.g. at program shutdown).
}

◆ isDownloading()

bool VP1HttpGetFile::isDownloading ( const QString & urltofile ) const

Definition at line 137 of file VP1HttpGetFile.cxx.

{
  for( VP1HttpGetFile_DownloadThread * thread : m_d->activeDownloadThreads)
    if (urltofile==thread->urltofile()) {
      QTimer::singleShot(0, thread, SLOT(checkForStall()));
      return true;
    }
  return false;
}

◆ isDownloadingTo()

bool VP1HttpGetFile::isDownloadingTo ( const QString & localtargetfile ) const

Definition at line 148 of file VP1HttpGetFile.cxx.

{
  for( VP1HttpGetFile_DownloadThread * thread : m_d->activeDownloadThreads)
    if (localtargetfile==thread->localtargetfile()) {
      QTimer::singleShot(0, thread, SLOT(checkForStall()));
      return true;
    }
  return false;
}

◆ maxNumberOfPendingDownloads()

unsigned VP1HttpGetFile::maxNumberOfPendingDownloads ( ) const

Definition at line 61 of file VP1HttpGetFile.cxx.

{
  return m_d->maxDownloads;
}

◆ numberOfPendingDownloads()

unsigned VP1HttpGetFile::numberOfPendingDownloads ( ) const

Definition at line 67 of file VP1HttpGetFile.cxx.

{
  return m_d->activeDownloadThreads.size();
}

◆ setMaxNumberOfPendingDownloads()

void VP1HttpGetFile::setMaxNumberOfPendingDownloads ( unsigned n )

Definition at line 55 of file VP1HttpGetFile.cxx.

{
  m_d->maxDownloads = n;
}

◆ startDownload()

QString VP1HttpGetFile::startDownload	(	const QString &	urltofile,
		const QString &	localtargetfile,
		const QString &	md5sum = "",
		const QString &	data = "" )

Definition at line 73 of file VP1HttpGetFile.cxx.

{
  if (m_d->maxDownloads>0 && unsigned(m_d->activeDownloadThreads.count()) >= m_d->maxDownloads)
    return "Too many simultaneous downloads requested";
 
  if (isDownloadingTo(localtargetfile))
    return "Already downloading file to location: "+localtargetfile;
 
  VP1HttpGetFile_DownloadThread * thread = new VP1HttpGetFile_DownloadThread( urltofile, localtargetfile, md5sum, data);
  connect(thread,SIGNAL(finished()),this,SLOT(downloadThreadFinished()));
  connect(thread,SIGNAL(terminated()),this,SLOT(downloadThreadTerminated()));
  m_d->activeDownloadThreads << thread;
  thread->start();
 
  return "";//Download started succesfully.
}

Member Data Documentation

◆ m_d

Imp* VP1HttpGetFile::m_d

private

Definition at line 61 of file VP1HttpGetFile.h.

The documentation for this class was generated from the following files:

Classes

Signals

Public Member Functions

Private Slots

Private Attributes