diff --git a/receiver/jfjoch_action_test.cpp b/receiver/jfjoch_action_test.cpp index bac3f859..c61e412e 100644 --- a/receiver/jfjoch_action_test.cpp +++ b/receiver/jfjoch_action_test.cpp @@ -46,6 +46,7 @@ int main(int argc, char **argv) { bool print_status_updates = true; uint16_t nthreads = 64; uint64_t clock_MHz = 200; + bool nonblocking_mode = true; logger.Verbose(verbose); @@ -65,9 +66,14 @@ int main(int argc, char **argv) { oc_devices.push_back(std::make_unique(dev_name[i], i)); oc_devices[i]->SetCustomInternalGeneratorFrame(input); oc_devices[i]->EnableLogging(&logger); + oc_devices[i]->SetFPGANonBlockingMode(nonblocking_mode); aq_devices.push_back(oc_devices[i].get()); } + if (nonblocking_mode) + logger.Warning("FPGA uses non-blocking mode - in case data acquisition is aborted, it is necessary to cold reboot the machine"); + + volatile bool done = false; JFJochProtoBuf::ReceiverOutput output; bool ret;