Merge pull request #8 from ReCodEx/sweeping-skeletons

Sweeping skeletons

CMakeLists.txt

@@ -38,8 +38,6 @@ set(SOURCE_FILES
 	src/worker.h
 	src/worker.cpp
 	src/notifier/status_notifier.h
-	src/notifier/http_status_notifier.h
-	src/notifier/http_status_notifier.cpp
 	src/notifier/empty_status_notifier.h
 	src/reactor/reactor.h
 	src/reactor/reactor.cpp

src/broker_core.h

@@ -21,7 +21,6 @@ namespace fs = boost::filesystem;
 #include "broker_connect.h"
 #include "config/broker_config.h"
 #include "config/log_config.h"
-#include "notifier/http_status_notifier.h"
 #include "reactor/command_holder.h"
 
 

src/handlers/status_notifier_handler.cpp

@@ -1,8 +1,11 @@
+#include "../helpers/curl.h"
+#include "status_notifier_handler.h"
+
 #include <map>
 #include <sstream>
+#include <thread>
+#include <chrono>
 
-#include "../helpers/curl.h"
-#include "status_notifier_handler.h"
 
 const std::string status_notifier_handler::TYPE_ERROR = "error";
 const std::string status_notifier_handler::TYPE_JOB_STATUS = "job-status";
@@ -47,9 +50,17 @@ void status_notifier_handler::on_request(
 		ss << "/" << id;
 	}
 
-	try {
-		helpers::curl_post(ss.str(), config_.port, params, config_.username, config_.password);
-	} catch (helpers::curl_exception &exception) {
-		logger_->critical("curl failed: {}", exception.what());
+	std::size_t retries = 4; // we come by this value using digital suction
+	auto delay = std::chrono::seconds(1);
+	while (retries > 0) {
+		--retries;
+		try {
+			helpers::curl_post(ss.str(), config_.port, params, config_.username, config_.password);
+			return; // success, nothing else to try
+		} catch (helpers::curl_exception &exception) {
+			logger_->critical("curl failed: {}", exception.what());
+			std::this_thread::sleep_for(delay);
+			delay *= 2; // exponentially growing waiting intervals are cool
+		}
 	}
 }