1*b1cdbd2cSJim Jagielski /**************************************************************
2*b1cdbd2cSJim Jagielski *
3*b1cdbd2cSJim Jagielski * Licensed to the Apache Software Foundation (ASF) under one
4*b1cdbd2cSJim Jagielski * or more contributor license agreements. See the NOTICE file
5*b1cdbd2cSJim Jagielski * distributed with this work for additional information
6*b1cdbd2cSJim Jagielski * regarding copyright ownership. The ASF licenses this file
7*b1cdbd2cSJim Jagielski * to you under the Apache License, Version 2.0 (the
8*b1cdbd2cSJim Jagielski * "License"); you may not use this file except in compliance
9*b1cdbd2cSJim Jagielski * with the License. You may obtain a copy of the License at
10*b1cdbd2cSJim Jagielski *
11*b1cdbd2cSJim Jagielski * http://www.apache.org/licenses/LICENSE-2.0
12*b1cdbd2cSJim Jagielski *
13*b1cdbd2cSJim Jagielski * Unless required by applicable law or agreed to in writing,
14*b1cdbd2cSJim Jagielski * software distributed under the License is distributed on an
15*b1cdbd2cSJim Jagielski * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
16*b1cdbd2cSJim Jagielski * KIND, either express or implied. See the License for the
17*b1cdbd2cSJim Jagielski * specific language governing permissions and limitations
18*b1cdbd2cSJim Jagielski * under the License.
19*b1cdbd2cSJim Jagielski *
20*b1cdbd2cSJim Jagielski *************************************************************/
21*b1cdbd2cSJim Jagielski
22*b1cdbd2cSJim Jagielski
23*b1cdbd2cSJim Jagielski
24*b1cdbd2cSJim Jagielski // MARKER(update_precomp.py): autogen include statement, do not remove
25*b1cdbd2cSJim Jagielski #include "precompiled_ucb.hxx"
26*b1cdbd2cSJim Jagielski /**************************************************************************
27*b1cdbd2cSJim Jagielski TODO
28*b1cdbd2cSJim Jagielski **************************************************************************
29*b1cdbd2cSJim Jagielski
30*b1cdbd2cSJim Jagielski *************************************************************************/
31*b1cdbd2cSJim Jagielski #include "ftploaderthread.hxx"
32*b1cdbd2cSJim Jagielski #include "curl.hxx"
33*b1cdbd2cSJim Jagielski
34*b1cdbd2cSJim Jagielski using namespace ftp;
35*b1cdbd2cSJim Jagielski
36*b1cdbd2cSJim Jagielski
37*b1cdbd2cSJim Jagielski /********************************************************************************/
38*b1cdbd2cSJim Jagielski /* */
39*b1cdbd2cSJim Jagielski /* cleanup function for thread specific data */
40*b1cdbd2cSJim Jagielski /* */
41*b1cdbd2cSJim Jagielski /********************************************************************************/
42*b1cdbd2cSJim Jagielski
43*b1cdbd2cSJim Jagielski
44*b1cdbd2cSJim Jagielski #ifdef __cplusplus
45*b1cdbd2cSJim Jagielski extern "C" {
46*b1cdbd2cSJim Jagielski #endif
47*b1cdbd2cSJim Jagielski
memory_write_dummy(void *,size_t,size_t,void *)48*b1cdbd2cSJim Jagielski int memory_write_dummy(void *,size_t,size_t,void *)
49*b1cdbd2cSJim Jagielski {
50*b1cdbd2cSJim Jagielski return 0;
51*b1cdbd2cSJim Jagielski }
52*b1cdbd2cSJim Jagielski
delete_CURL(void * pData)53*b1cdbd2cSJim Jagielski void delete_CURL(void *pData)
54*b1cdbd2cSJim Jagielski {
55*b1cdbd2cSJim Jagielski // Otherwise response for QUIT will be sent to already destroyed
56*b1cdbd2cSJim Jagielski // MemoryContainer via non-dummy memory_write function.
57*b1cdbd2cSJim Jagielski curl_easy_setopt(static_cast<CURL*>(pData),
58*b1cdbd2cSJim Jagielski CURLOPT_HEADERFUNCTION,
59*b1cdbd2cSJim Jagielski memory_write_dummy);
60*b1cdbd2cSJim Jagielski curl_easy_cleanup(static_cast<CURL*>(pData));
61*b1cdbd2cSJim Jagielski }
62*b1cdbd2cSJim Jagielski
63*b1cdbd2cSJim Jagielski #ifdef __cplusplus
64*b1cdbd2cSJim Jagielski }
65*b1cdbd2cSJim Jagielski #endif
66*b1cdbd2cSJim Jagielski
67*b1cdbd2cSJim Jagielski
68*b1cdbd2cSJim Jagielski /********************************************************************************/
69*b1cdbd2cSJim Jagielski /* */
70*b1cdbd2cSJim Jagielski /* Member part of FTPLoaderThread */
71*b1cdbd2cSJim Jagielski /* */
72*b1cdbd2cSJim Jagielski /********************************************************************************/
73*b1cdbd2cSJim Jagielski
74*b1cdbd2cSJim Jagielski
FTPLoaderThread()75*b1cdbd2cSJim Jagielski FTPLoaderThread::FTPLoaderThread()
76*b1cdbd2cSJim Jagielski : m_threadKey(osl_createThreadKey(delete_CURL)) {
77*b1cdbd2cSJim Jagielski }
78*b1cdbd2cSJim Jagielski
79*b1cdbd2cSJim Jagielski
80*b1cdbd2cSJim Jagielski
~FTPLoaderThread()81*b1cdbd2cSJim Jagielski FTPLoaderThread::~FTPLoaderThread() {
82*b1cdbd2cSJim Jagielski osl_destroyThreadKey(m_threadKey);
83*b1cdbd2cSJim Jagielski }
84*b1cdbd2cSJim Jagielski
85*b1cdbd2cSJim Jagielski
86*b1cdbd2cSJim Jagielski
handle()87*b1cdbd2cSJim Jagielski CURL* FTPLoaderThread::handle() {
88*b1cdbd2cSJim Jagielski CURL* ret = osl_getThreadKeyData(m_threadKey);
89*b1cdbd2cSJim Jagielski if(!ret) {
90*b1cdbd2cSJim Jagielski ret = curl_easy_init();
91*b1cdbd2cSJim Jagielski if (ret != 0) {
92*b1cdbd2cSJim Jagielski // Make sure curl is not internally using environment variables like
93*b1cdbd2cSJim Jagielski // "ftp_proxy":
94*b1cdbd2cSJim Jagielski if (curl_easy_setopt(ret, CURLOPT_PROXY, "") != CURLE_OK) {
95*b1cdbd2cSJim Jagielski curl_easy_cleanup(ret);
96*b1cdbd2cSJim Jagielski ret = 0;
97*b1cdbd2cSJim Jagielski }
98*b1cdbd2cSJim Jagielski }
99*b1cdbd2cSJim Jagielski osl_setThreadKeyData(m_threadKey,static_cast<void*>(ret));
100*b1cdbd2cSJim Jagielski }
101*b1cdbd2cSJim Jagielski
102*b1cdbd2cSJim Jagielski return ret;
103*b1cdbd2cSJim Jagielski }
104*b1cdbd2cSJim Jagielski
105*b1cdbd2cSJim Jagielski
106