Fixed ICE-7406 - IceStorm/stress test hang on W2008R2, fixes to allow building Ice from directory with spaces

2 files changed, 16 insertions, 9 deletions

diff --git a/cpp/test/IceStorm/stress/Publisher.cpp b/cpp/test/IceStorm/stress/Publisher.cpp
index b83347b2658..6b9c7801f68 100644
--- a/cpp/test/IceStorm/stress/Publisher.cpp
+++ b/cpp/test/IceStorm/stress/Publisher.cpp
@@ -23,6 +23,7 @@ run(int argc, char* argv[], const CommunicatorPtr& communicator)
     IceUtilInternal::Options opts;
     opts.addOpt("", "events", IceUtilInternal::Options::NeedArg);
     opts.addOpt("", "oneway");
+    opts.addOpt("", "maxQueueTest");
 
     try
     {
@@ -47,6 +48,7 @@ run(int argc, char* argv[], const CommunicatorPtr& communicator)
     }
 
     bool oneway = opts.isSet("oneway");
+    bool maxQueueTest = opts.isSet("maxQueueTest");
 
     PropertiesPtr properties = communicator->getProperties();
     const char* managerProxyProperty = "IceStormAdmin.TopicManager.Default";
@@ -74,7 +76,7 @@ run(int argc, char* argv[], const CommunicatorPtr& communicator)
     {
         cerr << argv[0] << ": NoSuchTopic: " << e.name << endl;
         return EXIT_FAILURE;
-        
+
     }
 
     EventPrx twowayProxy = EventPrx::uncheckedCast(topic->getPublisher()->ice_twoway());
@@ -90,6 +92,11 @@ run(int argc, char* argv[], const CommunicatorPtr& communicator)
 
     for(int i = 0; i < events; ++i)
     {
+        if(maxQueueTest && i == 10)
+        {
+            // Sleep one seconds to give some time to IceStorm to connect to the subscriber
+            IceUtil::ThreadControl::sleep(IceUtil::Time::seconds(1));
+        }
         proxy->pub(i);
     }
 
diff --git a/cpp/test/IceStorm/stress/run.py b/cpp/test/IceStorm/stress/run.py
index 805c8283a31..ed8eb9b2d48 100755
--- a/cpp/test/IceStorm/stress/run.py
+++ b/cpp/test/IceStorm/stress/run.py
@@ -177,21 +177,21 @@ def runtest(type):
 
     sys.stdout.write("Sending 5000 ordered events with max queue size drop events... ")
     sys.stdout.flush()
-    server1.start(echo=False,
-                  additionalOptions = ' --IceStorm.Send.QueueSizeMax=4000 --IceStorm.Send.QueueSizeMaxPolicy=DropEvents')
+    opts = " --IceStorm.Send.QueueSizeMax=2000 --IceStorm.Send.QueueSizeMaxPolicy=DropEvents"
+    server1.start(echo=False, additionalOptions = opts)
     doTest(server1,
-           '--events 5000 --qos "reliability,ordered" --maxQueueDropEvents=4000 ' + server1.reference(),
-           '--events 5000')
+           '--events 5000 --qos "reliability,ordered" --maxQueueDropEvents=2000 ' + server1.reference(),
+           '--events 5000 --maxQueueTest')
     server1.stop()
     print("ok")
 
     sys.stdout.write("Sending 5000 ordered events with max queue size remove subscriber... ")
     sys.stdout.flush()
-    server1.start(echo=False,
-                  additionalOptions = ' --IceStorm.Send.QueueSizeMax=4000 --IceStorm.Send.QueueSizeMaxPolicy=RemoveSubscriber')
+    opts = " --IceStorm.Send.QueueSizeMax=2000 --IceStorm.Send.QueueSizeMaxPolicy=RemoveSubscriber"
+    server1.start(echo=False, additionalOptions = opts)
     doTest(server1,
-           '--events 5000 --qos "reliability,ordered" --maxQueueRemoveSub=4000 ' + server1.reference(),
-           '--events 5000')
+           '--events 5000 --qos "reliability,ordered" --maxQueueRemoveSub=2000 ' + server1.reference(),
+           '--events 5000 --maxQueueTest')
     server1.stop()
     print("ok")