Kiu/xenadmin
1
0
Fork 0
mirror of https://github.com/xcp-ng/xenadmin.git synced 2025-01-20 15:29:26 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Export VM as XVA compressed with zstd

Browse Source 
JUST AS DEMO
uses experimental new xapi feature compressen=zstd
= serverside zstd compression (causes load on Hypervisor)
hardcoded for XVA Exports
This commit is contained in:
cocoon 2019-01-25 20:09:43 +01:00 committed by GitHub
parent 54ed885622
commit 3eb478bbac
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 11 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
XenModel/Actions/VM/ExportVmAction.cs
View File

@ -103,7 +103,7 @@ namespace XenAdmin.Actions
UriBuilder uriBuilder = new UriBuilder(this.Session.Url); UriBuilder uriBuilder = new UriBuilder(this.Session.Url);
uriBuilder.Path = "export"; uriBuilder.Path = "export";
uriBuilder.Query = string.Format("session_id={0}&uuid={1}&task_id={2}", uriBuilder.Query = string.Format("session_id={0}&uuid={1}&task_id={2}&use_compression=zstd",
Uri.EscapeDataString(this.Session.opaque_ref), Uri.EscapeDataString(this.Session.opaque_ref),
Uri.EscapeDataString(this.VM.uuid), Uri.EscapeDataString(this.VM.uuid),
Uri.EscapeDataString(this.RelatedTask.opaque_ref)); Uri.EscapeDataString(this.RelatedTask.opaque_ref));
@ -120,7 +120,7 @@ namespace XenAdmin.Actions
String tmpFile = _filename + ".tmp"; String tmpFile = _filename + ".tmp";
try try
{ {
HttpGet(tmpFile, uriBuilder.Uri); HttpGet(tmpFile, uriBuilder.Uri, true);
} }
catch (Exception e) catch (Exception e)
{ {
@ -248,13 +248,20 @@ namespace XenAdmin.Actions
private void HttpGet(string filename, Uri uri) private void HttpGet(string filename, Uri uri, bool useServerSideCompression = false)
{ {
using (FileStream fs = new FileStream(filename, FileMode.Create, FileAccess.Write)) using (FileStream fs = new FileStream(filename, FileMode.Create, FileAccess.Write))
{ {
using (Stream http = HTTPHelper.GET(uri, Connection, true, true)) using (Stream http = HTTPHelper.GET(uri, Connection, true, true))
{ {
new Export().verify(http, fs, (Export.cancellingCallback)delegate() { return Cancelling; }); if (useServerSideCompression)
{
http.CopyTo(fs);
}
else
{
new Export().verify(http, fs, (Export.cancellingCallback)delegate () { return Cancelling; });
}
} }
} }
} }