NuKVM/xen-orchestra
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Limit tries in case of transport errors (ugly).

Browse Source
This commit is contained in:
Julien Fontanet 2015-04-14 17:57:31 +02:00
parent 4a0a09ba3e
commit 36c1e2cc73
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
packages/xen-api/src/index.js
View File

@ -100,6 +100,8 @@ notConnectedPromise.catch(noop)
// ===================================================================
const MAX_TRIES = 5
export class Xapi extends EventEmitter {
constructor (opts) {
super()
@ -108,6 +110,7 @@ export class Xapi extends EventEmitter {
this._auth = opts.auth
this._sessionId = notConnectedPromise
this._tries = 0
this._init()
@ -261,6 +264,10 @@ export class Xapi extends EventEmitter {
.catch(isNetworkError, isXapiNetworkError, () => {
debug('%s: a network error happened', this._humanId)
if (++this._tries > MAX_TRIES) {
throw new Error('will not try anymore')
}
// TODO: ability to cancel the connection
// TODO: ability to force immediate reconnection
// TODO: implement back-off
@ -268,7 +275,9 @@ export class Xapi extends EventEmitter {
return Bluebird.delay(5e3).then(() => {
// TODO: handling not responding host.
return this._transportCall(method, args)
return this._transportCall(method, args).then(() => {
this._tries = 0
})
})
})
.cancellable()