123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179 |
- using System;
- using System.Collections.Generic;
- using System.Runtime.Remoting;
- using System.Runtime.Remoting.Channels;
- using System.Runtime.Remoting.Channels.Tcp;
- using Nini.Config;
- using OpenSim.Framework;
- using OpenSim.Region.Environment.Interfaces;
- using OpenSim.Region.Environment.Scenes;
- namespace OpenSim.Region.Environment.Modules.Grid.Interregion
- {
- public class InterregionModule : IInterregionModule, IRegionModule
- {
- #region Direction enum
- public enum Direction
- {
- North,
- NorthEast,
- East,
- SouthEast,
- South,
- SouthWest,
- West,
- NorthWest
- }
- #endregion
- private readonly Dictionary<Type, Object> m_interfaces = new Dictionary<Type, object>();
- private readonly List<Location> m_myLocations = new List<Location>();
- private readonly Dictionary<Location, string[]> m_neighbourInterfaces = new Dictionary<Location, string[]>();
- private readonly Dictionary<Location, RemotingObject> m_neighbourRemote = new Dictionary<Location, RemotingObject>();
- private IConfigSource m_config;
- private bool m_enabled = false;
- private Object m_lockObject = new object();
- private RemotingObject m_myRemote;
- private TcpChannel m_tcpChannel;
- private int m_tcpPort = 10101;
- #region IInterregionModule Members
- public void internal_CreateRemotingObjects()
- {
- lock (m_lockObject)
- {
- if (m_tcpChannel == null)
- {
- m_myRemote = new RemotingObject(m_interfaces, m_myLocations.ToArray());
- m_tcpChannel = new TcpChannel(m_tcpPort);
- ChannelServices.RegisterChannel(m_tcpChannel, false);
- RemotingServices.Marshal(m_myRemote, "OpenSimRemote2", typeof (RemotingObject));
- }
- }
- }
- public void RegisterMethod<T>(T e)
- {
- m_interfaces[typeof (T)] = e;
- }
- public bool HasInterface<T>(Location loc)
- {
- foreach (string val in m_neighbourInterfaces[loc])
- {
- if (val == typeof (T).FullName)
- {
- return true;
- }
- }
- return false;
- }
- public T RequestInterface<T>(Location loc)
- {
- if (m_neighbourRemote.ContainsKey(loc))
- {
- return m_neighbourRemote[loc].RequestInterface<T>();
- }
- else
- {
- throw new IndexOutOfRangeException("No neighbour availible at that location");
- }
- }
- public T[] RequestInterface<T>()
- {
- List<T> m_t = new List<T>();
- foreach (RemotingObject remote in m_neighbourRemote.Values)
- {
- try
- {
- m_t.Add(remote.RequestInterface<T>());
- }
- catch (NotSupportedException)
- {
- }
- }
- return m_t.ToArray();
- }
- public Location GetLocationByDirection(Scene scene, Direction dir)
- {
- return new Location(0, 0);
- }
- #endregion
- //TODO: This prevents us from registering new scenes after PostInitialise if we want comms updated.
- #region IRegionModule Members
- public void Initialise(Scene scene, IConfigSource source)
- {
- if (m_enabled)
- {
- m_myLocations.Add(new Location((int) scene.RegionInfo.RegionLocX,
- (int) scene.RegionInfo.RegionLocY));
- m_config = source;
- scene.RegisterModuleInterface<IInterregionModule>(this);
- }
- }
- //TODO: This prevents us from registering new scenes after PostInitialise if we want comms updated.
- public void PostInitialise()
- {
- if (m_enabled)
- {
- try
- {
- m_tcpPort = m_config.Configs["Comms"].GetInt("remoting_port", m_tcpPort);
- }
- catch
- {
- }
- internal_CreateRemotingObjects();
- }
- }
- public void Close()
- {
- ChannelServices.UnregisterChannel(m_tcpChannel);
- }
- public string Name
- {
- get { return "InterregionModule"; }
- }
- public bool IsSharedModule
- {
- get { return true; }
- }
- #endregion
- public void RegisterRemoteRegion(string uri)
- {
- RegisterRemotingInterface((RemotingObject) Activator.GetObject(typeof (RemotingObject), uri));
- }
- private void RegisterRemotingInterface(RemotingObject remote)
- {
- Location[] locs = remote.GetLocations();
- string[] interfaces = remote.GetInterfaces();
- foreach (Location loc in locs)
- {
- m_neighbourInterfaces[loc] = interfaces;
- m_neighbourRemote[loc] = remote;
- }
- }
- }
- }
|