Added GridServerPlugin class (which implements IGridPlugin) to OpenSim.Grid.GridServer.Modules.

This class handles all the initialising of the grid server.
And made GridServer into basically a generic server that just loads plugins. 
So this is a step towards having a generic server that loads service modules.
GenericGridServerConcept
MW 2009-02-27 15:57:09 +00:00
parent 95230c244c
commit d45fa9c2df
4 changed files with 170 additions and 92 deletions

View File

@ -0,0 +1,147 @@
using System;
using System.Collections.Generic;
using System.Reflection;
using System.Text;
using log4net;
using OpenSim.Framework;
using OpenSim.Framework.Console;
using OpenSim.Grid.Framework;
using OpenSim.Grid;
namespace OpenSim.Grid.GridServer.Modules
{
public class GridServerPlugin : IGridPlugin
{
private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
protected GridXmlRpcModule m_gridXmlRpcModule;
protected GridMessagingModule m_gridMessageModule;
protected GridRestModule m_gridRestModule;
protected GridDBService m_gridDBService;
protected string m_version;
protected GridConfig m_config;
protected IGridServiceCore m_core;
protected ConsoleBase m_console;
#region IGridPlugin Members
public void Initialise(GridServerBase gridServer)
{
m_core = gridServer;
m_config = gridServer.Config;
m_version = gridServer.Version;
m_console = MainConsole.Instance;
AddConsoleCommands();
SetupGridServices();
}
#endregion
#region IPlugin Members
public string Version
{
get { return "0.0"; }
}
public string Name
{
get { return "GridServerPlugin"; }
}
public void Initialise()
{
}
#endregion
protected virtual void SetupGridServices()
{
// m_log.Info("[DATA]: Connecting to Storage Server");
m_gridDBService = new GridDBService();
m_gridDBService.AddPlugin(m_config.DatabaseProvider, m_config.DatabaseConnect);
//Register the database access service so modules can fetch it
// RegisterInterface<GridDBService>(m_gridDBService);
m_gridMessageModule = new GridMessagingModule();
m_gridMessageModule.Initialise(m_version, m_gridDBService, m_core, m_config);
m_gridXmlRpcModule = new GridXmlRpcModule();
m_gridXmlRpcModule.Initialise(m_version, m_gridDBService, m_core, m_config);
m_gridRestModule = new GridRestModule();
m_gridRestModule.Initialise(m_version, m_gridDBService, m_core, m_config);
m_gridMessageModule.PostInitialise();
m_gridXmlRpcModule.PostInitialise();
m_gridRestModule.PostInitialise();
}
#region Console Command Handlers
protected virtual void AddConsoleCommands()
{
m_console.Commands.AddCommand("gridserver", false,
"enable registration",
"enable registration",
"Enable new regions to register", HandleRegistration);
m_console.Commands.AddCommand("gridserver", false,
"disable registration",
"disable registration",
"Disable registering new regions", HandleRegistration);
m_console.Commands.AddCommand("gridserver", false, "show status",
"show status",
"Show registration status", HandleShowStatus);
}
private void HandleRegistration(string module, string[] cmd)
{
switch (cmd[0])
{
case "enable":
m_config.AllowRegionRegistration = true;
m_log.Info("Region registration enabled");
break;
case "disable":
m_config.AllowRegionRegistration = false;
m_log.Info("Region registration disabled");
break;
}
}
private void HandleShowStatus(string module, string[] cmd)
{
if (m_config.AllowRegionRegistration)
{
m_log.Info("Region registration enabled.");
}
else
{
m_log.Info("Region registration disabled.");
}
}
#endregion
#region IDisposable Members
public void Dispose()
{
}
#endregion
}
}

View File

@ -0,0 +1,11 @@
<Addin id="OpenSim.Grid.GridServer.Modules" version="0.1">
<Runtime>
<Import assembly="OpenSim.Grid.GridServer.Modules.dll"/>
</Runtime>
<Dependencies>
<Addin id="OpenSim.Grid.GridServer" version="0.5" />
</Dependencies>
<Extension path = "/OpenSim/GridServer">
<Plugin id="GridServerModules" type="OpenSim.Grid.GridServer.Modules.GridServerPlugin" />
</Extension>
</Addin>

View File

