2 files changed, 201 insertions, 0 deletions

diff --git a/devel/ice/files/patch-cpp-test-Glacier2-override-Client.cpp b/devel/ice/files/patch-cpp-test-Glacier2-override-Client.cpp
new file mode 100644
index 000000000000..4a6ab66a0902
--- /dev/null
+++ b/devel/ice/files/patch-cpp-test-Glacier2-override-Client.cpp
@@ -0,0 +1,152 @@
+--- cpp/test/Glacier2/override/Client.cpp.orig	2015-08-02 15:07:07.945090996 +0200
++++ cpp/test/Glacier2/override/Client.cpp	2015-08-02 15:08:39.753584996 +0200
+@@ -102,59 +102,105 @@
+ 
+     {
+         cout << "testing server request override... " << flush;
++        cout << __LINE__ << endl;
+         Ice::Context ctx;
++        cout << __LINE__ << endl;
+         ctx["serverOvrd"] = "test";
++        cout << __LINE__ << endl;
+         for(int i = 0; i < 5; i++)
+         {
++        cout << __LINE__ << endl;
+             oneway->initiateCallback(onewayR, i, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallback(onewayR, i, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallback(onewayR, i, ctx);
++        cout << __LINE__ << endl;
+             IceUtil::ThreadControl::sleep(IceUtil::Time::milliSeconds(100));
++        cout << __LINE__ << endl;
+             test(callbackReceiverImpl->callbackOK(1, i) < 3);
++        cout << __LINE__ << endl;
+         }
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(twowayR, 0);
++        cout << __LINE__ << endl;
+         test(callbackReceiverImpl->callbackOK(1, 0) == 0);
++        cout << __LINE__ << endl;
+ 
+         int count = 0;
+         int nRetry = 0;
+         do
+         {
++        cout << __LINE__ << endl;
+             callbackReceiverImpl->hold();
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallbackWithPayload(onewayR, ctx);
++        cout << __LINE__ << endl;
+             oneway->initiateCallback(twowayR, 0);
++        cout << __LINE__ << endl;
+             IceUtil::ThreadControl::sleep(IceUtil::Time::milliSeconds(200 + nRetry * 200));
++        cout << __LINE__ << endl;
+             callbackReceiverImpl->activate();
++        cout << __LINE__ << endl;
+             test(callbackReceiverImpl->callbackOK(1, 0) == 0);
++        cout << __LINE__ << endl;
+             count = callbackReceiverImpl->callbackWithPayloadOK(0);
++        cout << __LINE__ << endl;
+             callbackReceiverImpl->callbackWithPayloadOK(count);
++        cout << __LINE__ << endl;
+         }
+         while(count == 10 && nRetry++ < 10);
++        cout << __LINE__ << endl;
+         test(count < 10);
++        cout << __LINE__ << endl;
+ 
+         oneway->initiateCallbackWithPayload(twowayR);
++        cout << __LINE__ << endl;
+         oneway->initiateCallbackWithPayload(twowayR);
++        cout << __LINE__ << endl;
+         callbackReceiverImpl->hold();
++        cout << __LINE__ << endl;
+         oneway->initiateCallbackWithPayload(twowayR);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallbackWithPayload(twowayR);
++        cout << __LINE__ << endl;
+         IceUtil::ThreadControl::sleep(IceUtil::Time::milliSeconds(1000));
++        cout << __LINE__ << endl;
+         callbackReceiverImpl->activate();
++        cout << __LINE__ << endl;
+         test(callbackReceiverImpl->callbackWithPayloadOK(4) == 0);
++        cout << __LINE__ << endl;
+         
+         int remainingCallbacks = callbackReceiverImpl->callbackOK(1, 0);
++        cout << __LINE__ << endl;
+         //
+         // Occasionally, Glacier2 flushes in the middle of our 5
+         // callbacks, so we get more than 1 callback
+@@ -164,26 +210,43 @@
+         // time to receive this (these) extra callback(s).
+         //
+         test(remainingCallbacks <= 4);
++        cout << __LINE__ << endl;
+         if(remainingCallbacks > 0)
+         {
++        cout << __LINE__ << endl;
+             test(callbackReceiverImpl->callbackOK(remainingCallbacks, 0) == 0);
+         }
++        cout << __LINE__ << endl;
+         
+         ctx["_fwd"] = "O";
++        cout << __LINE__ << endl;
+ 
+         oneway->initiateCallbackWithPayload(twowayR);
++        cout << __LINE__ << endl;
+         callbackReceiverImpl->hold();
++        cout << __LINE__ << endl;
+         oneway->initiateCallbackWithPayload(twowayR);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallback(onewayR, 0, ctx);
++        cout << __LINE__ << endl;
+         oneway->initiateCallbackWithPayload(twowayR);
++        cout << __LINE__ << endl;
+         IceUtil::ThreadControl::sleep(IceUtil::Time::milliSeconds(200));
++        cout << __LINE__ << endl;
+         callbackReceiverImpl->activate();
++        cout << __LINE__ << endl;
+         test(callbackReceiverImpl->callbackWithPayloadOK(3) == 0);
++        cout << __LINE__ << endl;
+         test(callbackReceiverImpl->callbackOK(1, 0) == 0);
++        cout << __LINE__ << endl;
+ 
+         cout << "ok" << endl;
+     }
diff --git a/devel/ice/files/patch-cpp-test-Ice-hold-AllTests.cpp b/devel/ice/files/patch-cpp-test-Ice-hold-AllTests.cpp
new file mode 100644
index 000000000000..7dd89df78710
--- /dev/null
+++ b/devel/ice/files/patch-cpp-test-Ice-hold-AllTests.cpp
@@ -0,0 +1,49 @@
+--- cpp/test/Ice/hold/AllTests.cpp.orig	2015-06-23 17:30:20.000000000 +0200
++++ cpp/test/Ice/hold/AllTests.cpp	2015-08-02 15:05:08.363617996 +0200
+@@ -152,31 +152,46 @@
+         ConditionPtr cond = new Condition(true);
+         int value = 0;
+         Ice::AsyncResultPtr result;
++        cout << __LINE__ << endl;
+         while(value < 3000 && cond->value())
+         {
++            if (!value)
++                cout << __LINE__ << endl;
+             result = holdSerialized->begin_set(value + 1,
+                                                IceUtilInternal::random(1),
+                                                newCallback_Hold_set(new SetCB(cond, value), 
+                                                                     &SetCB::response, 
+                                                                     &SetCB::exception));
++            if (!value)
++                cout << __LINE__ << endl;
+             ++value;
+             if(value % 100 == 0)
+             {
++                cout << __LINE__ << endl;
+                 result->waitForSent();
+             }
+         }
++        cout << __LINE__ << endl;
+         result->waitForCompleted();
++        cout << __LINE__ << endl;
+         test(cond->value());
++        cout << __LINE__ << endl;
+ 
+         for(int i = 0; i < 10000; ++i)
+         {
++            if (value == 3000)
++                cout << __LINE__ << endl;
+             holdSerialized->ice_oneway()->setOneway(value + 1, value);
++            if (value == 3000)
++                cout << __LINE__ << endl;
+             ++value;
+             if((i % 100) == 0)
+             {
++                cout << __LINE__ << endl;
+                 holdSerialized->ice_oneway()->putOnHold(1);
+             }
+         }
++        cout << __LINE__ << endl;
+     }
+     cout << "ok" << endl;
+