OnlineDBOutputService.cc File Reference

#include "CondCore/DBOutputService/interface/OnlineDBOutputService.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include <curl/curl.h>

Go to the source code of this file.

Namespaces
	cond

Functions
static size_t	getHtmlCallback (void *contents, size_t size, size_t nmemb, void *ptr)
bool	getInfoFromService (const std::string &urlString, std::string &info)
cond::Time_t	cond::getLastLumiFromOMS (const std::string &omsServiceUrl)
cond::Time_t	cond::getLatestLumiFromFile (const std::string &fileName)

Function Documentation

getHtmlCallback()

static size_t getHtmlCallback ( void *  contents, size_t  size, size_t  nmemb, void *  ptr  )

static

Definition at line 6 of file OnlineDBOutputService.cc.

References relmon_rootfiles_spy::contents, findQualityFiles::size, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by getInfoFromService().

                                                                                    {
  // Cast ptr to std::string pointer and append contents to that string
  ((std::string*)ptr)->append((char*)contents, size * nmemb);
  return size * nmemb;
}

getInfoFromService()

bool getInfoFromService	(	const std::string &	urlString,
		std::string &	info
	)

Definition at line 12 of file OnlineDBOutputService.cc.

References RooUtil::StringUtil::chunk(), getHtmlCallback(), info(), runTheMatrix::ret, submitPVResolutionJobs::stderr, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by cond::getLastLumiFromOMS().

                                                                     {
  CURL* curl;
  CURLcode res;
  std::string htmlBuffer;
  char errbuf[CURL_ERROR_SIZE];

  curl = curl_easy_init();
  bool ret = false;
  if (curl) {
    struct curl_slist* chunk = nullptr;
    chunk = curl_slist_append(chunk, "content-type:document/plain");
    curl_easy_setopt(curl, CURLOPT_HTTPHEADER, chunk);
    curl_easy_setopt(curl, CURLOPT_URL, urlString.c_str());
    curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION, getHtmlCallback);
    curl_easy_setopt(curl, CURLOPT_WRITEDATA, &htmlBuffer);
    curl_easy_setopt(curl, CURLOPT_ERRORBUFFER, errbuf);
    res = curl_easy_perform(curl);
    if (CURLE_OK == res) {
      info = htmlBuffer;
      ret = true;
    } else {
      size_t len = strlen(errbuf);
      fprintf(stderr, "\nlibcurl: (%d) ", res);
      if (len)
        fprintf(stderr, "%s%s", errbuf, ((errbuf[len - 1] != '\n') ? "\n" : ""));
      else
        fprintf(stderr, "%s\n", curl_easy_strerror(res));
    }
    curl_easy_cleanup(curl);
  }
  return ret;
}