@ -35,7 +35,6 @@ using OpenSim.Framework;
using OpenSim.Framework.Console; using OpenSim.Framework.Console;
using OpenSim.Framework.Servers; using OpenSim.Framework.Servers;
using OpenSim.Grid.Framework; using OpenSim.Grid.Framework;
using OpenSim.Grid.GridServer.Modules;
namespace OpenSim.Grid.GridServer namespace OpenSim.Grid.GridServer
{ {
@ -47,11 +46,15 @@ namespace OpenSim.Grid.GridServer
protected GridConfig m_config; protected GridConfig m_config;
protected GridXmlRpcModule m_gridXmlRpcModule; public GridConfig Config
protected GridMessagingModule m_gridMessageModule; {
protected GridRestModule m_gridRestModule; get { return m_config; }
}
protected GridDBService m_gridDBService; public string Version
{
get { return m_version; }
}
protected List<IGridPlugin> m_plugins = new List<IGridPlugin>(); protected List<IGridPlugin> m_plugins = new List<IGridPlugin>();
@ -71,34 +74,6 @@ namespace OpenSim.Grid.GridServer
MainConsole.Instance = m_console; MainConsole.Instance = m_console;
} }
private void HandleRegistration(string module, string[] cmd)
{
switch (cmd[0])
{
case "enable":
m_config.AllowRegionRegistration = true;
m_log.Info("Region registration enabled");
break;
case "disable":
m_config.AllowRegionRegistration = false;
m_log.Info("Region registration disabled");
break;
}
}
private void HandleShowStatus(string module, string[] cmd)
{
if (m_config.AllowRegionRegistration)
{
m_log.Info("Region registration enabled.");
}
else
{
m_log.Info("Region registration disabled.");
}
}
protected override void StartupSpecific() protected override void StartupSpecific()
{ {
m_config = new GridConfig("GRID SERVER", (Path.Combine(Util.configDir(), "GridServer_Config.xml"))); m_config = new GridConfig("GRID SERVER", (Path.Combine(Util.configDir(), "GridServer_Config.xml")));
@ -106,43 +81,14 @@ namespace OpenSim.Grid.GridServer
m_log.Info("[GRID]: Starting HTTP process"); m_log.Info("[GRID]: Starting HTTP process");
m_httpServer = new BaseHttpServer(m_config.HttpPort); m_httpServer = new BaseHttpServer(m_config.HttpPort);
SetupGridServices();
AddHttpHandlers();
LoadPlugins(); LoadPlugins();
m_httpServer.Start(); m_httpServer.Start();
// m_log.Info("[GRID]: Starting sim status checker");
//
// Timer simCheckTimer = new Timer(3600000 * 3); // 3 Hours between updates.
// simCheckTimer.Elapsed += new ElapsedEventHandler(CheckSims);
// simCheckTimer.Enabled = true;
base.StartupSpecific(); base.StartupSpecific();
m_console.Commands.AddCommand("gridserver", false,
"enable registration",
"enable registration",
"Enable new regions to register", HandleRegistration);
m_console.Commands.AddCommand("gridserver", false,
"disable registration",
"disable registration",
"Disable registering new regions", HandleRegistration);
m_console.Commands.AddCommand("gridserver", false, "show status",
"show status",
"Show registration status", HandleShowStatus);
} }
protected void AddHttpHandlers() protected virtual void LoadPlugins()
{
// Registering Handlers is now done in the components/modules
}
protected void LoadPlugins()
{ {
PluginLoader<IGridPlugin> loader = PluginLoader<IGridPlugin> loader =
new PluginLoader<IGridPlugin>(new GridPluginInitialiser(this)); new PluginLoader<IGridPlugin>(new GridPluginInitialiser(this));
@ -151,39 +97,12 @@ namespace OpenSim.Grid.GridServer
m_plugins = loader.Plugins; m_plugins = loader.Plugins;
} }
protected virtual void SetupGridServices()
{
m_log.Info("[DATA]: Connecting to Storage Server");
m_gridDBService = new GridDBService();
m_gridDBService.AddPlugin(m_config.DatabaseProvider, m_config.DatabaseConnect);
//Register the database access service so modules can fetch it
// RegisterInterface<GridDBService>(m_gridDBService);
m_gridMessageModule = new GridMessagingModule();
m_gridMessageModule.Initialise(m_version, m_gridDBService, this, m_config);
m_gridXmlRpcModule = new GridXmlRpcModule();
m_gridXmlRpcModule.Initialise(m_version, m_gridDBService, this, m_config);
m_gridRestModule = new GridRestModule();
m_gridRestModule.Initialise(m_version, m_gridDBService, this, m_config);
m_gridMessageModule.PostInitialise();
m_gridXmlRpcModule.PostInitialise();
m_gridRestModule.PostInitialise();
}
public void CheckSims(object sender, ElapsedEventArgs e)
{
}
public override void ShutdownSpecific() public override void ShutdownSpecific()
{ {
foreach (IGridPlugin plugin in m_plugins) plugin.Dispose(); foreach (IGridPlugin plugin in m_plugins) plugin.Dispose();
} }
#region IUGAIMCore #region IServiceCore
protected Dictionary<Type, object> m_moduleInterfaces = new Dictionary<Type, object>(); protected Dictionary<Type, object> m_moduleInterfaces = new Dictionary<Type, object>();
/// <summary> /// <summary>

View File

@ -738,12 +738,14 @@
<Reference name="OpenSim.Data.MySQL"/> <Reference name="OpenSim.Data.MySQL"/>
<Reference name="OpenSim.Grid.Framework"/> <Reference name="OpenSim.Grid.Framework"/>
<Reference name="OpenMetaverseTypes.dll"/> <Reference name="OpenMetaverseTypes.dll"/>
<Reference name="OpenSim.Grid.GridServer"/>
<Reference name="OpenMetaverse.dll"/> <Reference name="OpenMetaverse.dll"/>
<Reference name="XMLRPC.dll"/> <Reference name="XMLRPC.dll"/>
<Reference name="log4net.dll"/> <Reference name="log4net.dll"/>
<Files> <Files>
<Match pattern="*.cs" recurse="true"/> <Match pattern="*.cs" recurse="true"/>
<Match pattern="*.addin.xml" path="Resources" buildAction="EmbeddedResource" recurse="true"/>
</Files> </Files>
</Project> </Project>
@ -772,7 +774,6 @@
<Reference name="OpenSim.Data"/> <Reference name="OpenSim.Data"/>
<Reference name="OpenSim.Data.MySQL"/> <Reference name="OpenSim.Data.MySQL"/>
<Reference name="OpenSim.Grid.Framework"/> <Reference name="OpenSim.Grid.Framework"/>
<Reference name="OpenSim.Grid.GridServer.Modules"/>
<Reference name="OpenMetaverseTypes.dll"/> <Reference name="OpenMetaverseTypes.dll"/>
<Reference name="OpenMetaverse.dll"/> <Reference name="OpenMetaverse.dll"/>
<Reference name="XMLRPC.dll"/> <Reference name="XMLRPC.dll"/>