Exit indefinte wait loop if conference ends (#25)

demo-content/demo.py

@@ -70,6 +70,8 @@ def stop_injection_process(folder):
         injector = open(folder + "/pid", "r")
         pid = injector.read()
         os.kill(int(pid), signal.SIGTERM)
+    else:
+        print("The PID file has already been removed, app is not running")
 
 def parse_injection_input():
     '''

src/linux/daemonize.cc

@@ -45,14 +45,16 @@ daemonize::daemonize(const std::string &log_dir) {
   open("/dev/null", O_WRONLY);
 
   pid_ = getpid();
-  std::ofstream pid_file(log_dir + "/pid");
+  pid_file_ = log_dir + "/pid";
+  std::ofstream pid_file(pid_file_);
   pid_file << std::to_string(pid_);
 }
 
 daemonize::~daemonize() {
   close(0);
   close(1);
   close(2);
+  remove(pid_file_.c_str());
 }
 
 void daemonize::wait_indefinitely() {

src/linux/daemonize.h

@@ -34,6 +34,7 @@ class daemonize {
  private:
   void parent_exit(pid_t pid);
   pid_t pid_{-1};
+  std::string pid_file_{};
   sem_t semaphore_{};
 };
 

src/main.cc

@@ -13,6 +13,7 @@
 #include "utils/async_accumulator.h"
 #include "utils/commands_handler.h"
 
+#include <memory>
 #include <vector>
 
 using namespace dolbyio::comms::sample;
@@ -23,9 +24,8 @@ using namespace dolbyio::comms::sample;
 #include <execinfo.h>
 #include <signal.h>
 
-// Global unique_ptr for linux daemonization, because I was too lazy
-// to read sigaction and setting context for handler ;)
-std::unique_ptr<daemonize> daemonize_ptr{nullptr};
+// Global pointer for linux daemonization
+std::shared_ptr<daemonize> daemonize_ptr{nullptr};
 
 void signal_handler(int sig) {
   if (sig == SIGTERM && daemonize_ptr)
@@ -120,7 +120,21 @@ int main(int argc, char** argv) {
 
     // Run blocking loop
 #if defined(__linux__)
+    // If the conference has ended then we should unblock the loop.
+    // Not ideal because you could techinically race here with signal
+    // handler, but for our purposes it should be ok.
+    std::weak_ptr<daemonize> weak_daemoize_ptr{daemonize_ptr};
+    sdk->conference()
+        .add_event_handler(
+            [weak_daemoize_ptr](
+                const dolbyio::comms::conference_status_updated& status) {
+              if (status.is_ended() && !weak_daemoize_ptr.expired()) {
+                weak_daemoize_ptr.lock()->unblock_indefinte_wait();
+              }
+            })
+        .on_error([](auto&&) {});
     daemonize_ptr->wait_indefinitely();
+    daemonize_ptr.reset();
 #else
     while (!quit) {
       command_handler.print_interactive_options();