diff --git a/src/logging/writers/ElasticSearch.cc b/src/logging/writers/ElasticSearch.cc index 2da79ed7b9..cc6f8b1c4f 100644 --- a/src/logging/writers/ElasticSearch.cc +++ b/src/logging/writers/ElasticSearch.cc @@ -359,10 +359,10 @@ CURL* ElasticSearch::HTTPSetup() return handle; } -bool ElasticSearch::HTTPReceive(void* ptr, int size, int nmemb, void* userdata) +size_t ElasticSearch::HTTPReceive(void* ptr, int size, int nmemb, void* userdata) { //TODO: Do some verification on the result? - return true; + return size; } bool ElasticSearch::HTTPSend(CURL *handle) diff --git a/src/logging/writers/ElasticSearch.h b/src/logging/writers/ElasticSearch.h index 0d863f2f19..0e88bf3e88 100644 --- a/src/logging/writers/ElasticSearch.h +++ b/src/logging/writers/ElasticSearch.h @@ -45,7 +45,7 @@ private: bool UpdateIndex(double now, double rinterval, double rbase); CURL* HTTPSetup(); - bool HTTPReceive(void* ptr, int size, int nmemb, void* userdata); + size_t HTTPReceive(void* ptr, int size, int nmemb, void* userdata); bool HTTPSend(CURL *handle); // Buffers, etc.