Chesto::DownloadQueue Class Reference

Collaboration diagram for Chesto::DownloadQueue:

Public Member Functions
void	downloadAdd (DownloadOperation *download)
	add a new download operation More...
void	downloadCancel (DownloadOperation *download)
	cancel a download operation More...
int	process ()
	process finished and queued downloads More...

Static Public Member Functions
static void	init ()
static void	quit ()

Static Public Attributes
static DownloadQueue *	downloadQueue = NULL

Detailed Description

Definition at line 41 of file DownloadQueue.hpp.

Constructor & Destructor Documentation

DownloadQueue()

Chesto::DownloadQueue::DownloadQueue

(

)

Definition at line 63 of file DownloadQueue.cpp.

{
#ifndef NETWORK_MOCK
    cm = curl_multi_init();
    curl_multi_setopt(cm, CURLMOPT_MAXCONNECTS, MAX_PARALLEL_DOWNLOADS);
#endif
}

~DownloadQueue()

Chesto::DownloadQueue::~DownloadQueue

(

)

Definition at line 71 of file DownloadQueue.cpp.

{
#ifndef NETWORK_MOCK
    curl_multi_cleanup(cm);
    cm = NULL;
#endif
}

Member Function Documentation

downloadAdd()

void Chesto::DownloadQueue::downloadAdd

(

DownloadOperation *

download

)

add a new download operation

Definition at line 80 of file DownloadQueue.cpp.

{
    download->status = DownloadStatus::QUEUED;
    queue.push_back(download);
}

downloadCancel()

void Chesto::DownloadQueue::downloadCancel

(

DownloadOperation *

download

)

cancel a download operation

Definition at line 87 of file DownloadQueue.cpp.

{
    if (download->status == DownloadStatus::DOWNLOADING)
        transferFinish(download);
    else if (download->status == DownloadStatus::QUEUED && queue.size() > 0)
        queue.remove(download);
}

init()

void Chesto::DownloadQueue::init ( )

static

Definition at line 46 of file DownloadQueue.cpp.

{
    downloadQueue = new DownloadQueue();
}

process()

int Chesto::DownloadQueue::process

(

)

process finished and queued downloads

Definition at line 158 of file DownloadQueue.cpp.

{
#ifndef NETWORK_MOCK
    DownloadOperation *download;
    int still_alive = 1;
    int msgs_left = -1;
 
    CURLMsg *msg;
 
    curl_multi_perform(cm, &still_alive);
 
    // handle completed or failed downloads
    while((msg = curl_multi_info_read(cm, &msgs_left)))
    {
        long response_code = 404;
 
        if (msg->msg != CURLMSG_DONE)
            continue;
 
        curl_easy_getinfo(msg->easy_handle, CURLINFO_PRIVATE, &download);
        curl_easy_getinfo(msg->easy_handle, CURLINFO_RESPONSE_CODE, &response_code);
 
        transferFinish(download);
        startTransfersFromQueue();
 
        if (response_code == 200)
            download->status = DownloadStatus::COMPLETE;
        else
            download->status = DownloadStatus::FAILED;
 
        download->cb(download);
    }
 
    startTransfersFromQueue();
 
    return ((still_alive) || (msgs_left > 0) || (queue.size() > 0));
#else
    return false;
#endif
}

quit()

void Chesto::DownloadQueue::quit ( )

static

Definition at line 51 of file DownloadQueue.cpp.

{
    delete downloadQueue;
}

Member Data Documentation

downloadQueue

DownloadQueue * Chesto::DownloadQueue::downloadQueue = NULL

static

Definition at line 59 of file DownloadQueue.hpp.

---

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

• src/DownloadQueue.hpp
• src/DownloadQueue.cpp