/* * Copyright (c) Contributors, https://github.com/jonc/osboids * 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 OpenSimulator 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.Timers; using System.Collections.Generic; using OpenMetaverse; using System.IO; using Nini.Config; using System.Threading; using log4net; using OpenSim.Region.Framework.Interfaces; using OpenSim.Region.Framework.Scenes; using OpenSim.Framework; using OpenSim.Framework.Console; using Mono.Addins; [assembly: Addin("BoidsModule", "0.1")] [assembly: AddinDependency("OpenSim", "0.5")] namespace Flocking { [Extension(Path = "/OpenSim/RegionModules", NodeName = "RegionModule")] public class FlockingModule : INonSharedRegionModule { #region Fields private static readonly ILog m_log = LogManager.GetLogger (System.Reflection.MethodBase.GetCurrentMethod ().DeclaringType); static object m_sync = new object(); public string m_name = "BoidsModule"; private Scene m_scene; private FlockingModel m_model; private FlockingView m_view; private bool m_enabled = false; private bool m_ready = false; private uint m_frame = 0; private int m_frameUpdateRate = 1; private int m_chatChannel = 118; private string m_boidPrim; private int m_flockSize = 100; private float m_maxSpeed; private float m_maxForce; private float m_neighbourDistance; private float m_desiredSeparation; private float m_tolerance; private float m_borderSize; private int m_maxHeight; private UUID m_owner; #endregion #region IRegionModuleBase implementation public void Initialise (IConfigSource source) { //check if we are in the ini files //if so get some physical constants out of them and pass into the model IConfig config = source.Configs ["Boids"]; if (config != null) { m_chatChannel = config.GetInt ("chat-channel", 118); m_boidPrim = config.GetString ("boid-prim", "boidPrim"); m_flockSize = config.GetInt ("flock-size", 100); m_maxSpeed = config.GetFloat("max-speed", 3f); m_maxForce = config.GetFloat("max-force", 0.25f); m_neighbourDistance = config.GetFloat("neighbour-dist", 25f); m_desiredSeparation = config.GetFloat("desired-separation", 20f); m_tolerance = config.GetFloat("tolerance", 5f); m_borderSize = config.GetFloat("border-size", 5f); m_maxHeight = config.GetInt("max-height", 256); m_enabled = config.GetBoolean("enabled", false); } if (m_enabled) { m_log.InfoFormat("[BOIDS] Enabled on channel {0} with Flock Size {1}", m_chatChannel, m_flockSize); //m_ready = true; return; } } public void PostInitialise() { } public void AddRegion (Scene scene) { m_scene = scene; m_log.InfoFormat ("[BOIDS]: Adding {0}", scene.RegionInfo.RegionName); if (m_enabled) { //register commands RegisterCommands(); //register handlers scene.EventManager.OnFrame += FlockUpdate; scene.EventManager.OnChatFromClient += SimChatSent; //listen for commands sent from the client // init module m_model = new FlockingModel(m_maxSpeed, m_maxForce, m_neighbourDistance, m_desiredSeparation, m_tolerance, m_borderSize); m_view = new FlockingView(scene); m_view.BoidPrim = m_boidPrim; } } public void RegionLoaded (Scene scene) { if (m_enabled) { //make a flow map for this scene FlowMap flowMap = new FlowMap(scene, m_maxHeight, m_borderSize); flowMap.Initialise(); // Generate initial flock values m_model.Initialise (m_flockSize, flowMap); // who is the owner for the flock in this region m_owner = scene.RegionInfo.EstateSettings.EstateOwner; m_view.PostInitialize (m_owner); // Mark Module Ready for duty m_ready = true; } } public void RemoveRegion (Scene scene) { if (m_enabled) { m_ready = false; scene.EventManager.OnFrame -= FlockUpdate; scene.EventManager.OnChatFromClient -= SimChatSent; } } public void Close() { if (m_enabled) { m_ready = false; m_scene.EventManager.OnFrame -= FlockUpdate; m_scene.EventManager.OnChatFromClient -= SimChatSent; } } public string Name { get { return m_name; } } public bool IsSharedModule { get { return false; } } public Type ReplaceableInterface { get { return null; } } #endregion #region EventHandlers public void FlockUpdate () { if (((m_frame++ % m_frameUpdateRate) != 0) || !m_ready || !m_enabled) { return; } //m_log.InfoFormat("update my boids"); // work out where everyone has moved to // and tell the scene to render the new positions lock( m_sync ) { List boids = m_model.UpdateFlockPos (); m_view.Render (boids); } } protected void SimChatSent (Object x, OSChatMessage msg) { if (m_scene.ConsoleScene () != m_scene || msg.Channel != m_chatChannel) return; // not for us // try and parse a valid cmd from this msg string cmd = msg.Message.ToLower (); //stick ui in the args so we know to respond in world //bit of a hack - but lets us use CommandDelegate inWorld string[] args = (cmd + " ").Split (" ".ToCharArray ()); if (cmd.StartsWith ("stop")) { HandleStopCmd ("flock", args); } else if (cmd.StartsWith ("start")) { HandleStartCmd ("flock", args); } else if (cmd.StartsWith ("size")) { HandleSetSizeCmd ("flock", args); } else if (cmd.StartsWith ("stats")) { HandleShowStatsCmd ("flock", args); } else if (cmd.StartsWith ("prim")) { HandleSetPrimCmd ("flock", args); } else if (cmd.StartsWith ("framerate")) { HandleSetFrameRateCmd ("flock", args); } } #endregion #region Command Handling private void AddCommand (string cmd, string args, string help, CommandDelegate fn) { string argStr = ""; if (args.Trim ().Length > 0) { argStr = " <" + args + "> "; } m_scene.AddCommand (this, "flock-" + cmd, "flock-" + cmd + argStr, help, fn); } private void RegisterCommands () { AddCommand ("stop", "", "Stop all Flocking", HandleStopCmd); AddCommand ("start", "", "Start Flocking", HandleStartCmd); AddCommand ("size", "num", "Adjust the size of the flock ", HandleSetSizeCmd); AddCommand ("stats", "", "show flocking stats", HandleShowStatsCmd); AddCommand ("prim", "name", "set the prim used for each boid to that passed in", HandleSetPrimCmd); AddCommand ("framerate", "num", "[debugging] only update boids every frames", HandleSetFrameRateCmd); } private bool ShouldHandleCmd () { return m_scene.ConsoleScene () == m_scene; } private bool IsInWorldCmd (ref string [] args) { bool retVal = false; if (args.Length > 0 && args [args.Length - 1].Equals ("")) { retVal = true; } return retVal; } private void ShowResponse (string response, bool inWorld) { if (inWorld) { IClientAPI ownerAPI = null; if (m_scene.TryGetClient (m_owner, out ownerAPI)) { ownerAPI.SendBlueBoxMessage (m_owner, "Boids", response); } } else { MainConsole.Instance.Output (response); } } public void HandleStopCmd (string module, string[] args) { if (ShouldHandleCmd ()) { m_log.Info ("stop the flocking capability"); m_enabled = false; m_view.Clear (); } } void HandleSetFrameRateCmd (string module, string[] args) { if (ShouldHandleCmd ()) { int frameRate = Convert.ToInt32( args[1] ); m_frameUpdateRate = frameRate; } } public void HandleStartCmd (string module, string[] args) { if (ShouldHandleCmd ()) { m_log.Info ("start the flocking capability"); m_enabled = true; FlockUpdate (); } } public void HandleSetSizeCmd (string module, string[] args) { if (ShouldHandleCmd ()) { lock( m_sync ) { int newSize = Convert.ToInt32(args[1]); m_model.Size = newSize; m_view.Clear(); } } } public void HandleShowStatsCmd (string module, string[] args) { if (ShouldHandleCmd ()) { bool inWorld = IsInWorldCmd (ref args); ShowResponse ("Num Boids = " + m_model.Size, inWorld); } } public void HandleSetPrimCmd (string module, string[] args) { if (ShouldHandleCmd ()) { string primName = args[1]; lock(m_sync) { m_view.BoidPrim = primName; m_view.Clear(); } } } #endregion } }