diff options
author | Benoit Foucher <benoit@zeroc.com> | 2014-10-15 17:26:45 +0200 |
---|---|---|
committer | Benoit Foucher <benoit@zeroc.com> | 2014-10-15 17:26:45 +0200 |
commit | f94eb5f938d33dc2ce9b09b03b5dc6ccf7bd46c2 (patch) | |
tree | 6b12ef2c59421702743048393f4757c0d1e0c504 /js/src/Ice/RetryQueue.js | |
parent | ICE-5732 missing tracing in throughput demo (diff) | |
download | ice-f94eb5f938d33dc2ce9b09b03b5dc6ccf7bd46c2.tar.bz2 ice-f94eb5f938d33dc2ce9b09b03b5dc6ccf7bd46c2.tar.xz ice-f94eb5f938d33dc2ce9b09b03b5dc6ccf7bd46c2.zip |
Fixed ICE-5666: setting the invocation timeout to -2 provides the previous connection timeouts
Diffstat (limited to 'js/src/Ice/RetryQueue.js')
-rw-r--r-- | js/src/Ice/RetryQueue.js | 9 |
1 files changed, 2 insertions, 7 deletions
diff --git a/js/src/Ice/RetryQueue.js b/js/src/Ice/RetryQueue.js index 86148cd0757..e346a4e0efb 100644 --- a/js/src/Ice/RetryQueue.js +++ b/js/src/Ice/RetryQueue.js @@ -25,11 +25,11 @@ var RetryQueue = Class({ throw new Ice.CommunicatorDestroyedException(); } var task = new RetryTask(this, outAsync); + outAsync.__cancelable(task); // This will throw if the request is canceled task.token = this._instance.timer().schedule(function() { task.run(); }, interval); - outAsync.__cancelable(task); this._requests.push(task); }, destroy: function() @@ -90,12 +90,7 @@ var RetryTask = Class({ { if(this.queue.cancel(this)) { - // - // We just retry the outgoing async now rather than marking it - // as finished. The retry will check for the cancellation - // exception and terminate appropriately the request. - // - this.outAsync.__retry(); + this.outAsync.__completedEx(ex); } } }); |