|
|
|
@ -1513,10 +1513,12 @@ int main(int argc, const char **argv)
|
|
|
|
traceit("DVAP opened and initialized!\n");
|
|
|
|
traceit("DVAP opened and initialized!\n");
|
|
|
|
dstar_dv_init();
|
|
|
|
dstar_dv_init();
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
std::future<void> readthread;
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
std::async(std::launch::async, ReadDVAPThread);
|
|
|
|
readthread = std::async(std::launch::async, ReadDVAPThread);
|
|
|
|
} catch (const std::exception &e) {
|
|
|
|
} catch (const std::exception &e) {
|
|
|
|
traceit("Unable to start ReadDVAPThread(). Exception: %s\n", e.what());
|
|
|
|
traceit("Unable to start ReadDVAPThread(). Exception: %s\n", e.what());
|
|
|
|
|
|
|
|
keep_running = false;
|
|
|
|
}
|
|
|
|
}
|
|
|
|
traceit("Started ReadDVAPThread()\n");
|
|
|
|
traceit("Started ReadDVAPThread()\n");
|
|
|
|
|
|
|
|
|
|
|
|
@ -1537,6 +1539,7 @@ int main(int argc, const char **argv)
|
|
|
|
readFrom20000();
|
|
|
|
readFrom20000();
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
readthread.get();
|
|
|
|
close(insock);
|
|
|
|
close(insock);
|
|
|
|
traceit("dvap_rptr exiting\n");
|
|
|
|
traceit("dvap_rptr exiting\n");
|
|
|
|
return 0;
|
|
|
|
return 0;
|
|
|
|
|