/* * 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; using System.Collections.Generic; using System.Linq; using System.Text; using System.Reflection; using log4net; using OpenSim.Framework; using OpenMetaverse.StructuredData; namespace OpenSim.Framework.Monitoring { /// /// Static class used to register/deregister/fetch statistics /// public static class StatsManager { private static readonly ILog m_log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); // Subcommand used to list other stats. public const string AllSubCommand = "all"; // Subcommand used to list other stats. public const string ListSubCommand = "list"; // All subcommands public static HashSet SubCommands = new HashSet { AllSubCommand, ListSubCommand }; /// /// Registered stats categorized by category/container/shortname /// /// /// Do not add or remove directly from this dictionary. /// public static SortedDictionary>> RegisteredStats = new SortedDictionary>>(); // private static AssetStatsCollector assetStats; // private static UserStatsCollector userStats; // private static SimExtraStatsCollector simExtraStats = new SimExtraStatsCollector(); // public static AssetStatsCollector AssetStats { get { return assetStats; } } // public static UserStatsCollector UserStats { get { return userStats; } } public static SimExtraStatsCollector SimExtraStats { get; set; } public static void RegisterConsoleCommands(ICommandConsole console) { console.Commands.AddCommand( "General", false, "stats show", "stats show [list|all|([.])+", "Show statistical information for this server", "If no final argument is specified then legacy statistics information is currently shown.\n" + "'list' argument will show statistic categories.\n" + "'all' will show all statistics.\n" + "A name will show statistics from that category.\n" + "A . name will show statistics from that category in that container.\n" + "More than one name can be given separated by spaces.\n" + "THIS STATS FACILITY IS EXPERIMENTAL AND DOES NOT YET CONTAIN ALL STATS", HandleShowStatsCommand); console.Commands.AddCommand( "General", false, "show stats", "show stats [list|all|([.])+", "Alias for 'stats show' command", HandleShowStatsCommand); StatsLogger.RegisterConsoleCommands(console); } public static void HandleShowStatsCommand(string module, string[] cmd) { ICommandConsole con = MainConsole.Instance; StringBuilder report = new StringBuilder(); if (cmd.Length > 2) { foreach (string name in cmd.Skip(2)) { string[] components = name.Split('.'); string categoryName = components[0]; string containerName = components.Length > 1 ? components[1] : null; string statName = components.Length > 2 ? components[2] : null; if (categoryName == AllSubCommand) { foreach (string report2 in GetAllStatsReports()) report.AppendLine(report2); } else if (categoryName == ListSubCommand) { con.Output("Statistic categories available are:"); foreach (string category in RegisteredStats.Keys) con.OutputFormat(" {0}", category); } else { SortedDictionary> category; if (!RegisteredStats.TryGetValue(categoryName, out category)) { con.OutputFormat("No such category as {0}", categoryName); } else { if (String.IsNullOrEmpty(containerName)) { foreach (string report2 in GetCategoryStatsReports(category)) report.AppendLine(report2); } else { SortedDictionary container; if (category.TryGetValue(containerName, out container)) { if (String.IsNullOrEmpty(statName)) { foreach (string report2 in GetContainerStatsReports(container)) report.AppendLine(report2); } else { Stat stat; if (container.TryGetValue(statName, out stat)) { report.AppendLine(stat.ToConsoleString()); } else { con.OutputFormat( "No such stat {0} in {1}.{2}", statName, categoryName, containerName); } } } else { con.OutputFormat("No such container {0} in category {1}", containerName, categoryName); } } } } } } else { // Legacy if (SimExtraStats != null) { report.Append(SimExtraStats.Report()); } else { foreach (string report2 in GetAllStatsReports()) report.AppendLine(report2); } } if (report.Length > 0) m_log.Debug(string.Join(" ", cmd) + "\n" + report.ToString()); } public static List GetAllStatsReports() { List reports = new List(); foreach (var category in RegisteredStats.Values) reports.AddRange(GetCategoryStatsReports(category)); return reports; } private static List GetCategoryStatsReports( SortedDictionary> category) { List reports = new List(); foreach (var container in category.Values) reports.AddRange(GetContainerStatsReports(container)); return reports; } private static List GetContainerStatsReports(SortedDictionary container) { List reports = new List(); foreach (Stat stat in container.Values) reports.Add(stat.ToConsoleString()); return reports; } // Creates an OSDMap of the format: // { categoryName: { // containerName: { // statName: { // "Name": name, // "ShortName": shortName, // ... // }, // statName: { // "Name": name, // "ShortName": shortName, // ... // }, // ... // }, // containerName: { // ... // }, // ... // }, // categoryName: { // ... // }, // ... // } // The passed in parameters will filter the categories, containers and stats returned. If any of the // parameters are either EmptyOrNull or the AllSubCommand value, all of that type will be returned. // Case matters. public static OSDMap GetStatsAsOSDMap(string pCategoryName, string pContainerName, string pStatName) { OSDMap map = new OSDMap(); foreach (string catName in RegisteredStats.Keys) { // Do this category if null spec, "all" subcommand or category name matches passed parameter. // Skip category if none of the above. if (!(String.IsNullOrEmpty(pCategoryName) || pCategoryName == AllSubCommand || pCategoryName == catName)) continue; OSDMap contMap = new OSDMap(); foreach (string contName in RegisteredStats[catName].Keys) { if (!(string.IsNullOrEmpty(pContainerName) || pContainerName == AllSubCommand || pContainerName == contName)) continue; OSDMap statMap = new OSDMap(); SortedDictionary theStats = RegisteredStats[catName][contName]; foreach (string statName in theStats.Keys) { if (!(String.IsNullOrEmpty(pStatName) || pStatName == AllSubCommand || pStatName == statName)) continue; statMap.Add(statName, theStats[statName].ToOSDMap()); } contMap.Add(contName, statMap); } map.Add(catName, contMap); } return map; } public static Hashtable HandleStatsRequest(Hashtable request) { Hashtable responsedata = new Hashtable(); // string regpath = request["uri"].ToString(); int response_code = 200; string contenttype = "text/json"; string pCategoryName = StatsManager.AllSubCommand; string pContainerName = StatsManager.AllSubCommand; string pStatName = StatsManager.AllSubCommand; if (request.ContainsKey("cat")) pCategoryName = request["cat"].ToString(); if (request.ContainsKey("cont")) pContainerName = request["cat"].ToString(); if (request.ContainsKey("stat")) pStatName = request["cat"].ToString(); string strOut = StatsManager.GetStatsAsOSDMap(pCategoryName, pContainerName, pStatName).ToString(); // If requestor wants it as a callback function, build response as a function rather than just the JSON string. if (request.ContainsKey("callback")) { strOut = request["callback"].ToString() + "(" + strOut + ");"; } // m_log.DebugFormat("{0} StatFetch: uri={1}, cat={2}, cont={3}, stat={4}, resp={5}", // LogHeader, regpath, pCategoryName, pContainerName, pStatName, strOut); responsedata["int_response_code"] = response_code; responsedata["content_type"] = contenttype; responsedata["keepalive"] = false; responsedata["str_response_string"] = strOut; responsedata["access_control_allow_origin"] = "*"; return responsedata; } // /// // /// Start collecting statistics related to assets. // /// Should only be called once. // /// // public static AssetStatsCollector StartCollectingAssetStats() // { // assetStats = new AssetStatsCollector(); // // return assetStats; // } // // /// // /// Start collecting statistics related to users. // /// Should only be called once. // /// // public static UserStatsCollector StartCollectingUserStats() // { // userStats = new UserStatsCollector(); // // return userStats; // } /// /// Register a statistic. /// /// /// public static bool RegisterStat(Stat stat) { SortedDictionary> category = null, newCategory; SortedDictionary container = null, newContainer; lock (RegisteredStats) { // Stat name is not unique across category/container/shortname key. // XXX: For now just return false. This is to avoid problems in regression tests where all tests // in a class are run in the same instance of the VM. if (TryGetStatParents(stat, out category, out container)) return false; // We take a copy-on-write approach here of replacing dictionaries when keys are added or removed. // This means that we don't need to lock or copy them on iteration, which will be a much more // common operation after startup. if (container != null) newContainer = new SortedDictionary(container); else newContainer = new SortedDictionary(); if (category != null) newCategory = new SortedDictionary>(category); else newCategory = new SortedDictionary>(); newContainer[stat.ShortName] = stat; newCategory[stat.Container] = newContainer; RegisteredStats[stat.Category] = newCategory; } return true; } /// /// Deregister a statistic /// > /// /// public static bool DeregisterStat(Stat stat) { SortedDictionary> category = null, newCategory; SortedDictionary container = null, newContainer; lock (RegisteredStats) { if (!TryGetStatParents(stat, out category, out container)) return false; newContainer = new SortedDictionary(container); newContainer.Remove(stat.ShortName); newCategory = new SortedDictionary>(category); newCategory.Remove(stat.Container); newCategory[stat.Container] = newContainer; RegisteredStats[stat.Category] = newCategory; return true; } } public static bool TryGetStat(string category, string container, string statShortName, out Stat stat) { stat = null; SortedDictionary> categoryStats; lock (RegisteredStats) { if (!TryGetStatsForCategory(category, out categoryStats)) return false; SortedDictionary containerStats; if (!categoryStats.TryGetValue(container, out containerStats)) return false; return containerStats.TryGetValue(statShortName, out stat); } } public static bool TryGetStatsForCategory( string category, out SortedDictionary> stats) { lock (RegisteredStats) return RegisteredStats.TryGetValue(category, out stats); } /// /// Get the same stat for each container in a given category. /// /// /// The stats if there were any to fetch. Otherwise null. /// /// /// public static List GetStatsFromEachContainer(string category, string statShortName) { SortedDictionary> categoryStats; lock (RegisteredStats) { if (!RegisteredStats.TryGetValue(category, out categoryStats)) return null; List stats = null; foreach (SortedDictionary containerStats in categoryStats.Values) { if (containerStats.ContainsKey(statShortName)) { if (stats == null) stats = new List(); stats.Add(containerStats[statShortName]); } } return stats; } } public static bool TryGetStatParents( Stat stat, out SortedDictionary> category, out SortedDictionary container) { category = null; container = null; lock (RegisteredStats) { if (RegisteredStats.TryGetValue(stat.Category, out category)) { if (category.TryGetValue(stat.Container, out container)) { if (container.ContainsKey(stat.ShortName)) return true; } } } return false; } public static void RecordStats() { lock (RegisteredStats) { foreach (SortedDictionary> category in RegisteredStats.Values) { foreach (SortedDictionary container in category.Values) { foreach (Stat stat in container.Values) { if (stat.MeasuresOfInterest != MeasuresOfInterest.None) stat.RecordValue(); } } } } } } /// /// Stat type. /// /// /// A push stat is one which is continually updated and so it's value can simply by read. /// A pull stat is one where reading the value triggers a collection method - the stat is not continually updated. /// public enum StatType { Push, Pull } /// /// Measures of interest for this stat. /// [Flags] public enum MeasuresOfInterest { None, AverageChangeOverTime } /// /// Verbosity of stat. /// /// /// Info will always be displayed. /// public enum StatVerbosity { Debug, Info } }