diff options
author | Mark Spruiell <mes@zeroc.com> | 2003-05-05 16:08:01 +0000 |
---|---|---|
committer | Mark Spruiell <mes@zeroc.com> | 2003-05-05 16:08:01 +0000 |
commit | c1f3783f2ce63cf62fee134fbba772cca332d954 (patch) | |
tree | b9cc7b1a3efbb1edd8328c6c7000d407c12d0da8 /java/src/Ice/ObjectPrxHelper.java | |
parent | merge with e3_2003 (diff) | |
download | ice-c1f3783f2ce63cf62fee134fbba772cca332d954.tar.bz2 ice-c1f3783f2ce63cf62fee134fbba772cca332d954.tar.xz ice-c1f3783f2ce63cf62fee134fbba772cca332d954.zip |
merge with e3_2003
Diffstat (limited to 'java/src/Ice/ObjectPrxHelper.java')
-rw-r--r-- | java/src/Ice/ObjectPrxHelper.java | 20 |
1 files changed, 18 insertions, 2 deletions
diff --git a/java/src/Ice/ObjectPrxHelper.java b/java/src/Ice/ObjectPrxHelper.java index 63d3330e1fd..a8fd21d33fa 100644 --- a/java/src/Ice/ObjectPrxHelper.java +++ b/java/src/Ice/ObjectPrxHelper.java @@ -509,8 +509,24 @@ public class ObjectPrxHelper implements ObjectPrx public final void ice_flush() { - _ObjectDel __del = __getDelegate(); - __del.ice_flush(); + // + // Retry is necessary for ice_flush in case the current connection + // is closed. If that's the case we need to get a new connection. + // + int __cnt = 0; + while(true) + { + try + { + _ObjectDel __del = __getDelegate(); + __del.ice_flush(); + return; + } + catch(LocalException __ex) + { + __cnt = __handleException(__ex, __cnt); + } + } } public final boolean |