Avoid crashes on failed VM exports.
This commit is contained in:
parent
012e5c09ed
commit
a2adbb19bd
@ -658,7 +658,9 @@ exports.revert = revert
|
|||||||
|
|
||||||
#---------------------------------------------------------------------
|
#---------------------------------------------------------------------
|
||||||
|
|
||||||
handleExport = (req, res, {stream, response: upstream}) ->
|
handleExport = (req, res, { stream }) ->
|
||||||
|
upstream = stream.response
|
||||||
|
|
||||||
res.writeHead(
|
res.writeHead(
|
||||||
upstream.statusCode,
|
upstream.statusCode,
|
||||||
upstream.statusMessage ? '',
|
upstream.statusMessage ? '',
|
||||||
@ -675,10 +677,7 @@ export_ = $coroutine ({vm, compress, onlyMetadata}) ->
|
|||||||
})
|
})
|
||||||
|
|
||||||
return {
|
return {
|
||||||
$getFrom: yield @registerHttpRequest(handleExport, {
|
$getFrom: yield @registerHttpRequest(handleExport, { stream })
|
||||||
stream,
|
|
||||||
response: yield stream.response
|
|
||||||
})
|
|
||||||
}
|
}
|
||||||
|
|
||||||
export_.params = {
|
export_.params = {
|
||||||
|
@ -632,7 +632,8 @@ export default class Xapi extends XapiBase {
|
|||||||
use_compression: compress ? 'true' : 'false'
|
use_compression: compress ? 'true' : 'false'
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
stream.response = eventToPromise(stream, 'response')
|
|
||||||
|
stream.response = await eventToPromise(stream, 'response')
|
||||||
|
|
||||||
return stream
|
return stream
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user