diff --git a/controller/DBMirrorSet.cpp b/controller/DBMirrorSet.cpp index 4c56517dc..f8c6f0366 100644 --- a/controller/DBMirrorSet.cpp +++ b/controller/DBMirrorSet.cpp @@ -21,17 +21,17 @@ DBMirrorSet::DBMirrorSet(DB::ChangeListener* listener) : _listener(listener), _r { _syncCheckerThread = std::thread([this]() { for (;;) { - auto provider = opentelemetry::trace::Provider::GetTracerProvider(); - auto tracer = provider->GetTracer("db_mirror_set"); - auto span = tracer->StartSpan("db::syncChecker"); - auto scope = tracer->WithActiveSpan(span); - for (int i = 0; i < 120; ++i) { // 1 minute delay between checks if (! _running) return; std::this_thread::sleep_for(std::chrono::milliseconds(500)); } + auto provider = opentelemetry::trace::Provider::GetTracerProvider(); + auto tracer = provider->GetTracer("db_mirror_set"); + auto span = tracer->StartSpan("db::syncChecker"); + auto scope = tracer->WithActiveSpan(span); + std::vector > dbs; { std::unique_lock l(_dbs_l);