From d57fa4375df3c0660f851cd9d7d76c17409c921d Mon Sep 17 00:00:00 2001 From: Julien Fontanet Date: Fri, 29 Mar 2019 15:27:37 +0100 Subject: [PATCH] chore(xen-api/signals): not disconnected when connecting --- packages/xen-api/src/index.js | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/packages/xen-api/src/index.js b/packages/xen-api/src/index.js index b82822e9e..54b87923c 100644 --- a/packages/xen-api/src/index.js +++ b/packages/xen-api/src/index.js @@ -234,6 +234,9 @@ export class Xapi extends EventEmitter { const auth = this._auth this._sessionId = CONNECTING + this._disconnected = new Promise(resolve => { + this._resolveDisconnected = resolve + }) try { const [methods, sessionId] = await Promise.all([ @@ -260,9 +263,6 @@ export class Xapi extends EventEmitter { this._pool = (await this.getAllRecords('pool'))[0] debug('%s: connected', this._humanId) - this._disconnected = new Promise(resolve => { - this._resolveDisconnected = resolve - }) this._resolveConnected() this._resolveConnected = undefined this.emit(CONNECTED) @@ -284,9 +284,6 @@ export class Xapi extends EventEmitter { this._connected = new Promise(resolve => { this._resolveConnected = resolve }) - - this._resolveDisconnected() - this._resolveDisconnected = undefined } else { assert(status === CONNECTING) } @@ -300,6 +297,8 @@ export class Xapi extends EventEmitter { debug('%s: disconnected', this._humanId) this.emit(DISCONNECTED) + this._resolveDisconnected() + this._resolveDisconnected = undefined } // ===========================================================================