/* * 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 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.Collections.Generic; using System.Linq; using System.Reflection; using System.Threading; using OpenMetaverse; using log4net; using log4net.Appender; using log4net.Core; using log4net.Repository; using Nini.Config; using OpenSim.Framework; using OpenSim.Framework.Console; using OpenSim.Framework.Monitoring; using pCampBot.Interfaces; namespace pCampBot { /// /// Thread/Bot manager for the application /// public class BotManager { private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); public const int DefaultLoginDelay = 5000; /// /// Is pCampbot in the process of connecting bots? /// public bool ConnectingBots { get; private set; } /// /// Is pCampbot in the process of disconnecting bots? /// public bool DisconnectingBots { get; private set; } /// /// Delay between logins of multiple bots. /// /// TODO: This value needs to be configurable by a command line argument. public int LoginDelay { get; set; } /// /// Command console /// protected CommandConsole m_console; /// /// Controls whether bots start out sending agent updates on connection. /// public bool InitBotSendAgentUpdates { get; set; } /// /// Controls whether bots request textures for the object information they receive /// public bool InitBotRequestObjectTextures { get; set; } /// /// Created bots, whether active or inactive. /// protected List m_bots; /// /// Random number generator. /// public Random Rng { get; private set; } /// /// Track the assets we have and have not received so we don't endlessly repeat requests. /// public Dictionary AssetsReceived { get; private set; } /// /// The regions that we know about. /// public Dictionary RegionsKnown { get; private set; } /// /// First name for bots /// private string m_firstName; /// /// Last name stem for bots /// private string m_lastNameStem; /// /// Password for bots /// private string m_password; /// /// Login URI for bots. /// private string m_loginUri; /// /// Start location for bots. /// private string m_startUri; /// /// Postfix bot number at which bot sequence starts. /// private int m_fromBotNumber; /// /// Wear setting for bots. /// private string m_wearSetting; /// /// Behaviour switches for bots. /// private HashSet m_defaultBehaviourSwitches = new HashSet(); /// /// Collects general information on this server (which reveals this to be a misnamed class). /// private ServerStatsCollector m_serverStatsCollector; /// /// Constructor Creates MainConsole.Instance to take commands and provide the place to write data /// public BotManager() { // We set this to avoid issues with bots running out of HTTP connections if many are run from a single machine // to multiple regions. Settings.MAX_HTTP_CONNECTIONS = int.MaxValue; // System.Threading.ThreadPool.SetMaxThreads(600, 240); // // int workerThreads, iocpThreads; // System.Threading.ThreadPool.GetMaxThreads(out workerThreads, out iocpThreads); // Console.WriteLine("ThreadPool.GetMaxThreads {0} {1}", workerThreads, iocpThreads); InitBotSendAgentUpdates = true; InitBotRequestObjectTextures = true; LoginDelay = DefaultLoginDelay; Rng = new Random(Environment.TickCount); AssetsReceived = new Dictionary(); RegionsKnown = new Dictionary(); m_console = CreateConsole(); MainConsole.Instance = m_console; // Make log4net see the console // ILoggerRepository repository = LogManager.GetRepository(); IAppender[] appenders = repository.GetAppenders(); OpenSimAppender consoleAppender = null; foreach (IAppender appender in appenders) { if (appender.Name == "Console") { consoleAppender = (OpenSimAppender)appender; consoleAppender.Console = m_console; break; } } m_console.Commands.AddCommand( "Bots", false, "shutdown", "shutdown", "Shutdown bots and exit", HandleShutdown); m_console.Commands.AddCommand( "Bots", false, "quit", "quit", "Shutdown bots and exit", HandleShutdown); m_console.Commands.AddCommand( "Bots", false, "connect", "connect []", "Connect bots", "If an is given, then the first disconnected bots by postfix number are connected.\n" + "If no is given, then all currently disconnected bots are connected.", HandleConnect); m_console.Commands.AddCommand( "Bots", false, "disconnect", "disconnect []", "Disconnect bots", "Disconnecting bots will interupt any bot connection process, including connection on startup.\n" + "If an is given, then the last connected bots by postfix number are disconnected.\n" + "If no is given, then all currently connected bots are disconnected.", HandleDisconnect); m_console.Commands.AddCommand( "Bots", false, "add behaviour", "add behaviour []", "Add a behaviour to a bot", "If no bot number is specified then behaviour is added to all bots.\n" + "Can be performed on connected or disconnected bots.", HandleAddBehaviour); m_console.Commands.AddCommand( "Bots", false, "remove behaviour", "remove behaviour []", "Remove a behaviour from a bot", "If no bot number is specified then behaviour is added to all bots.\n" + "Can be performed on connected or disconnected bots.", HandleRemoveBehaviour); m_console.Commands.AddCommand( "Bots", false, "sit", "sit", "Sit all bots on the ground.", HandleSit); m_console.Commands.AddCommand( "Bots", false, "stand", "stand", "Stand all bots.", HandleStand); m_console.Commands.AddCommand( "Bots", false, "set bots", "set bots ", "Set a setting for all bots.", HandleSetBots); m_console.Commands.AddCommand( "Bots", false, "show regions", "show regions", "Show regions known to bots", HandleShowRegions); m_console.Commands.AddCommand( "Bots", false, "show bots", "show bots", "Shows the status of all bots", HandleShowBotsStatus); m_console.Commands.AddCommand( "Bots", false, "show bot", "show bot ", "Shows the detailed status and settings of a particular bot.", HandleShowBotStatus); m_bots = new List(); Watchdog.Enabled = true; StatsManager.RegisterConsoleCommands(m_console); m_serverStatsCollector = new ServerStatsCollector(); m_serverStatsCollector.Initialise(null); m_serverStatsCollector.Enabled = true; m_serverStatsCollector.Start(); } /// /// Startup number of bots specified in the starting arguments /// /// How many bots to start up /// The configuration for the bots to use public void CreateBots(int botcount, IConfig startupConfig) { m_firstName = startupConfig.GetString("firstname"); m_lastNameStem = startupConfig.GetString("lastname"); m_password = startupConfig.GetString("password"); m_loginUri = startupConfig.GetString("loginuri"); m_fromBotNumber = startupConfig.GetInt("from", 0); m_wearSetting = startupConfig.GetString("wear", "no"); m_startUri = ParseInputStartLocationToUri(startupConfig.GetString("start", "last")); Array.ForEach( startupConfig.GetString("behaviours", "p").Split(new char[] { ',' }), b => m_defaultBehaviourSwitches.Add(b)); for (int i = 0; i < botcount; i++) { lock (m_bots) { string lastName = string.Format("{0}_{1}", m_lastNameStem, i + m_fromBotNumber); CreateBot( this, CreateBehavioursFromAbbreviatedNames(m_defaultBehaviourSwitches), m_firstName, lastName, m_password, m_loginUri, m_startUri, m_wearSetting); } } } private List CreateBehavioursFromAbbreviatedNames(HashSet abbreviatedNames) { // We must give each bot its own list of instantiated behaviours since they store state. List behaviours = new List(); // Hard-coded for now foreach (string abName in abbreviatedNames) { IBehaviour newBehaviour = null; if (abName == "c") newBehaviour = new CrossBehaviour(); if (abName == "g") newBehaviour = new GrabbingBehaviour(); if (abName == "n") newBehaviour = new NoneBehaviour(); if (abName == "p") newBehaviour = new PhysicsBehaviour(); if (abName == "t") newBehaviour = new TeleportBehaviour(); if (abName == "tw") newBehaviour = new TwitchyBehaviour(); if (abName == "ph2") newBehaviour = new PhysicsBehaviour2(); if (newBehaviour != null) { behaviours.Add(newBehaviour); } else { MainConsole.Instance.OutputFormat("No behaviour with abbreviated name {0} found", abName); } } return behaviours; } public void ConnectBots(int botcount) { ConnectingBots = true; Thread connectBotThread = new Thread(o => ConnectBotsInternal(botcount)); connectBotThread.Name = "Bots connection thread"; connectBotThread.Start(); } private void ConnectBotsInternal(int botCount) { m_log.InfoFormat( "[BOT MANAGER]: Starting {0} bots connecting to {1}, location {2}, named {3} {4}_", botCount, m_loginUri, m_startUri, m_firstName, m_lastNameStem); m_log.DebugFormat("[BOT MANAGER]: Delay between logins is {0}ms", LoginDelay); m_log.DebugFormat("[BOT MANAGER]: BotsSendAgentUpdates is {0}", InitBotSendAgentUpdates); m_log.DebugFormat("[BOT MANAGER]: InitBotRequestObjectTextures is {0}", InitBotRequestObjectTextures); List botsToConnect = new List(); lock (m_bots) { foreach (Bot bot in m_bots) { if (bot.ConnectionState == ConnectionState.Disconnected) botsToConnect.Add(bot); if (botsToConnect.Count >= botCount) break; } } foreach (Bot bot in botsToConnect) { if (!ConnectingBots) { MainConsole.Instance.Output( "[BOT MANAGER]: Aborting bot connection due to user-initiated disconnection"); break; } bot.Connect(); // Stagger logins Thread.Sleep(LoginDelay); } ConnectingBots = false; } /// /// Parses the command line start location to a start string/uri that the login mechanism will recognize. /// /// /// The input start location to URI. /// /// /// Start location. /// private string ParseInputStartLocationToUri(string startLocation) { if (startLocation == "home" || startLocation == "last") return startLocation; string regionName; // Just a region name or only one (!) extra component. Like a viewer, we will stick 128/128/0 on the end Vector3 startPos = new Vector3(128, 128, 0); string[] startLocationComponents = startLocation.Split('/'); regionName = startLocationComponents[0]; if (startLocationComponents.Length >= 2) { float.TryParse(startLocationComponents[1], out startPos.X); if (startLocationComponents.Length >= 3) { float.TryParse(startLocationComponents[2], out startPos.Y); if (startLocationComponents.Length >= 4) float.TryParse(startLocationComponents[3], out startPos.Z); } } return string.Format("uri:{0}&{1}&{2}&{3}", regionName, startPos.X, startPos.Y, startPos.Z); } /// /// This creates a bot but does not start it. /// /// /// Behaviours for this bot to perform. /// First name /// Last name /// Password /// Login URI /// Location to start the bot. Can be "last", "home" or a specific sim name. /// public void CreateBot( BotManager bm, List behaviours, string firstName, string lastName, string password, string loginUri, string startLocation, string wearSetting) { MainConsole.Instance.OutputFormat( "[BOT MANAGER]: Creating bot {0} {1}, behaviours are {2}", firstName, lastName, string.Join(",", behaviours.ConvertAll(b => b.Name).ToArray())); Bot pb = new Bot(bm, behaviours, firstName, lastName, password, startLocation, loginUri); pb.wear = wearSetting; pb.Client.Settings.SEND_AGENT_UPDATES = InitBotSendAgentUpdates; pb.RequestObjectTextures = InitBotRequestObjectTextures; pb.OnConnected += handlebotEvent; pb.OnDisconnected += handlebotEvent; m_bots.Add(pb); } /// /// High level connnected/disconnected events so we can keep track of our threads by proxy /// /// /// private void handlebotEvent(Bot callbot, EventType eventt) { switch (eventt) { case EventType.CONNECTED: { m_log.Info("[" + callbot.FirstName + " " + callbot.LastName + "]: Connected"); break; } case EventType.DISCONNECTED: { m_log.Info("[" + callbot.FirstName + " " + callbot.LastName + "]: Disconnected"); break; } } } /// /// Standard CreateConsole routine /// /// protected CommandConsole CreateConsole() { return new LocalConsole("pCampbot"); } private void HandleConnect(string module, string[] cmd) { if (ConnectingBots) { MainConsole.Instance.Output("Still connecting bots. Please wait for previous process to complete."); return; } lock (m_bots) { int botsToConnect; int disconnectedBots = m_bots.Count(b => b.ConnectionState == ConnectionState.Disconnected); if (cmd.Length == 1) { botsToConnect = disconnectedBots; } else { if (!ConsoleUtil.TryParseConsoleNaturalInt(MainConsole.Instance, cmd[1], out botsToConnect)) return; botsToConnect = Math.Min(botsToConnect, disconnectedBots); } MainConsole.Instance.OutputFormat("Connecting {0} bots", botsToConnect); ConnectBots(botsToConnect); } } private void HandleAddBehaviour(string module, string[] cmd) { if (cmd.Length < 3 || cmd.Length > 4) { MainConsole.Instance.OutputFormat("Usage: add behaviour []"); return; } string rawBehaviours = cmd[2]; List botsToEffect = new List(); if (cmd.Length == 3) { lock (m_bots) botsToEffect.AddRange(m_bots); } else { int botNumber; if (!ConsoleUtil.TryParseConsoleNaturalInt(MainConsole.Instance, cmd[3], out botNumber)) return; Bot bot = GetBotFromNumber(botNumber); if (bot == null) { MainConsole.Instance.OutputFormat("Error: No bot found with number {0}", botNumber); return; } botsToEffect.Add(bot); } HashSet rawAbbreviatedSwitchesToAdd = new HashSet(); Array.ForEach(rawBehaviours.Split(new char[] { ',' }), b => rawAbbreviatedSwitchesToAdd.Add(b)); foreach (Bot bot in botsToEffect) { List behavioursAdded = new List(); foreach (IBehaviour behaviour in CreateBehavioursFromAbbreviatedNames(rawAbbreviatedSwitchesToAdd)) { if (bot.AddBehaviour(behaviour)) behavioursAdded.Add(behaviour); } MainConsole.Instance.OutputFormat( "Added behaviours {0} to bot {1}", string.Join(", ", behavioursAdded.ConvertAll(b => b.Name).ToArray()), bot.Name); } } private void HandleRemoveBehaviour(string module, string[] cmd) { if (cmd.Length < 3 || cmd.Length > 4) { MainConsole.Instance.OutputFormat("Usage: remove behaviour []"); return; } string rawBehaviours = cmd[2]; List botsToEffect = new List(); if (cmd.Length == 3) { lock (m_bots) botsToEffect.AddRange(m_bots); } else { int botNumber; if (!ConsoleUtil.TryParseConsoleNaturalInt(MainConsole.Instance, cmd[3], out botNumber)) return; Bot bot = GetBotFromNumber(botNumber); if (bot == null) { MainConsole.Instance.OutputFormat("Error: No bot found with number {0}", botNumber); return; } botsToEffect.Add(bot); } HashSet abbreviatedBehavioursToRemove = new HashSet(); Array.ForEach(rawBehaviours.Split(new char[] { ',' }), b => abbreviatedBehavioursToRemove.Add(b)); foreach (Bot bot in botsToEffect) { List behavioursRemoved = new List(); foreach (string b in abbreviatedBehavioursToRemove) { IBehaviour behaviour; if (bot.TryGetBehaviour(b, out behaviour)) { bot.RemoveBehaviour(b); behavioursRemoved.Add(behaviour); } } MainConsole.Instance.OutputFormat( "Removed behaviours {0} from bot {1}", string.Join(", ", behavioursRemoved.ConvertAll(b => b.Name).ToArray()), bot.Name); } } private void HandleDisconnect(string module, string[] cmd) { List connectedBots; int botsToDisconnectCount; lock (m_bots) connectedBots = m_bots.FindAll(b => b.ConnectionState == ConnectionState.Connected); if (cmd.Length == 1) { botsToDisconnectCount = connectedBots.Count; } else { if (!ConsoleUtil.TryParseConsoleNaturalInt(MainConsole.Instance, cmd[1], out botsToDisconnectCount)) return; botsToDisconnectCount = Math.Min(botsToDisconnectCount, connectedBots.Count); } DisconnectingBots = true; Thread disconnectBotThread = new Thread(o => DisconnectBotsInternal(connectedBots, botsToDisconnectCount)); disconnectBotThread.Name = "Bots disconnection thread"; disconnectBotThread.Start(); } private void DisconnectBotsInternal(List connectedBots, int disconnectCount) { ConnectingBots = false; MainConsole.Instance.OutputFormat("Disconnecting {0} bots", disconnectCount); int disconnectedBots = 0; for (int i = connectedBots.Count - 1; i >= 0; i--) { if (disconnectedBots >= disconnectCount) break; Bot thisBot = connectedBots[i]; if (thisBot.ConnectionState == ConnectionState.Connected) { ThreadPool.QueueUserWorkItem(o => thisBot.Disconnect()); disconnectedBots++; } } DisconnectingBots = false; } private void HandleSit(string module, string[] cmd) { lock (m_bots) { foreach (Bot bot in m_bots) { if (bot.ConnectionState == ConnectionState.Connected) { MainConsole.Instance.OutputFormat("Sitting bot {0} on ground.", bot.Name); bot.SitOnGround(); } } } } private void HandleStand(string module, string[] cmd) { lock (m_bots) { foreach (Bot bot in m_bots) { if (bot.ConnectionState == ConnectionState.Connected) { MainConsole.Instance.OutputFormat("Standing bot {0} from ground.", bot.Name); bot.Stand(); } } } } private void HandleShutdown(string module, string[] cmd) { lock (m_bots) { int connectedBots = m_bots.Count(b => b.ConnectionState == ConnectionState.Connected); if (connectedBots > 0) { MainConsole.Instance.OutputFormat("Please disconnect {0} connected bots first", connectedBots); return; } } MainConsole.Instance.Output("Shutting down"); m_serverStatsCollector.Close(); Environment.Exit(0); } private void HandleSetBots(string module, string[] cmd) { string key = cmd[2]; string rawValue = cmd[3]; if (key == "SEND_AGENT_UPDATES") { bool newSendAgentUpdatesSetting; if (!ConsoleUtil.TryParseConsoleBool(MainConsole.Instance, rawValue, out newSendAgentUpdatesSetting)) return; MainConsole.Instance.OutputFormat( "Setting SEND_AGENT_UPDATES to {0} for all bots", newSendAgentUpdatesSetting); lock (m_bots) m_bots.ForEach(b => b.Client.Settings.SEND_AGENT_UPDATES = newSendAgentUpdatesSetting); } else { MainConsole.Instance.Output("Error: Only setting currently available is SEND_AGENT_UPDATES"); } } private void HandleShowRegions(string module, string[] cmd) { string outputFormat = "{0,-30} {1, -20} {2, -5} {3, -5}"; MainConsole.Instance.OutputFormat(outputFormat, "Name", "Handle", "X", "Y"); lock (RegionsKnown) { foreach (GridRegion region in RegionsKnown.Values) { MainConsole.Instance.OutputFormat( outputFormat, region.Name, region.RegionHandle, region.X, region.Y); } } } private void HandleShowBotsStatus(string module, string[] cmd) { ConsoleDisplayTable cdt = new ConsoleDisplayTable(); cdt.AddColumn("Name", 24); cdt.AddColumn("Region", 24); cdt.AddColumn("Status", 13); cdt.AddColumn("Conns", 5); cdt.AddColumn("Behaviours", 20); Dictionary totals = new Dictionary(); foreach (object o in Enum.GetValues(typeof(ConnectionState))) totals[(ConnectionState)o] = 0; lock (m_bots) { foreach (Bot bot in m_bots) { Simulator currentSim = bot.Client.Network.CurrentSim; totals[bot.ConnectionState]++; cdt.AddRow( bot.Name, currentSim != null ? currentSim.Name : "(none)", bot.ConnectionState, bot.SimulatorsCount, string.Join(",", bot.Behaviours.Keys.ToArray())); } } MainConsole.Instance.Output(cdt.ToString()); ConsoleDisplayList cdl = new ConsoleDisplayList(); foreach (KeyValuePair kvp in totals) cdl.AddRow(kvp.Key, kvp.Value); MainConsole.Instance.Output(cdl.ToString()); } private void HandleShowBotStatus(string module, string[] cmd) { if (cmd.Length != 3) { MainConsole.Instance.Output("Usage: show bot "); return; } int botNumber; if (!ConsoleUtil.TryParseConsoleInt(MainConsole.Instance, cmd[2], out botNumber)) return; Bot bot = GetBotFromNumber(botNumber); if (bot == null) { MainConsole.Instance.OutputFormat("Error: No bot found with number {0}", botNumber); return; } ConsoleDisplayList cdl = new ConsoleDisplayList(); cdl.AddRow("Name", bot.Name); cdl.AddRow("Status", bot.ConnectionState); Simulator currentSim = bot.Client.Network.CurrentSim; cdl.AddRow("Region", currentSim != null ? currentSim.Name : "(none)"); List connectedSimulators = bot.Simulators; List simulatorNames = connectedSimulators.ConvertAll(cs => cs.Name); cdl.AddRow("Connections", string.Join(", ", simulatorNames.ToArray())); MainConsole.Instance.Output(cdl.ToString()); MainConsole.Instance.Output("Settings"); ConsoleDisplayList statusCdl = new ConsoleDisplayList(); statusCdl.AddRow( "Behaviours", string.Join(", ", bot.Behaviours.Values.ToList().ConvertAll(b => b.Name).ToArray())); GridClient botClient = bot.Client; statusCdl.AddRow("SEND_AGENT_UPDATES", botClient.Settings.SEND_AGENT_UPDATES); MainConsole.Instance.Output(statusCdl.ToString()); } /// /// Get a specific bot from its number. /// /// null if no bot was found /// private Bot GetBotFromNumber(int botNumber) { string name = GenerateBotNameFromNumber(botNumber); Bot bot; lock (m_bots) bot = m_bots.Find(b => b.Name == name); return bot; } private string GenerateBotNameFromNumber(int botNumber) { return string.Format("{0} {1}_{2}", m_firstName, m_lastNameStem, botNumber); } internal void Grid_GridRegion(object o, GridRegionEventArgs args) { lock (RegionsKnown) { GridRegion newRegion = args.Region; if (RegionsKnown.ContainsKey(newRegion.RegionHandle)) { return; } else { m_log.DebugFormat( "[BOT MANAGER]: Adding {0} {1} to known regions", newRegion.Name, newRegion.RegionHandle); RegionsKnown[newRegion.RegionHandle] = newRegion; } } } } }