More capitalisation fixes.

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

diff --git a/src/tools/dcpomatic_cli.cc b/src/tools/dcpomatic_cli.cc
index af148b2fab25e97037c2b7e0cfb7302bbcef92fd..7ab6d284d84650e0bedd3f5674519979fb002912 100644 (file)
--- a/src/tools/dcpomatic_cli.cc
+++ b/src/tools/dcpomatic_cli.cc
@@ -27,7 +27,7 @@
 #include "lib/config.h"
 #include "lib/log.h"
 #include "lib/signal_manager.h"
-#include "lib/server_finder.h"
+#include "lib/encode_server_finder.h"
 #include "lib/json_server.h"
 #include "lib/ratio.h"
 #include "lib/video_content.h"
@@ -43,6 +43,7 @@ using std::cerr;
 using std::cout;
 using std::vector;
 using std::pair;
+using std::setw;
 using std::list;
 using boost::shared_ptr;
 using boost::optional;
@@ -51,7 +52,7 @@ using boost::dynamic_pointer_cast;
 static void
 help (string n)
 {
-       cerr << "Syntax: " << n << " [OPTION] <FILM>\n"
+       cerr << "Syntax: " << n << " [OPTION] [<FILM>]\n"
             << "  -v, --version      show DCP-o-matic version\n"
             << "  -h, --help         show this help\n"
             << "  -f, --flags        show flags passed to C++ compiler on build\n"
@@ -59,6 +60,8 @@ help (string n)
             << "  -r, --no-remote    do not use any remote servers\n"
             << "  -j, --json <port>  run a JSON server on the specified port\n"
             << "  -k, --keep-going   keep running even when the job is complete\n"
+            << "  -s, --servers      just display a list of encoding servers that DCP-o-matic is configured to use; don't encode\n"
+            << "  -d, --dcp-path     echo DCP's path to stdout on successful completion (implies -n)\n"
             << "      --dump         just dump a summary of the film's settings; don't encode\n"
             << "\n"
             << "<FILM> is the film directory.\n";
@@ -112,6 +115,61 @@ print_dump (shared_ptr<Film> film)
        }
 }
 
+static void
+show_servers ()
+{
+       while (true) {
+               int N = 0;
+               list<EncodeServerDescription> servers = EncodeServerFinder::instance()->servers ();
+
+               if (Config::instance()->use_any_servers ()) {
+                       if (servers.empty ()) {
+                               cout << "No encoding servers found.\n";
+                               ++N;
+                       } else {
+                               cout << std::left << setw(24) << "Host" << " Threads\n";
+                               ++N;
+                               BOOST_FOREACH (EncodeServerDescription const & i, servers) {
+                                       cout << std::left << setw(24) << i.host_name() << " " << i.threads() << "\n";
+                                       ++N;
+                               }
+                       }
+               } else {
+                       vector<string> configured_servers = Config::instance()->servers();
+                       if (configured_servers.empty()) {
+                               cout << "No configured servers, and DCP-o-matic is not set to search for any server.\n";
+                               ++N;
+                       } else {
+                               cout << std::left << setw(24) << "Host" << " Status Threads\n";
+                               ++N;
+                               BOOST_FOREACH (string const & i, Config::instance()->servers()) {
+                                       cout << std::left << setw(24) << i << " ";
+                                       optional<int> threads;
+                                       BOOST_FOREACH (EncodeServerDescription const & j, servers) {
+                                               if (i == j.host_name()) {
+                                                       threads = j.threads();
+                                               }
+                                       }
+                                       if (static_cast<bool>(threads)) {
+                                               cout << "UP     " << threads.get() << "\n";
+                                       } else {
+                                               cout << "DOWN\n";
+                                       }
+                                       ++N;
+                               }
+                       }
+               }
+
+
+               dcpomatic_sleep (1);
+
+               for (int i = 0; i < N; ++i) {
+                       cout << "\033[1A\033[2K";
+               }
+       }
+}
+
+
 int
 main (int argc, char* argv[])
 {
@@ -121,6 +179,8 @@ main (int argc, char* argv[])
        optional<int> json_port;
        bool keep_going = false;
        bool dump = false;
+       bool servers = false;
+       bool dcp_path = false;
 
        int option_index = 0;
        while (true) {
@@ -132,12 +192,14 @@ main (int argc, char* argv[])
                        { "no-remote", no_argument, 0, 'r'},
                        { "json", required_argument, 0, 'j'},
                        { "keep-going", no_argument, 0, 'k' },
+                       { "servers", no_argument, 0, 's' },
+                       { "dcp-path", no_argument, 0, 'd' },
                        /* Just using A, B, C ... from here on */
                        { "dump", no_argument, 0, 'A' },
                        { 0, 0, 0, 0 }
                };
 
-               int c = getopt_long (argc, argv, "vhfnrj:kA", long_options, &option_index);
+               int c = getopt_long (argc, argv, "vhfnrj:kAsd", long_options, &option_index);
 
                if (c == -1) {
                        break;
@@ -168,9 +230,21 @@ main (int argc, char* argv[])
                case 'A':
                        dump = true;
                        break;
+               case 's':
+                       servers = true;
+                       break;
+               case 'd':
+                       dcp_path = true;
+                       progress = false;
+                       break;
                }
        }
 
+       if (servers) {
+               show_servers ();
+               exit (EXIT_SUCCESS);
+       }
+
        if (optind >= argc) {
                help (argv[0]);
                exit (EXIT_FAILURE);
@@ -183,7 +257,7 @@ main (int argc, char* argv[])
        signal_manager = new SignalManager ();
 
        if (no_remote) {
-               ServerFinder::instance()->disable ();
+               EncodeServerFinder::instance()->disable ();
        }
 
        if (json_port) {
@@ -231,7 +305,9 @@ main (int argc, char* argv[])
                list<shared_ptr<Job> > jobs = JobManager::instance()->get ();
 
                if (!first && progress) {
-                       cout << "\033[" << jobs.size() << "A";
+                       for (size_t i = 0; i < jobs.size(); ++i) {
+                               cout << "\033[1A\033[2K";
+                       }
                        cout.flush ();
                }
 
@@ -284,7 +360,11 @@ main (int argc, char* argv[])
        */
        JobManager::drop ();
 
-       ServerFinder::drop ();
+       EncodeServerFinder::drop ();
+
+       if (dcp_path && !error) {
+               cout << film->dir (film->dcp_name (false)).string() << "\n";
+       }
 
        return error ? EXIT_FAILURE : EXIT_SUCCESS;
 }