blob: 544a5c4a28ea81a48057d30b2f78bed9b2d3636d (
plain)
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
|
#pragma once
#include <atomic>
#include <chrono>
#include <mutex>
#include <string>
#include <curl/curl.h>
#include "XTransport.h"
namespace vagt
{
namespace transport
{
class XLibcurlTransport: public XTransport
{
public:
XLibcurlTransport(const XTransportOption& option);
virtual ~XLibcurlTransport() {}
virtual XErrorCode start() override;
virtual XErrorCode stop() override;
virtual XErrorCode post(const std::string& event) override;
private:
XErrorCode initLibcurl();
XErrorCode cleanupLibcurl();
XErrorCode curlPost(const std::string& body);
static char curlErrorBuf_[CURL_ERROR_SIZE];
static size_t readCallback(void *ptr, size_t size, size_t nmemb, void *userp);
static size_t writeCallback(void *ptr, size_t size, size_t nmemb, void *userp);
XTransportOption option_;
CURL* curl_;
struct curl_slist* hdr_;
};
}
}
|
