1 files changed, 245 insertions, 0 deletions

diff --git a/OpenSim/Tools/OpenSim.GridLaunch/Program.cs b/OpenSim/Tools/OpenSim.GridLaunch/Program.cs
new file mode 100644
index 0000000..5a0bb0c
--- /dev/null
+++ b/OpenSim/Tools/OpenSim.GridLaunch/Program.cs
@@ -0,0 +1,245 @@
+/*
+ * Copyright (c) Contributors, http://opensimulator.org/
+ * See CONTRIBUTORS.TXT for a full list of copyright holders.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *     * Redistributions of source code must retain the above copyright
+ *       notice, this list of conditions and the following disclaimer.
+ *     * Redistributions in binary form must reproduce the above copyright
+ *       notice, this list of conditions and the following disclaimer in the
+ *       documentation and/or other materials provided with the distribution.
+ *     * Neither the name of the OpenSim Project nor the
+ *       names of its contributors may be used to endorse or promote products
+ *       derived from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
+ * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
+ * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
+ * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
+ * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
+ * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
+ * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
+ * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+using System;
+using System.Collections;
+using System.Collections.Generic;
+using System.Reflection;
+using System.Threading;
+using log4net;
+using log4net.Appender;
+using log4net.Repository.Hierarchy;
+using OpenSim.GridLaunch.GUI;
+using OpenSim.GridLaunch.GUI.Network;
+
+namespace OpenSim.GridLaunch
+{
+    class Program
+    {
+        public static readonly string ConfigFile = "OpenSim.GridLaunch.ini";
+        internal static Dictionary<string, AppExecutor> AppList = new Dictionary<string, AppExecutor>();
+        private static readonly int delayBetweenExecuteSeconds = 10;
+        //private static readonly int consoleReadIntervalMilliseconds = 50;
+        ////private static readonly Timer readTimer = new Timer(readConsole, null, Timeout.Infinite, Timeout.Infinite);
+        //private static Thread timerThread;
+        //private static object timerThreadLock = new object();
+        private static IGUI GUIModule;
+        private static string GUIModuleName = "";
+        public static readonly CommandProcessor Command = new CommandProcessor();
+        public static readonly Settings Settings = new Settings();
+
+        private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
+
+        public delegate void AppConsoleOutputDelegate(string App, string Text);
+        public static event AppConsoleOutputDelegate AppConsoleOutput;
+        public delegate void AppConsoleErrorDelegate(string App, string Text);
+        public static event AppConsoleErrorDelegate AppConsoleError;
+        public delegate void AppCreatedDelegate(string App);
+        public static event AppCreatedDelegate AppCreated;
+        public delegate void AppRemovedDelegate(string App);
+        public static event AppRemovedDelegate AppRemoved;
+
+        internal static void FireAppConsoleOutput(string App, string Text)
+        {
+            if (AppConsoleOutput != null)
+                AppConsoleOutput(App, Text);
+        }
+        internal static void FireAppConsoleError(string App, string Text)
+        {
+            if (AppConsoleError != null)
+                AppConsoleError(App, Text);
+        }
+        
+
+        private static readonly object startStopLock = new object();
+
+        public static string Name { get { return "OpenSim Grid executor"; } }
+
+        #region Start/Shutdown
+        static void Main(string[] args)
+        {
+            log4net.Config.XmlConfigurator.Configure();
+
+            // Startup
+            m_log.Info(Name);
+            m_log.Info(new string('-', Name.Length));
+
+            // Read settings
+            Settings.LoadConfig(ConfigFile);
+            // Command line arguments override settings
+            Settings.ParseCommandArguments(args);
+
+            // Start GUI module
+            StartGUIModule();
+
+            // Start the processes
+            ThreadPool.QueueUserWorkItem(startProcesses);
+
+            // Hand over thread control to whatever GUI module
+            GUIModule.StartGUI();
+
+            // GUI module returned, we are done
+            Shutdown();
+
+        }
+
+        private static void StartGUIModule()
+        {
+            // Create GUI module
+            GUIModuleName = Settings["GUI"];
+
+            switch (GUIModuleName.ToLower())
+            {
+                case "winform":
+                    GUIModuleName = "WinForm";
+                    GUIModule = new GUI.WinForm.ProcessPanel();
+                    break;
+                case "service":
+                    GUIModuleName = "Service";
+                    GUIModule = new Service();
+                    break;
+                case "tcpd":
+                    GUIModuleName = "TCPD";
+                    GUIModule = new TCPD();
+                    break;
+                case "console":
+                default:
+                    GUIModuleName = "Console";
+                    GUIModule = new GUI.Console.Console();
+                    break;
+            }
+            m_log.Info("GUI type: " + GUIModuleName);
+
+        }
+
+        internal static void Shutdown()
+        {
+            // Stop the processes
+            stopProcesses();
+
+            lock (startStopLock)
+            {
+                // Stop GUI module
+                if (GUIModule != null)
+                {
+                    GUIModule.StopGUI();
+                    GUIModule = null;
+                }
+            }
+        }
+
+        internal static void SafeDisposeOf(object obj)
+        {
+            IDisposable o = obj as IDisposable;
+            try
+            {
+                if (o != null)
+                    o.Dispose();
+            }
+            catch { }
+        }
+        #endregion
+
+        #region Start / Stop applications
+        private static void startProcesses(Object stateInfo)
+        {
+            // Stop before starting
+            stopProcesses();
+
+            // Start console read timer
+            //timer_Start();
+
+                // Start the applications
+                foreach (string file in new ArrayList(Settings.Components.Keys))
+                {
+                    // Is this file marked for startup?
+                    if (Settings.Components[file])
+                    {
+                        AppExecutor app = new AppExecutor(file);
+                        app.Start();
+                        AppList.Add(file, app);
+                        if (AppCreated != null)
+                            AppCreated(app.File);
+                        System.Threading.Thread.Sleep(1000*delayBetweenExecuteSeconds);
+                    }
+                }
+        }
+
+        private static void stopProcesses()
+        {
+            // Stop timer
+            //timer_Stop();
+
+            // Lock so we don't collide with any timer still executing on AppList
+            lock (AppList)
+            {
+                // Start the applications
+                foreach (AppExecutor app in AppList.Values)
+                {
+                    try
+                    {
+                        m_log.Info("Stopping: " + app.File);
+                        app.Stop();
+                    }
+                    catch (Exception ex)
+                    {
+                        m_log.ErrorFormat("Exception while stopping \"{0}\": {1}", app.File, ex.ToString());
+                    }
+                    finally
+                    {
+                        if (AppRemoved != null)
+                            AppRemoved(app.File);
+                        app.Dispose();
+                    }
+
+                }
+                AppList.Clear();
+            }
+        }
+        #endregion
+
+       public static void Write(string App, string Text)
+        {
+            // Check if it is a commands
+            bool isCommand = Command.Process(App, Text);
+
+            // Write to stdInput of app
+            if (!isCommand && AppList.ContainsKey(App))
+                AppList[App].Write(Text);
+        }
+
+        public static void WriteLine(string App, string Text)
+        {
+            // Check if it is a commands
+            bool isCommand = Command.Process(App, Text);
+
+            // Write to stdInput of app
+            if (!isCommand && AppList.ContainsKey(App))
+                AppList[App].WriteLine(Text);
+        }
+    }
+}