blob: f4beec211d358326ec6a1f07312279c9e71079de [file] [log] [blame]
//========================================================================
//
// CurlCachedFile.cc
//
// This file is licensed under the GPLv2 or later
//
// Copyright 2009 Stefan Thomas <thomas@eload24.com>
// Copyright 2010 Hib Eris <hib@hiberis.nl>
// Copyright 2010 Albert Astals Cid <aacid@kde.org>
//
//========================================================================
#include <config.h>
#include "CurlCachedFile.h"
#include "goo/GooString.h"
//------------------------------------------------------------------------
CurlCachedFileLoader::CurlCachedFileLoader()
{
url = NULL;
cachedFile = NULL;
curl = NULL;
}
CurlCachedFileLoader::~CurlCachedFileLoader() {
curl_easy_cleanup(curl);
}
static size_t
noop_cb(char *ptr, size_t size, size_t nmemb, void *ptr2)
{
return size*nmemb;
}
size_t
CurlCachedFileLoader::init(GooString *urlA, CachedFile *cachedFileA)
{
long code = NULL;
double contentLength = -1;
size_t size;
url = urlA;
cachedFile = cachedFileA;
curl = curl_easy_init();
curl_easy_setopt(curl, CURLOPT_URL, url->getCString());
curl_easy_setopt(curl, CURLOPT_HEADER, 1);
curl_easy_setopt(curl, CURLOPT_NOBODY, 1);
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, &noop_cb);
curl_easy_perform(curl);
curl_easy_getinfo(curl, CURLINFO_RESPONSE_CODE, &code);
curl_easy_getinfo(curl, CURLINFO_CONTENT_LENGTH_DOWNLOAD, &contentLength);
curl_easy_reset(curl);
size = contentLength;
return size;
}
static
size_t load_cb(const char *ptr, size_t size, size_t nmemb, void *data)
{
CachedFileWriter *writer = (CachedFileWriter *) data;
return (writer->write) (ptr, size*nmemb);
}
int CurlCachedFileLoader::load(const std::vector<ByteRange> &ranges, CachedFileWriter *writer)
{
CURLcode r = CURLE_OK;
size_t fromByte, toByte;
for (size_t i = 0; i < ranges.size(); i++) {
fromByte = ranges[i].offset;
toByte = fromByte + ranges[i].length - 1;
GooString *range = GooString::format("{0:ud}-{1:ud}", fromByte, toByte);
curl_easy_setopt(curl, CURLOPT_URL, url->getCString());
curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, load_cb);
curl_easy_setopt(curl, CURLOPT_WRITEDATA, writer);
curl_easy_setopt(curl, CURLOPT_RANGE, range->getCString());
r = curl_easy_perform(curl);
curl_easy_reset(curl);
delete range;
if (r != CURLE_OK) break;
}
return r;
}
//------------------------------------------------------------------------