ucb/source/ucp/ftp/ftploaderthread.cxx

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: ftploaderthread.cxx,v $
  10  * $Revision: 1.10 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 // MARKER(update_precomp.py): autogen include statement, do not remove
  32 #include "precompiled_ucb.hxx"
  33 /**************************************************************************
  34                                 TODO
  35  **************************************************************************
  36
  37  *************************************************************************/
  38 #include "ftploaderthread.hxx"
  39 #include "curl.hxx"
  40
  41 using namespace ftp;
  42
  43
  44 /********************************************************************************/
  45 /*                                                                              */
  46 /*                cleanup function for thread specific data                     */
  47 /*                                                                              */
  48 /********************************************************************************/
  49
  50
  51 #ifdef __cplusplus
  52 extern "C" {
  53 #endif
  54
  55     int memory_write_dummy(void *,size_t,size_t,void *)
  56     {
  57         return 0;
  58     }
  59
  60     void delete_CURL(void *pData)
  61     {
  62         // Otherwise response for QUIT will be sent to already destroyed
  63         // MemoryContainer via non-dummy memory_write function.
  64         curl_easy_setopt(static_cast<CURL*>(pData),
  65                          CURLOPT_HEADERFUNCTION,
  66                          memory_write_dummy);
  67         curl_easy_cleanup(static_cast<CURL*>(pData));
  68     }
  69
  70 #ifdef __cplusplus
  71 }
  72 #endif
  73
  74
  75 /********************************************************************************/
  76 /*                                                                              */
  77 /*                  Member part of FTPLoaderThread                              */
  78 /*                                                                              */
  79 /********************************************************************************/
  80
  81
  82 FTPLoaderThread::FTPLoaderThread()
  83     : m_threadKey(osl_createThreadKey(delete_CURL)) {
  84 }
  85
  86
  87
  88 FTPLoaderThread::~FTPLoaderThread() {
  89     osl_destroyThreadKey(m_threadKey);
  90 }
  91
  92
  93
  94 CURL* FTPLoaderThread::handle() {
  95     CURL* ret = osl_getThreadKeyData(m_threadKey);
  96     if(!ret) {
  97         ret = curl_easy_init();
  98         if (ret != 0) {
  99             // Make sure curl is not internally using environment variables like
 100             // "ftp_proxy":
 101             if (curl_easy_setopt(ret, CURLOPT_PROXY, "") != CURLE_OK) {
 102                 curl_easy_cleanup(ret);
 103                 ret = 0;
 104             }
 105         }
 106         osl_setThreadKeyData(m_threadKey,static_cast<void*>(ret));
 107     }
 108
 109     return ret;
 110 }
 111
 112