diff --git a/streaming_recording_backend.cpp b/streaming_recording_backend.cpp index 491b722a656bbe4378d6e412c342b4abaf94f297..a0296f08587668115bf7bb0846993e9d529c1eaf 100644 --- a/streaming_recording_backend.cpp +++ b/streaming_recording_backend.cpp @@ -22,9 +22,9 @@ #include "streaming_recording_backend.h" -#include "recording_device.h" #include "nesci/producer/nest_multimeter.hpp" #include "nesci/producer/spike_detector.hpp" +#include "recording_device.h" #include <iostream> #include <memory> @@ -41,8 +41,13 @@ void StreamingRecordingBackend::initialize() { } void StreamingRecordingBackend::prepare() { - std::cout << "prepare()" << std::endl; - std::cout << "Get the number of nodes" << nest::kernel().node_manager.size() << std::endl; + LOG(nest::M_INFO, "StreamingRecordingBackend", + "Wait until connection is established..."); + while (!relay_.IsConnected()) { + std::this_thread::yield(); + } + LOG(nest::M_INFO, "StreamingRecordingBackend", + "Connection established!"); } void StreamingRecordingBackend::cleanup() { @@ -159,7 +164,7 @@ void StreamingRecordingBackend::synchronize() { } } -void StreamingRecordingBackend::clear(const nest::RecordingDevice& device) { +void StreamingRecordingBackend::clear(const nest::RecordingDevice &device) { std::cout << "clear(" << device.get_name() << ")" << std::endl; }