diff options
Diffstat (limited to 'csharp/test/Ice/operations/BatchOneways.cs')
| -rw-r--r-- | csharp/test/Ice/operations/BatchOneways.cs | 42 |
1 files changed, 39 insertions, 3 deletions
diff --git a/csharp/test/Ice/operations/BatchOneways.cs b/csharp/test/Ice/operations/BatchOneways.cs index 26e5d3edab1..45dede6d54d 100644 --- a/csharp/test/Ice/operations/BatchOneways.cs +++ b/csharp/test/Ice/operations/BatchOneways.cs @@ -15,7 +15,7 @@ class BatchOneways { if(!b) { - throw new System.Exception(); + throw new Exception(); } } @@ -100,7 +100,7 @@ class BatchOneways batch1.ice_ping(); batch2.ice_ping(); batch1.ice_flushBatchRequests(); - batch1.ice_getConnection().close(false); + batch1.ice_getConnection().close(Ice.ConnectionClose.GracefullyWithWait); batch1.ice_ping(); batch2.ice_ping(); @@ -108,7 +108,7 @@ class BatchOneways batch2.ice_getConnection(); batch1.ice_ping(); - batch1.ice_getConnection().close(false); + batch1.ice_getConnection().close(Ice.ConnectionClose.GracefullyWithWait); batch1.ice_ping(); batch2.ice_ping(); } @@ -162,5 +162,41 @@ class BatchOneways ic.destroy(); } + + p.ice_ping(); + if(p.ice_getConnection() != null && + p.ice_getCommunicator().getProperties().getProperty("Ice.Override.Compress").Equals("")) + { + Ice.ObjectPrx prx = p.ice_getConnection().createProxy(p.ice_getIdentity()).ice_batchOneway(); + + Test.MyClassPrx batchC1 = Test.MyClassPrxHelper.uncheckedCast(prx.ice_compress(false)); + Test.MyClassPrx batchC2 = Test.MyClassPrxHelper.uncheckedCast(prx.ice_compress(true)); + Test.MyClassPrx batchC3 = Test.MyClassPrxHelper.uncheckedCast(prx.ice_identity(identity)); + + batchC1.opByteSOneway(bs1); + batchC1.opByteSOneway(bs1); + batchC1.opByteSOneway(bs1); + batchC1.ice_getConnection().flushBatchRequests(Ice.CompressBatch.Yes); + + batchC2.opByteSOneway(bs1); + batchC2.opByteSOneway(bs1); + batchC2.opByteSOneway(bs1); + batchC1.ice_getConnection().flushBatchRequests(Ice.CompressBatch.No); + + batchC1.opByteSOneway(bs1); + batchC1.opByteSOneway(bs1); + batchC1.opByteSOneway(bs1); + batchC1.ice_getConnection().flushBatchRequests(Ice.CompressBatch.BasedOnProxy); + + batchC1.opByteSOneway(bs1); + batchC2.opByteSOneway(bs1); + batchC1.opByteSOneway(bs1); + batchC1.ice_getConnection().flushBatchRequests(Ice.CompressBatch.BasedOnProxy); + + batchC1.opByteSOneway(bs1); + batchC3.opByteSOneway(bs1); + batchC1.opByteSOneway(bs1); + batchC1.ice_getConnection().flushBatchRequests(Ice.CompressBatch.BasedOnProxy); + } } } |