ogb912/opensim
1
0
Fork 0
mirror of https://github.com/opensim/opensim.git synced 2026-08-04 08:06:27 +08:00
Code Issues Packages Projects Releases Wiki Activity

GUI for launching grids. Early version, but should work fine.

Browse Source 
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. :)
This commit is contained in:
Tedd Hansen
2008-12-06 03:28:34 +00:00
parent b23e82b573
commit f2cbc48a9e
34 changed files with 4274 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

187
OpenSim/Tools/OpenSim.GridLaunch/AppExecutor_Thread.cs Normal file
View File

@@ -0,0 +1,187 @@
/*
* 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.Text;
//using System.Threading;
//using log4net;
//namespace OpenSim.GridLaunch
//{
// internal class AppExecutor2
// {
// private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
// 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();
// #region Start / Stop timer thread
// private static void timer_Start()
// {
// //readTimer.Change(0, consoleReadIntervalMilliseconds);
// lock (timerThreadLock)
// {
// if (timerThread == null)
// {
// m_log.Debug("Starting timer thread.");
// timerThread = new Thread(timerThreadLoop);
// timerThread.Name = "StdOutputStdErrorReadThread";
// timerThread.IsBackground = true;
// timerThread.Start();
// }
// }
// }
// private static void timer_Stop()
// {
// //readTimer.Change(Timeout.Infinite, Timeout.Infinite);
// lock (timerThreadLock)
// {
// if (timerThread != null)
// {
// m_log.Debug("Stopping timer thread.");
// try
// {
// if (timerThread.IsAlive)
// timerThread.Abort();
// timerThread.Join(2000);
// timerThread = null;
// }
// catch (Exception ex)
// {
// m_log.Error("Exception stopping timer thread: " + ex.ToString());
// }
// }
// }
// }
// #endregion
// #region Timer read from consoles and fire event
// private static void timerThreadLoop()
// {
// try
// {
// while (true)
// {
// readConsole();
// Thread.Sleep(consoleReadIntervalMilliseconds);
// }
// }
// catch (ThreadAbortException) { } // Expected on thread shutdown
// }
// private static void readConsole()
// {
// try
// {
// // Lock so we don't collide with any startup or shutdown
// lock (Program.AppList)
// {
// foreach (AppExecutor app in new ArrayList(Program.AppList.Values))
// {
// try
// {
// string txt = app.GetStdOutput();
// // Fire event with received text
// if (!string.IsNullOrEmpty(txt))
// Program.FireAppConsoleOutput(app.File, txt);
// }
// catch (Exception ex)
// {
// m_log.ErrorFormat("Exception reading standard output from \"{0}\": {1}", app.File, ex.ToString());
// }
// try
// {
// string txt = app.GetStdError();
// // Fire event with received text
// if (!string.IsNullOrEmpty(txt))
// Program.FireAppConsoleOutput(app.File, txt);
// }
// catch (Exception ex)
// {
// m_log.ErrorFormat("Exception reading standard error from \"{0}\": {1}", app.File, ex.ToString());
// }
// }
// }
// }
// finally
// {
// }
// }
// #endregion
// #region Read stdOutput and stdError
// public string GetStdOutput()
// {
// return GetStreamData(Output);
// }
// public string GetStdError()
// {
// return GetStreamData(Error);
// }
// private static int num = 0;
// // Gets any data from StreamReader object, non-blocking
// private static string GetStreamData(StreamReader sr)
// {
// // Can't read?
// if (!sr.BaseStream.CanRead)
// return "";
// // Read a chunk
// //sr.BaseStream.ReadTimeout = 100;
// byte[] buffer = new byte[4096];
// num++;
// Trace.WriteLine("Start read " + num);
// int len = sr.BaseStream.Read(buffer, 0, buffer.Length);
// Trace.WriteLine("End read " + num + ": " + len);
// // Nothing?
// if (len <= 0)
// return "";
// // Return data
// StringBuilder sb = new StringBuilder();
// sb.Append(System.Text.Encoding.ASCII.GetString(buffer, 0, len));
// //while (sr.Peek() >= 0)
// //{
// // sb.Append(Convert.ToChar(sr.Read()));
// //}
// return sb.ToString();
// }
// #endregion
// }
//}