Fix _writer process shutdown a little.

[dcpomatic.git] / src / tools / dcpomatic_dist_writer.cc

diff --git a/src/tools/dcpomatic_dist_writer.cc b/src/tools/dcpomatic_dist_writer.cc
index 04325dd5b617bb9e8f53558f94e627e78282d2cd..c667f2f95ee0f051862a7db94f7415938faf4169 100644 (file)
--- a/src/tools/dcpomatic_dist_writer.cc
+++ b/src/tools/dcpomatic_dist_writer.cc
@@ -365,20 +365,25 @@ idle ()
                return true;
        }
 
-       dcp_path = *s;
-       device = nanomsg->blocking_get();
+       if (*s == "Q") {
+               exit (EXIT_SUCCESS);
+       } else if (*s == "W") {
+               dcp_path = nanomsg->blocking_get();
+               device = nanomsg->blocking_get();
 
-       LOG_DIST ("Here we go writing %1 to %2", dcp_path, device);
+               LOG_DIST ("Here we go writing %1 to %2", dcp_path, device);
 
 #ifdef DCPOMATIC_LINUX
-       polkit_authority = polkit_authority_get_sync (0, 0);
-       PolkitSubject* subject = polkit_unix_process_new (getppid());
-       polkit_authority_check_authorization (
-                       polkit_authority, subject, "com.dcpomatic.write-drive", 0, POLKIT_CHECK_AUTHORIZATION_FLAGS_ALLOW_USER_INTERACTION, 0, polkit_callback, 0
-                       );
+               polkit_authority = polkit_authority_get_sync (0, 0);
+               PolkitSubject* subject = polkit_unix_process_new (getppid());
+               polkit_authority_check_authorization (
+                               polkit_authority, subject, "com.dcpomatic.write-drive", 0, POLKIT_CHECK_AUTHORIZATION_FLAGS_ALLOW_USER_INTERACTION, 0, polkit_callback, 0
+                               );
 #else
-       write ();
+               write ();
 #endif
+       }
+
        return true;
 }