summaryrefslogtreecommitdiff
path: root/extensions/source/update/check/download.cxx
diff options
context:
space:
mode:
authorMichael Stahl <mstahl@redhat.com>2012-01-28 20:52:45 +0100
committerMichael Stahl <mstahl@redhat.com>2012-01-28 20:52:45 +0100
commit2e626373db2412ac22e8c5c27a60d11cd29e875b (patch)
tree9e9f67205cd5b72f1031721273e1534a3a1e5b0f /extensions/source/update/check/download.cxx
parentf7ee7bbd5174b084f018c2ec94d8c70c98ee04da (diff)
replace obsolete "master" branch with README that points at new repoHEADmaster-deletedmaster
Diffstat (limited to 'extensions/source/update/check/download.cxx')
-rw-r--r--extensions/source/update/check/download.cxx463
1 files changed, 0 insertions, 463 deletions
diff --git a/extensions/source/update/check/download.cxx b/extensions/source/update/check/download.cxx
deleted file mode 100644
index ff1905be1..000000000
--- a/extensions/source/update/check/download.cxx
+++ /dev/null
@@ -1,463 +0,0 @@
-/* -*- Mode: C++; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
-/*************************************************************************
- *
- * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
- *
- * Copyright 2000, 2010 Oracle and/or its affiliates.
- *
- * OpenOffice.org - a multi-platform office productivity suite
- *
- * This file is part of OpenOffice.org.
- *
- * OpenOffice.org is free software: you can redistribute it and/or modify
- * it under the terms of the GNU Lesser General Public License version 3
- * only, as published by the Free Software Foundation.
- *
- * OpenOffice.org 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 Lesser General Public License version 3 for more details
- * (a copy is included in the LICENSE file that accompanied this code).
- *
- * You should have received a copy of the GNU Lesser General Public License
- * version 3 along with OpenOffice.org. If not, see
- * <http://www.openoffice.org/license.html>
- * for a copy of the LGPLv3 License.
- *
- ************************************************************************/
-
-// MARKER(update_precomp.py): autogen include statement, do not remove
-#include "precompiled_extensions.hxx"
-
-#if defined WNT
-#ifdef _MSC_VER
-#pragma warning(push, 1) /* disable warnings within system headers */
-#endif
-#include <curl/curl.h>
-#ifdef _MSC_VER
-#pragma warning(pop)
-#endif
-#else
-#include <curl/curl.h>
-#endif
-#include <com/sun/star/beans/PropertyValue.hpp>
-#include <com/sun/star/container/XNameAccess.hpp>
-#include <com/sun/star/lang/XMultiServiceFactory.hpp>
-
-#include "download.hxx"
-
-namespace beans = com::sun::star::beans ;
-namespace container = com::sun::star::container ;
-namespace lang = com::sun::star::lang ;
-namespace uno = com::sun::star::uno ;
-
-#define UNISTRING(s) rtl::OUString(RTL_CONSTASCII_USTRINGPARAM(s))
-
-
-struct OutData
-{
- rtl::Reference< DownloadInteractionHandler >Handler;
- rtl::OUString File;
- rtl::OUString DestinationDir;
- oslFileHandle FileHandle;
- sal_uInt64 Offset;
- osl::Condition& StopCondition;
- CURL *curl;
-
- OutData(osl::Condition& rCondition) : FileHandle(NULL), Offset(0), StopCondition(rCondition), curl(NULL) {};
-};
-
-//------------------------------------------------------------------------------
-
-static void openFile( OutData& out )
-{
- char * effective_url;
- curl_easy_getinfo(out.curl, CURLINFO_EFFECTIVE_URL, &effective_url);
-
- double fDownloadSize;
- curl_easy_getinfo(out.curl, CURLINFO_CONTENT_LENGTH_DOWNLOAD, &fDownloadSize);
-
- rtl::OString aURL(effective_url);
-
- // ensure no trailing '/'
- sal_Int32 nLen = aURL.getLength();
- while( (nLen > 0) && ('/' == aURL[nLen-1]) )
- aURL = aURL.copy(0, --nLen);
-
- // extract file name last '/'
- sal_Int32 nIndex = aURL.lastIndexOf('/');
- if( nIndex > 0 )
- {
- out.File = out.DestinationDir + rtl::OStringToOUString(aURL.copy(nIndex), RTL_TEXTENCODING_UTF8);
-
- oslFileError rc;
-
- // Give the user an overwrite warning if the target file exists
- const sal_Int32 openFlags = osl_File_OpenFlag_Write | osl_File_OpenFlag_Create;
- do
- {
- rc = osl_openFile(out.File.pData, &out.FileHandle, openFlags);
-
- if( osl_File_E_EXIST == rc && ! out.Handler->downloadTargetExists(out.File) )
- {
- out.StopCondition.set();
- break;
- }
-
- } while( osl_File_E_EXIST == rc );
-
- if( osl_File_E_None == rc )
- out.Handler->downloadStarted(out.File, (sal_Int64) fDownloadSize);
- }
-}
-
-//------------------------------------------------------------------------------
-
-static inline rtl::OString
-getStringValue(const uno::Reference< container::XNameAccess >& xNameAccess, const rtl::OUString& aName)
-{
- rtl::OString aRet;
-
- OSL_ASSERT(xNameAccess->hasByName(aName));
- uno::Any aValue = xNameAccess->getByName(aName);
-
- return rtl::OUStringToOString(aValue.get<rtl::OUString>(), RTL_TEXTENCODING_UTF8);
-}
-
-//------------------------------------------------------------------------------
-
-static inline sal_Int32
-getInt32Value(const uno::Reference< container::XNameAccess >& xNameAccess,
- const rtl::OUString& aName, sal_Int32 nDefault=-1)
-{
- OSL_ASSERT(xNameAccess->hasByName(aName));
- uno::Any aValue = xNameAccess->getByName(aName);
-
- sal_Int32 n=nDefault;
- aValue >>= n;
- return n;
-}
-
-//------------------------------------------------------------------------------
-
-static size_t
-write_function( void *ptr, size_t size, size_t nmemb, void *stream )
-{
- OutData *out = reinterpret_cast < OutData * > (stream);
-
- if( NULL == out->FileHandle )
- openFile(*out);
-
- sal_uInt64 nBytesWritten = 0;
-
- if( NULL != out->FileHandle )
- osl_writeFile(out->FileHandle, ptr, size * nmemb, &nBytesWritten);
-
- return (size_t) nBytesWritten;
-}
-
-//------------------------------------------------------------------------------
-
-static int
-progress_callback( void *clientp, double dltotal, double dlnow, double ultotal, double ulnow )
-{
- (void) ultotal;
- (void) ulnow;
-
- OutData *out = reinterpret_cast < OutData * > (clientp);
-
- OSL_ASSERT( out );
-
- if( ! out->StopCondition.check() )
- {
- double fPercent = 0;
- if ( dltotal + out->Offset )
- fPercent = (dlnow + out->Offset) * 100 / (dltotal + out->Offset);
- if( fPercent < 0 )
- fPercent = 0;
-
- // Do not report progress for redirection replies
- long nCode;
- curl_easy_getinfo(out->curl, CURLINFO_RESPONSE_CODE, &nCode);
- if( (nCode != 302) && (nCode != 303) && (dltotal > 0) )
- out->Handler->downloadProgressAt((sal_Int8)fPercent);
-
- return 0;
- }
-
- // If stop condition is set, return non 0 value to abort
- return -1;
-}
-
-//------------------------------------------------------------------------------
-
-void
-Download::getProxyForURL(const rtl::OUString& rURL, rtl::OString& rHost, sal_Int32& rPort) const
-{
- if( !m_xContext.is() )
- throw uno::RuntimeException(
- UNISTRING( "Download: empty component context" ),
- uno::Reference< uno::XInterface >() );
-
- uno::Reference< lang::XMultiComponentFactory > xServiceManager(m_xContext->getServiceManager());
-
- if( !xServiceManager.is() )
- throw uno::RuntimeException(
- UNISTRING( "Download: unable to obtain service manager from component context" ),
- uno::Reference< uno::XInterface >() );
-
- uno::Reference< lang::XMultiServiceFactory > xConfigProvider(
- xServiceManager->createInstanceWithContext( UNISTRING( "com.sun.star.configuration.ConfigurationProvider" ), m_xContext ),
- uno::UNO_QUERY_THROW);
-
- beans::PropertyValue aProperty;
- aProperty.Name = UNISTRING( "nodepath" );
- aProperty.Value = uno::makeAny( UNISTRING("org.openoffice.Inet/Settings") );
-
- uno::Sequence< uno::Any > aArgumentList( 1 );
- aArgumentList[0] = uno::makeAny( aProperty );
-
- uno::Reference< container::XNameAccess > xNameAccess(
- xConfigProvider->createInstanceWithArguments(
- UNISTRING("com.sun.star.configuration.ConfigurationAccess"), aArgumentList ),
- uno::UNO_QUERY_THROW );
-
- OSL_ASSERT(xNameAccess->hasByName(UNISTRING("ooInetProxyType")));
- uno::Any aValue = xNameAccess->getByName(UNISTRING("ooInetProxyType"));
-
- sal_Int32 nProxyType = aValue.get< sal_Int32 >();
- if( 0 != nProxyType ) // type 0 means "direct connection to the internet
- {
- if( rURL.matchAsciiL(RTL_CONSTASCII_STRINGPARAM("http:")) )
- {
- rHost = getStringValue(xNameAccess, UNISTRING("ooInetHTTPProxyName"));
- rPort = getInt32Value(xNameAccess, UNISTRING("ooInetHTTPProxyPort"));
- }
- else if( rURL.matchAsciiL(RTL_CONSTASCII_STRINGPARAM("https:")) )
- {
- rHost = getStringValue(xNameAccess, UNISTRING("ooInetHTTPSProxyName"));
- rPort = getInt32Value(xNameAccess, UNISTRING("ooInetHTTPSProxyPort"));
- }
- else if( rURL.matchAsciiL(RTL_CONSTASCII_STRINGPARAM("ftp:")) )
- {
- rHost = getStringValue(xNameAccess, UNISTRING("ooInetFTPProxyName"));
- rPort = getInt32Value(xNameAccess, UNISTRING("ooInetFTPProxyPort"));
- }
- }
-}
-
-//------------------------------------------------------------------------------
-
-bool curl_run(const rtl::OUString& rURL, OutData& out, const rtl::OString& aProxyHost, sal_Int32 nProxyPort)
-{
- /* Need to investigate further whether it is necessary to call
- * curl_global_init or not - leave it for now (as the ftp UCB content
- * provider does as well).
- */
-
- CURL * pCURL = curl_easy_init();
- bool ret = false;
-
- if( NULL != pCURL )
- {
- out.curl = pCURL;
-
- rtl::OString aURL(rtl::OUStringToOString(rURL, RTL_TEXTENCODING_UTF8));
- curl_easy_setopt(pCURL, CURLOPT_URL, aURL.getStr());
-
- // abort on http errors
- curl_easy_setopt(pCURL, CURLOPT_FAILONERROR, 1);
-
- // enable redirection
- curl_easy_setopt(pCURL, CURLOPT_FOLLOWLOCATION, 1);
-
- // write function
- curl_easy_setopt(pCURL, CURLOPT_WRITEDATA, &out);
- curl_easy_setopt(pCURL, CURLOPT_WRITEFUNCTION, &write_function);
-
- // progress handler - Condition::check unfortunatly is not defined const
- curl_easy_setopt(pCURL, CURLOPT_NOPROGRESS, 0);
- curl_easy_setopt(pCURL, CURLOPT_PROGRESSFUNCTION, &progress_callback);
- curl_easy_setopt(pCURL, CURLOPT_PROGRESSDATA, &out);
-
- // proxy
- curl_easy_setopt(pCURL, CURLOPT_PROXY, aProxyHost.getStr());
- curl_easy_setopt(pCURL, CURLOPT_PROXYTYPE, CURLPROXY_HTTP);
- if( -1 != nProxyPort )
- curl_easy_setopt(pCURL, CURLOPT_PROXYPORT, nProxyPort);
-
- if( out.Offset > 0 )
- {
- // curl_off_t offset = nOffset; libcurl seems to be compiled with large
- // file support (and we not) ..
- sal_Int64 offset = (sal_Int64) out.Offset;
- curl_easy_setopt(pCURL, CURLOPT_RESUME_FROM_LARGE, offset);
- }
-
- CURLcode cc = curl_easy_perform(pCURL);
-
- // treat zero byte downloads as errors
- if( NULL == out.FileHandle )
- openFile(out);
-
- if( CURLE_OK == cc )
- {
- out.Handler->downloadFinished(out.File);
- ret = true;
- }
-
- if ( CURLE_PARTIAL_FILE == cc )
- {
- // this sometimes happens, when a user throws away his user data, but has already
- // completed the download of an update.
- double fDownloadSize;
- curl_easy_getinfo( pCURL, CURLINFO_CONTENT_LENGTH_DOWNLOAD, &fDownloadSize );
- if ( -1 == fDownloadSize )
- {
- out.Handler->downloadFinished(out.File);
- ret = true;
- }
- }
-
- // Avoid target file being removed
- else if( (CURLE_ABORTED_BY_CALLBACK == cc) || out.StopCondition.check() )
- ret = true;
-
- // Only report errors when not stopped
- else
- {
- rtl::OString aMessage(RTL_CONSTASCII_STRINGPARAM("Unknown error"));
-
- const char * error_message = curl_easy_strerror(cc);
- if( NULL != error_message )
- aMessage = error_message;
-
- if ( CURLE_HTTP_RETURNED_ERROR == cc )
- {
- long nError;
- curl_easy_getinfo( pCURL, CURLINFO_RESPONSE_CODE, &nError );
-
- if ( 403 == nError )
- aMessage += rtl::OString( RTL_CONSTASCII_STRINGPARAM( " 403: Access denied!" ) );
- else if ( 404 == nError )
- aMessage += rtl::OString( RTL_CONSTASCII_STRINGPARAM( " 404: File not found!" ) );
- else if ( 416 == nError )
- {
- // we got this error probably, because we already downloaded the file
- out.Handler->downloadFinished(out.File);
- ret = true;
- }
- else
- {
- aMessage += rtl::OString( RTL_CONSTASCII_STRINGPARAM( ":error code = " ) );
- aMessage += aMessage.valueOf( nError );
- aMessage += rtl::OString( RTL_CONSTASCII_STRINGPARAM( " !" ) );
- }
- }
- if ( !ret )
- out.Handler->downloadStalled( rtl::OStringToOUString(aMessage, RTL_TEXTENCODING_UTF8) );
- }
-
- curl_easy_cleanup(pCURL);
- }
-
- return ret;
-}
-
-//------------------------------------------------------------------------------
-
-bool
-Download::start(const rtl::OUString& rURL, const rtl::OUString& rFile, const rtl::OUString& rDestinationDir)
-{
- OSL_ASSERT( m_aHandler.is() );
-
- OutData out(m_aCondition);
- rtl::OUString aFile( rFile );
-
- // when rFile is empty, there is no remembered file name. If there is already a file with the
- // same name ask the user if she wants to resume a download or restart the download
- if ( !aFile.getLength() )
- {
- // GetFileName()
- rtl::OUString aURL( rURL );
- // ensure no trailing '/'
- sal_Int32 nLen = aURL.getLength();
- while( (nLen > 0) && ('/' == aURL[ nLen-1 ]) )
- aURL = aURL.copy( 0, --nLen );
-
- // extract file name last '/'
- sal_Int32 nIndex = aURL.lastIndexOf('/');
- aFile = rDestinationDir + aURL.copy( nIndex );
-
- // check for existing file
- oslFileError rc = osl_openFile( aFile.pData, &out.FileHandle, osl_File_OpenFlag_Write | osl_File_OpenFlag_Create );
- osl_closeFile(out.FileHandle);
- out.FileHandle = NULL;
-
- if( osl_File_E_EXIST == rc )
- {
- if ( m_aHandler->checkDownloadDestination( aURL.copy( nIndex+1 ) ) )
- {
- osl_removeFile( aFile.pData );
- aFile = rtl::OUString();
- }
- else
- m_aHandler->downloadStarted( aFile, 0 );
- }
- else
- {
- osl_removeFile( aFile.pData );
- aFile = rtl::OUString();
- }
- }
-
- out.File = aFile;
- out.DestinationDir = rDestinationDir;
- out.Handler = m_aHandler;
-
- if( aFile.getLength() > 0 )
- {
- oslFileError rc = osl_openFile(aFile.pData, &out.FileHandle, osl_File_OpenFlag_Write);
-
- if( osl_File_E_None == rc )
- {
- // Set file pointer to the end of the file on resume
- if( osl_File_E_None == osl_setFilePos(out.FileHandle, osl_Pos_End, 0) )
- {
- osl_getFilePos(out.FileHandle, &out.Offset);
- }
- }
- else if( osl_File_E_NOENT == rc ) // file has been deleted meanwhile ..
- out.File = rtl::OUString();
- }
-
- rtl::OString aProxyHost;
- sal_Int32 nProxyPort = -1;
- getProxyForURL(rURL, aProxyHost, nProxyPort);
-
- bool ret = curl_run(rURL, out, aProxyHost, nProxyPort);
-
- if( NULL != out.FileHandle )
- {
- osl_syncFile(out.FileHandle);
- osl_closeFile(out.FileHandle);
-
-// #i90930# Don't remove already downloaded bits, when curl_run reports an error
-// because later calls might be successful
-// if( ! ret )
-// osl_removeFile(out.File.pData);
- }
-
- m_aCondition.reset();
- return ret;
-}
-
-//------------------------------------------------------------------------------
-
-void
-Download::stop()
-{
- m_aCondition.set();
-}
-
-/* vim:set shiftwidth=4 softtabstop=4 expandtab: */