Changeset 11575 for trunk/FACT++/src/scheduler.cc

Timestamp:

07/24/11 21:00:00 (13 years ago)

Author:

tbretz

Message:

Moved common option setup to Main.h; created Main namespace

File:

• trunk/FACT++/src/scheduler.cc (modified) (3 diffs)

trunk/FACT++/src/scheduler.cc

@@ -710 +710 @@
 // ------------------------------------------------------------------------
 #include "Main.h"
-/*
-void RunThread(StateMachineImp *io_service)
-{
-    // This is necessary so that the StateMachien Thread can signal the
-    // Readline to exit
-    io_service->Run();
-    Readline::Stop();
-}
-*/
-/*
-template<class S>
-int RunDim(Configuration &conf)
-{
-    WindowLog wout;
-
-    ReadlineColor::PrintBootMsg(wout, conf.GetName(), false);
-
-    //log.SetWindow(stdscr);
-    if (conf.Has("log"))
-        if (!wout.OpenLogFile(conf.Get<string>("log")))
-            wout << kRed << "ERROR - Couldn't open log-file " << conf.Get<string>("log") << ": " << strerror(errno) << endl;
-
-    // Start io_service.Run to use the StateMachineImp::Run() loop
-    // Start io_service.run to only use the commandHandler command detaching
-    AutoScheduler<S> io_service(wout);
-    if (!io_service.EvalConfiguration(conf))
-        return -1;
-
-    io_service.Run();
-
-    return 0;
-}
-*/
 
 template<class T, class S>
 int RunShell(Configuration &conf)
 {
-    return Main<T, AutoScheduler<S>>(conf);
-    /*
-    static T shell(conf.GetName().c_str(), conf.Get<int>("console")!=1);
-
-    WindowLog &win  = shell.GetStreamIn();
-    WindowLog &wout = shell.GetStreamOut();
-
-    if (conf.Has("log"))
-        if (!wout.OpenLogFile(conf.Get<string>("log")))
-            win << kRed << "ERROR - Couldn't open log-file " << conf.Get<string>("log") << ": " << strerror(errno) << endl;
-
-    AutoScheduler<S> io_service(wout);
-    if (!io_service.EvalConfiguration(conf))
-        return -1;
-
-    shell.SetReceiver(io_service);
-
-//    boost::thread t(boost::bind(&AutoScheduler<S>::Run, &io_service));
-    boost::thread t(boost::bind(RunThread, &io_service));
-
-    if (conf.Has("cmd"))
-    {
-        const vector<string> v = conf.Get<vector<string>>("cmd");
-        for (vector<string>::const_iterator it=v.begin(); it!=v.end(); it++)
-            shell.ProcessLine(*it);
-    }
-
-    if (conf.Has("exec"))
-    {
-        const vector<string> v = conf.Get<vector<string>>("exec");
-        for (vector<string>::const_iterator it=v.begin(); it!=v.end(); it++)
-            shell.Execute(*it);
-    }
-
-    if (conf.Get<bool>("quit"))
-        shell.Stop();
-
-    shell.Run();                 // Run the shell
-    io_service.Stop();           // Signal Loop-thread to stop
-    // io_service.Close();       // Obsolete, done by the destructor
-    // wout << "join: " << t.timed_join(boost::posix_time::milliseconds(0)) << endl;
-
-    // Wait until the StateMachine has finished its thread
-    // before returning and destroying the dim objects which might
-    // still be in use.
-    t.join();
-
-    return 0;
-*/
+    return Main::execute<T, AutoScheduler<S>>(conf);
 }
 
 void SetupConfiguration(Configuration &conf)
 {
-    const string n = conf.GetName()+".log";
-
-    //po::options_description config("Program options");
-    po::options_description config("Configuration");
-    config.add_options()
-        ("dns",       var<string>("localhost"),       "Dim nameserver (overwites DIM_DNS_NODE environment variable)")
-        ("host",      var<string>(""),                "Address with which the Dim nameserver can connect to this host (overwites DIM_HOST_NODE environment variable)")
-        ("log,l",     var<string>(n), "Write log-file")
-        ("no-dim,d",  po_switch(),    "Disable dim services")
-        ("console,c", var<int>(),     "Use console (0=shell, 1=simple buffered, X=simple unbuffered)")
-        ("cmd",       vars<string>(), "Execute one or more commands at startup")
-        ("exec,e",    vars<string>(), "Execute one or more scrips at startup")
-        ("quit",      po_switch(),    "Quit after startup");
-
     po::options_description control("Scheduler options");
     control.add_options()
+        ("no-dim",    po_switch(),    "Disable dim services")
         ("schedule-database", var<string>()
 #if BOOST_VERSION >= 104200
@@ -843 +749 @@
     p.add("schedule", 1); // The first positional options
 
-    conf.AddEnv("dns",  "DIM_DNS_NODE");
-    conf.AddEnv("host", "DIM_HOST_NODE");
-
-    conf.AddOptions(config);
     conf.AddOptions(control);
     conf.SetArgumentPositions(p);
@@ -876 +778 @@
     Configuration conf(argv[0]);
     conf.SetPrintUsage(PrintUsage);
+    Main::SetupConfiguration(conf);
     SetupConfiguration(conf);