summaryrefslogtreecommitdiff
path: root/js/src/Ice/RetryQueue.js
diff options
context:
space:
mode:
authorBenoit Foucher <benoit@zeroc.com>2014-10-15 17:26:45 +0200
committerBenoit Foucher <benoit@zeroc.com>2014-10-15 17:26:45 +0200
commitf94eb5f938d33dc2ce9b09b03b5dc6ccf7bd46c2 (patch)
tree6b12ef2c59421702743048393f4757c0d1e0c504 /js/src/Ice/RetryQueue.js
parentICE-5732 missing tracing in throughput demo (diff)
downloadice-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.js9
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);
}
}
});