Monitoring/src/Transports/HTTP.cxx at b16f2a750ee7c3d5a70462bc20b1d81923172134 · AliceO2Group/Monitoring · GitHub

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
///
/// \file HTTP.cxx
/// \author Adam Wegrzynek <adam.wegrzynek@cern.ch>
///

#include "HTTP.h"
#include "../MonLogger.h"
#include "../Exceptions/MonitoringException.h"
#include <boost/algorithm/string.hpp>

namespace o2
{
/// ALICE O2 Monitoring system
namespace monitoring
{
/// Monitoring transports
namespace transports
{

HTTP::HTTP(const std::string& url)
{
  mHeaders = NULL;
  mCurl = curl_easy_init();
  curl_easy_setopt(mCurl, CURLOPT_URL, url.c_str());
  curl_easy_setopt(mCurl, CURLOPT_SSL_VERIFYPEER, 0);
  curl_easy_setopt(mCurl, CURLOPT_CONNECTTIMEOUT, 10);
  curl_easy_setopt(mCurl, CURLOPT_TIMEOUT, 10);
  curl_easy_setopt(mCurl, CURLOPT_POST, 1);
  curl_easy_setopt(mCurl, CURLOPT_TCP_KEEPIDLE, 120L);
  curl_easy_setopt(mCurl, CURLOPT_TCP_KEEPINTVL, 60L);
  FILE *devnull = fopen("/dev/null", "w+");
  curl_easy_setopt(mCurl, CURLOPT_WRITEDATA, devnull);

  MonLogger::Get() << "HTTP transport initialized (" << url << ")" << MonLogger::End();
}

HTTP::~HTTP()
{
  curl_slist_free_all(mHeaders);
  curl_easy_cleanup(mCurl);
  curl_global_cleanup();
}

void HTTP::addHeader(const std::string& header)
{
  mHeaders = curl_slist_append(mHeaders, header.c_str());
  curl_easy_setopt(mCurl,  CURLOPT_HTTPHEADER, mHeaders);
}

void HTTP::send(std::string&& post)
{
  CURLcode response;
  long responseCode;
  curl_easy_setopt(mCurl, CURLOPT_POSTFIELDS, post.c_str());
  curl_easy_setopt(mCurl, CURLOPT_POSTFIELDSIZE, (long) post.length());
  response = curl_easy_perform(mCurl);
  curl_easy_getinfo(mCurl, CURLINFO_RESPONSE_CODE, &responseCode);
  if (response != CURLE_OK) {
    MonLogger::Get() << "HTTP Tranport " << curl_easy_strerror(response) << MonLogger::End();
  }
  if (responseCode < 200 || responseCode > 206) {
    MonLogger::Get() << "HTTP Transport: Response code : " << std::to_string(responseCode) << MonLogger::End();
  }
}

} // namespace transports
} // namespace monitoring
} // namespace o2