aboutsummaryrefslogtreecommitdiffstatshomepage
path: root/OpenSim/Tools/OpenSim.GridLaunch/AppExecutor_AsyncIO.cs
diff options
context:
space:
mode:
authorTedd Hansen2008-12-06 03:28:34 +0000
committerTedd Hansen2008-12-06 03:28:34 +0000
commitf2cbc48a9e704da8e86ed659437c1e338e212c50 (patch)
tree483255008f063c08d541ae56760f894273eaf041 /OpenSim/Tools/OpenSim.GridLaunch/AppExecutor_AsyncIO.cs
parentMinor formatting cleanup. (diff)
downloadopensim-SC_OLD-f2cbc48a9e704da8e86ed659437c1e338e212c50.zip
opensim-SC_OLD-f2cbc48a9e704da8e86ed659437c1e338e212c50.tar.gz
opensim-SC_OLD-f2cbc48a9e704da8e86ed659437c1e338e212c50.tar.bz2
opensim-SC_OLD-f2cbc48a9e704da8e86ed659437c1e338e212c50.tar.xz
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. :)
Diffstat (limited to 'OpenSim/Tools/OpenSim.GridLaunch/AppExecutor_AsyncIO.cs')
-rw-r--r--OpenSim/Tools/OpenSim.GridLaunch/AppExecutor_AsyncIO.cs85
1 files changed, 85 insertions, 0 deletions
diff --git a/OpenSim/Tools/OpenSim.GridLaunch/AppExecutor_AsyncIO.cs b/OpenSim/Tools/OpenSim.GridLaunch/AppExecutor_AsyncIO.cs
new file mode 100644
index 0000000..0d07226
--- /dev/null
+++ b/OpenSim/Tools/OpenSim.GridLaunch/AppExecutor_AsyncIO.cs
@@ -0,0 +1,85 @@
1/*
2 * Copyright (c) Contributors, http://opensimulator.org/
3 * See CONTRIBUTORS.TXT for a full list of copyright holders.
4 *
5 * Redistribution and use in source and binary forms, with or without
6 * modification, are permitted provided that the following conditions are met:
7 * * Redistributions of source code must retain the above copyright
8 * notice, this list of conditions and the following disclaimer.
9 * * Redistributions in binary form must reproduce the above copyright
10 * notice, this list of conditions and the following disclaimer in the
11 * documentation and/or other materials provided with the distribution.
12 * * Neither the name of the OpenSim Project nor the
13 * names of its contributors may be used to endorse or promote products
14 * derived from this software without specific prior written permission.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE DEVELOPERS ``AS IS'' AND ANY
17 * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
18 * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
19 * DISCLAIMED. IN NO EVENT SHALL THE CONTRIBUTORS BE LIABLE FOR ANY
20 * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
21 * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
22 * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
23 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
24 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
25 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
26 */
27using System;
28using System.Collections.Generic;
29using System.IO;
30using System.Text;
31
32namespace OpenSim.GridLaunch
33{
34 internal partial class AppExecutor
35 {
36
37
38 #region Start / Stop timer thread
39 private void timer_Start()
40 {
41 asyncReadOutput();
42 asyncReadError();
43 }
44
45 private bool running = true;
46 private void timer_Stop()
47 {
48 running = false;
49 }
50 #endregion
51
52 private byte[] readBufferOutput = new byte[4096];
53 private byte[] readBufferError = new byte[4096];
54
55 private void asyncReadOutput()
56 {
57 if (running)
58 Output.BaseStream.BeginRead(readBufferOutput, 0, readBufferOutput.Length, asyncReadCallBackOutput, null);
59 }
60 private void asyncReadError()
61 {
62 if (running)
63 Error.BaseStream.BeginRead(readBufferError, 0, readBufferError.Length, asyncReadCallBackError, null);
64 }
65
66 private void asyncReadCallBackOutput(IAsyncResult ar)
67 {
68 int len = Output.BaseStream.EndRead(ar);
69 Program.FireAppConsoleOutput(file,
70 System.Text.Encoding.ASCII.GetString(readBufferOutput, 0, len)
71 );
72
73 asyncReadOutput();
74 }
75 private void asyncReadCallBackError(IAsyncResult ar)
76 {
77 int len = Error.BaseStream.EndRead(ar);
78 Program.FireAppConsoleError(file,
79 System.Text.Encoding.ASCII.GetString(readBufferError, 0, len)
80 );
81
82 asyncReadError();
83 }
84 }
85}