1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
|
/*
* Copyright (C) 2005-2018 Team Kodi
* This file is part of Kodi - https://kodi.tv
*
* SPDX-License-Identifier: GPL-2.0-or-later
* See LICENSES/README.md for more information.
*/
#pragma once
#include "threads/CriticalSection.h"
#include <stdio.h>
#include <string>
#include <sys/time.h>
#include <sys/types.h>
#include <type_traits>
#include <vector>
#define CURL CURL_HANDLE
#include <curl/curl.h>
#undef CURL
namespace XCURL
{
class DllLibCurl
{
public:
virtual ~DllLibCurl() = default;
CURLcode global_init(long flags);
void global_cleanup();
CURL_HANDLE* easy_init();
template<typename... Args>
CURLcode easy_setopt(CURL_HANDLE* handle, CURLoption option, Args... args)
{
return curl_easy_setopt(handle, option, std::forward<Args>(args)...);
}
CURLcode easy_perform(CURL_HANDLE* handle);
CURLcode easy_pause(CURL_HANDLE* handle, int bitmask);
void easy_reset(CURL_HANDLE* handle);
template<typename... Args>
CURLcode easy_getinfo(CURL_HANDLE* curl, CURLINFO info, Args... args)
{
return curl_easy_getinfo(curl, info, std::forward<Args>(args)...);
}
void easy_cleanup(CURL_HANDLE* handle);
virtual CURL_HANDLE* easy_duphandle(CURL_HANDLE* handle);
CURLM* multi_init(void);
CURLMcode multi_add_handle(CURLM* multi_handle, CURL_HANDLE* easy_handle);
CURLMcode multi_perform(CURLM* multi_handle, int* running_handles);
CURLMcode multi_remove_handle(CURLM* multi_handle, CURL_HANDLE* easy_handle);
CURLMcode multi_fdset(CURLM* multi_handle,
fd_set* read_fd_set,
fd_set* write_fd_set,
fd_set* exc_fd_set,
int* max_fd);
CURLMcode multi_timeout(CURLM* multi_handle, long* timeout);
CURLMsg* multi_info_read(CURLM* multi_handle, int* msgs_in_queue);
CURLMcode multi_cleanup(CURLM* handle);
curl_slist* slist_append(curl_slist* list, const char* to_append);
void slist_free_all(curl_slist* list);
const char* easy_strerror(CURLcode code);
};
class DllLibCurlGlobal : public DllLibCurl
{
public:
DllLibCurlGlobal();
~DllLibCurlGlobal();
/* extend interface with buffered functions */
void easy_acquire(const char* protocol,
const char* hostname,
CURL_HANDLE** easy_handle,
CURLM** multi_handle);
void easy_release(CURL_HANDLE** easy_handle, CURLM** multi_handle);
void easy_duplicate(CURL_HANDLE* easy,
const CURLM* multi,
CURL_HANDLE** easy_out,
CURLM** multi_out);
CURL_HANDLE* easy_duphandle(CURL_HANDLE* easy_handle) override;
void CheckIdle();
/* overloaded load and unload with reference counter */
/* structure holding a session info */
typedef struct SSession
{
std::chrono::time_point<std::chrono::steady_clock>
m_idletimestamp; // timestamp of when this object when idle
std::string m_protocol;
std::string m_hostname;
bool m_busy;
CURL_HANDLE* m_easy;
CURLM* m_multi;
} SSession;
typedef std::vector<SSession> VEC_CURLSESSIONS;
VEC_CURLSESSIONS m_sessions;
CCriticalSection m_critSection;
};
} // namespace XCURL
extern XCURL::DllLibCurlGlobal g_curlInterface;
|
