Skip to content
Snippets Groups Projects
Commit ef61ccb2 authored by Matt Clarke_1's avatar Matt Clarke_1
Browse files

remove logging we added for debugging issue

parent 8807200f
No related branches found
No related tags found
1 merge request!898remove logging we added for debugging issue
...@@ -28,13 +28,10 @@ StreamController::StreamController( ...@@ -28,13 +28,10 @@ StreamController::StreamController(
_consumer_factory(std::move(consumer_factory)) {} _consumer_factory(std::move(consumer_factory)) {}
StreamController::~StreamController() { StreamController::~StreamController() {
Logger::Error("streamcontroller destructor start");
stop(); stop();
Logger::Error("streamcontroller destructor calls mdat");
MdatWriter->write_metadata(*WriterTask); MdatWriter->write_metadata(*WriterTask);
Logger::Info("Stopped StreamController for file with id : {}", Logger::Info("Stopped StreamController for file with id : {}",
StreamController::getJobId()); StreamController::getJobId());
Logger::Error("streamcontroller destructor end");
} }
void StreamController::start() { void StreamController::start() {
...@@ -47,7 +44,6 @@ void StreamController::start() { ...@@ -47,7 +44,6 @@ void StreamController::start() {
} }
void StreamController::setStopTime(time_point const &StopTime) { void StreamController::setStopTime(time_point const &StopTime) {
Logger::Error("streamcontroller setstoptime start");
StreamerOptions.StopTimestamp = StopTime; StreamerOptions.StopTimestamp = StopTime;
MdatWriter->set_stop_time(StopTime); MdatWriter->set_stop_time(StopTime);
Executor.sendWork([=]() { Executor.sendWork([=]() {
...@@ -55,7 +51,6 @@ void StreamController::setStopTime(time_point const &StopTime) { ...@@ -55,7 +51,6 @@ void StreamController::setStopTime(time_point const &StopTime) {
s->setStopTime(StopTime); s->setStopTime(StopTime);
} }
}); });
Logger::Error("streamcontroller setstoptime end");
} }
void StreamController::pauseStreamers() { StreamersPaused.store(true); } void StreamController::pauseStreamers() { StreamersPaused.store(true); }
...@@ -63,17 +58,14 @@ void StreamController::pauseStreamers() { StreamersPaused.store(true); } ...@@ -63,17 +58,14 @@ void StreamController::pauseStreamers() { StreamersPaused.store(true); }
void StreamController::resumeStreamers() { StreamersPaused.store(false); } void StreamController::resumeStreamers() { StreamersPaused.store(false); }
void StreamController::stop() { void StreamController::stop() {
Logger::Error("streamcontroller stop start");
for (auto &Stream : Streamers) for (auto &Stream : Streamers)
Stream->stop(); Stream->stop();
WriterThread.stop(); WriterThread.stop();
StopNow = true; StopNow = true;
Logger::Error("streamcontroller stop end");
} }
using duration = std::chrono::system_clock::duration; using duration = std::chrono::system_clock::duration;
bool StreamController::isDoneWriting() { bool StreamController::isDoneWriting() {
Logger::Error("streamcontroller isdonewriting start");
auto Now = std::chrono::system_clock::now(); auto Now = std::chrono::system_clock::now();
auto IsDoneWriting = auto IsDoneWriting =
HasError || StopNow or HasError || StopNow or
...@@ -88,7 +80,6 @@ bool StreamController::isDoneWriting() { ...@@ -88,7 +80,6 @@ bool StreamController::isDoneWriting() {
FileSizeCalcInterval * int(std::round(TimeDiffPeriods)); FileSizeCalcInterval * int(std::round(TimeDiffPeriods));
} }
} }
Logger::Error("streamcontroller isdonewriting end");
return IsDoneWriting; return IsDoneWriting;
} }
......
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