Skip to content
Snippets Groups Projects
Commit 0b4d1559 authored by Mihai Patrascoiu's avatar Mihai Patrascoiu Committed by Louis Regnier
Browse files

Disable all "INSERT" and "UPDATE" operations from the OptimizerService

parent 111bcb6e
No related branches found
No related tags found
No related merge requests found
Pipeline #8066729 passed with stages
in 5 minutes and 12 seconds
......@@ -558,6 +558,9 @@ double MySqlAPI::getThroughputAsDestination(const std::string &se)
void MySqlAPI::storeOptimizerDecision(const Pair &pair, int activeDecision, const PairState &newState,
int diff, const std::string &rationale)
{
FTS3_COMMON_LOGGER_NEWLOG(INFO) << "OptimizerDataSource->storeOptimizerDecision(..) stub" << commit;
return;
try {
soci::session sql(*connectionPool);
setNewOptimizerValue(sql, pair, activeDecision, newState.ema);
......@@ -573,6 +576,9 @@ void MySqlAPI::storeOptimizerDecision(const Pair &pair, int activeDecision, cons
void MySqlAPI::storeOptimizerStreams(const Pair &pair, int streams)
{
FTS3_COMMON_LOGGER_NEWLOG(INFO) << "OptimizerDataSource->storeOptimizerStreams(..) stub" << commit;
return;
soci::session sql(*connectionPool);
try {
const std::string utc_timestamp = sql.get_backend_name() == "mysql" ? "UTC_TIMESTAMP()" : "NOW() AT TIME ZONE 'UTC'";
......
......@@ -18,6 +18,7 @@
#include <string>
#include "common/Logger.h"
#include <db/generic/Pair.h>
#include <monitoring/msg-ifce.h>
......@@ -43,6 +44,9 @@ public:
void notifyDecision(const Pair& pair, int decision, const PairState& current,
int diff, const std::string& rationale)
{
FTS3_COMMON_LOGGER_NEWLOG(INFO) << "OptimizerNotifier->storeOptimizerDecision(..) stub" << fts3::common::commit;
return;
// Broadcast the decision
OptimizerInfo msg;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment