From f2cbc48a9e704da8e86ed659437c1e338e212c50 Mon Sep 17 00:00:00 2001 From: Tedd Hansen Date: Sat, 6 Dec 2008 03:28:34 +0000 Subject: GUI for launching grids. Early version, but should work fine. Will execute all OpenSim services redirect their input/output/errors to the selected "GUI module". This version has following "GUI modules": * Windows Forms * Windows Service (doesn't work yet) * Console * TCP daemon This means that OpenSim can now run in a single console for those who want that. Console functionallity is not too rich yet, but code/framework is there... more to come. :) --- OpenSim/Tools/OpenSim.GridLaunch/Program.cs | 245 ++++++++++++++++++++++++++++ 1 file changed, 245 insertions(+) create mode 100644 OpenSim/Tools/OpenSim.GridLaunch/Program.cs (limited to 'OpenSim/Tools/OpenSim.GridLaunch/Program.cs') 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 AppList = new Dictionary(); + 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); + } + } +} -- cgit v1.1