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

Fix events watching XenServer < 6.0.

Browse Source
This commit is contained in:
Julien Fontanet 2015-10-23 16:53:42 +02:00
parent fcbc476462
commit 277669a13c
1 changed files with 14 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -575,19 +575,26 @@ export class Xapi extends EventEmitter {
return Promise.all(map( return Promise.all(map(
getAllRecordsMethods, getAllRecordsMethods,
method => this._sessionCall(method, []).then(objects => { method => this._sessionCall(method, []).then(
const type = method.slice(0, method.indexOf('.')).toLowerCase() objects => {
forEach(objects, (object, ref) => { const type = method.slice(0, method.indexOf('.')).toLowerCase()
this._addObject(type, ref, object) forEach(objects, (object, ref) => {
}) this._addObject(type, ref, object)
}) })
},
error => {
if (error.code !== 'MESSAGE_REMOVED') {
throw error
}
}
)
)) ))
}) })
} }
const watchEvents = (() => { const watchEvents = (() => {
const loop = ((onSuccess, onFailure) => { const loop = ((onSuccess, onFailure) => {
return this._sessionCall('event.next', []).then(onSuccess, onFailure) return () => this._sessionCall('event.next', []).then(onSuccess, onFailure)
})( })(
events => { events => {
this._processEvents(events) this._processEvents(events)