svn merge -r84490:84497 svn+ssh://svn/svn/linden/branches/DEV-11812-3

QAR-433 make max queued size on event queue configurable

etc/message.xml

@@ -562,5 +562,8 @@
 			<map>
 			</map>
 		</map>
+
+		<key>maxQueuedEvents</key>
+		<integer>100</integer>
     </map>
 </llsd>

indra/llmessage/llmessageconfig.cpp

@@ -66,6 +66,7 @@ public:
 
 	/* virtual */ void loadFile();
 	void loadServerDefaults(const LLSD& data);
+	 void loadMaxQueuedEvents(const LLSD& data);
 	void loadMessages(const LLSD& data);
 	void loadCapBans(const LLSD& blacklist);
 	void loadMessageBans(const LLSD& blacklist);
@@ -73,6 +74,7 @@ public:
 
 public:
 	LLSD mCapBans;
+	 S32 mMaxQueuedEvents;
 };
 
 std::string LLMessageConfigFile::filename()
@@ -112,6 +114,7 @@ void LLMessageConfigFile::loadFile()
         }
     }
 	loadServerDefaults(data);
+	loadMaxQueuedEvents(data);
 	loadMessages(data);
 	loadCapBans(data);
 	loadMessageBans(data);
@@ -122,6 +125,19 @@ void LLMessageConfigFile::loadServerDefaults(const LLSD& data)
 	mServerDefault = data["serverDefaults"][sServerName].asString();
 }
 
+const S32 DEFAULT_MAX_QUEUED_EVENTS = 100;
+void LLMessageConfigFile::loadMaxQueuedEvents(const LLSD& data)
+{
+	 if (data.has("maxQueuedEvents"))
+	 {
+		  mMaxQueuedEvents = data["maxQueuedEvents"].asInteger();
+	 }
+	 else
+	 {
+		  mMaxQueuedEvents = DEFAULT_MAX_QUEUED_EVENTS;
+	 }
+}
+
 void LLMessageConfigFile::loadMessages(const LLSD& data)
 {
 	mMessages = data["messages"];
@@ -191,10 +207,10 @@ void LLMessageConfig::useConfig(const LLSD& config)
 {
 	LLMessageConfigFile &the_file = LLMessageConfigFile::instance();
 	the_file.loadServerDefaults(config);
+	the_file.loadMaxQueuedEvents(config);
 	the_file.loadMessages(config);
 	the_file.loadCapBans(config);
 	the_file.loadMessageBans(config);
-
 }
 
 //static
@@ -212,6 +228,13 @@ LLMessageConfig::Flavor LLMessageConfig::getServerDefaultFlavor()
 	return NO_FLAVOR;
 }
 
+//static
+S32 LLMessageConfig::getMaxQueuedEvents()
+{
+	LLMessageConfigFile& file = LLMessageConfigFile::instance();
+	return file.mMaxQueuedEvents;
+}
+
 //static
 LLMessageConfig::Flavor LLMessageConfig::getMessageFlavor(const std::string& msg_name)
 {

indra/llmessage/llmessageconfig.h

@@ -48,6 +48,7 @@ public:
 	static void useConfig(const LLSD& config);
 
 	static Flavor getServerDefaultFlavor();
+	 static S32 getMaxQueuedEvents();
 
 	// For individual messages
 	static Flavor getMessageFlavor(const std::string& msg_name);

indra/test/llmessageconfig_tut.cpp

@@ -221,4 +221,21 @@ namespace tut
 					  LLMessageConfig::onlySendLatest("msg2"),
 					  false);
 	}
+
+	template<> template<>
+	void LLMessageConfigTestObject::test<9>()
+		 // tests that event queue max is reloaded
+	{
+		LLSD config;
+		config["maxQueuedEvents"] = 200;
+		LLMessageConfig::useConfig(config);
+		ensure_equals("Ensure setting maxQueuedEvents",
+					  LLMessageConfig::getMaxQueuedEvents(),
+					  200);
+
+		LLMessageConfig::useConfig(LLSD());
+		ensure_equals("Ensure default of event queue max 100",
+					  LLMessageConfig::getMaxQueuedEvents(),
+					  100);
+	}	 
 }