From 02e0818aef1b95bd7278859267f4cd9f04ee2656 Mon Sep 17 00:00:00 2001
From: Yuriy Taraday <yorik.sar@gmail.com>
Date: Mon, 26 Feb 2018 00:56:27 +0400
Subject: [PATCH] Add streams to proc arguments, use requestStream

This makes functions look just like in actual libvirt API, except
virStreamPtr is replaced with io.Reader for outgoing streams and
io.Writer for incoming streams.
---
 internal/lvgen/procedures.tmpl |  16 +-
 libvirt.gen.go                 | 795 +++++++++++++++++----------------
 2 files changed, 411 insertions(+), 400 deletions(-)

diff --git a/internal/lvgen/procedures.tmpl b/internal/lvgen/procedures.tmpl
index 4763c86..372b0b1 100644
--- a/internal/lvgen/procedures.tmpl
+++ b/internal/lvgen/procedures.tmpl
@@ -23,6 +23,7 @@ package libvirt
 import (
 	"bytes"
 	"fmt"
+	"io"
 
 	"github.com/davecgh/go-xdr/xdr2"
 	"github.com/digitalocean/go-libvirt/internal/constants"
@@ -126,9 +127,15 @@ func decodeTypedParams(dec *xdr.Decoder) ([]TypedParam, error) {
 	return params, nil
 }
 
-{{range .Procs}}
+{{range $proc := .Procs}}
 // {{.Name}} is the go wrapper for {{.LVName}}.
-func (l *Libvirt) {{.Name}}({{range $ix, $arg := .Args}}{{if $ix}}, {{end}}{{.Name}} {{.Type}}{{end}}) ({{range .Ret}}r{{.Name}} {{.Type}}, {{end}}err error) {
+func (l *Libvirt) {{.Name}}(
+  {{- range $ix, $arg := .Args}}
+    {{- if (eq $ix $proc.WriteStreamIdx)}}{{if $ix}}, {{end}}outStream io.Reader{{end}}
+    {{- if (eq $ix $proc.ReadStreamIdx)}}{{if $ix}}, {{end}}inStream io.Writer{{end}}
+    {{- if $ix}}, {{end}}{{.Name}} {{.Type}}
+  {{- end -}}
+) ({{range .Ret}}r{{.Name}} {{.Type}}, {{end}}err error) {
 	var buf []byte
 {{if .ArgsStruct}}
 	args := {{.ArgsStruct}} {
@@ -141,7 +148,10 @@ func (l *Libvirt) {{.Name}}({{range $ix, $arg := .Args}}{{if $ix}}, {{end}}{{.Na
 	}
 {{end}}
 {{if .RetStruct}}	var r response{{end}}
-	{{if .RetStruct}}r{{else}}_{{end}}, err = l.request({{.Num}}, constants.Program, buf)
+	{{if .RetStruct}}r{{else}}_{{end}}, err = l.requestStream({{.Num}}, constants.Program, buf,
+    {{- if (ne .WriteStreamIdx -1)}} outStream,{{else}} nil,{{end}}
+    {{- if (ne .ReadStreamIdx -1)}} inStream{{else}} nil{{end -}}
+    )
 	if err != nil {
 		return
 	}
diff --git a/libvirt.gen.go b/libvirt.gen.go
index 698318e..5a29655 100644
--- a/libvirt.gen.go
+++ b/libvirt.gen.go
@@ -23,6 +23,7 @@ package libvirt
 import (
 	"bytes"
 	"fmt"
+	"io"
 
 	"github.com/davecgh/go-xdr/xdr2"
 	"github.com/digitalocean/go-libvirt/internal/constants"
@@ -3952,7 +3953,7 @@ func (l *Libvirt) ConnectOpen(Name OptString, Flags ConnectFlags) (err error) {
 	}
 
 
-	_, err = l.request(1, constants.Program, buf)
+	_, err = l.requestStream(1, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -3965,7 +3966,7 @@ func (l *Libvirt) ConnectClose() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(2, constants.Program, buf)
+	_, err = l.requestStream(2, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -3978,7 +3979,7 @@ func (l *Libvirt) ConnectGetType() (rType string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(3, constants.Program, buf)
+	r, err = l.requestStream(3, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4000,7 +4001,7 @@ func (l *Libvirt) ConnectGetVersion() (rHvVer uint64, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(4, constants.Program, buf)
+	r, err = l.requestStream(4, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4031,7 +4032,7 @@ func (l *Libvirt) ConnectGetMaxVcpus(Type OptString) (rMaxVcpus int32, err error
 	}
 
 	var r response
-	r, err = l.request(5, constants.Program, buf)
+	r, err = l.requestStream(5, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4053,7 +4054,7 @@ func (l *Libvirt) NodeGetInfo() (rModel [32]int8, rMemory uint64, rCpus int32, r
 	var buf []byte
 
 	var r response
-	r, err = l.request(6, constants.Program, buf)
+	r, err = l.requestStream(6, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4110,7 +4111,7 @@ func (l *Libvirt) ConnectGetCapabilities() (rCapabilities string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(7, constants.Program, buf)
+	r, err = l.requestStream(7, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4142,7 +4143,7 @@ func (l *Libvirt) DomainAttachDevice(Dom Domain, XML string) (err error) {
 	}
 
 
-	_, err = l.request(8, constants.Program, buf)
+	_, err = l.requestStream(8, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4164,7 +4165,7 @@ func (l *Libvirt) DomainCreate(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(9, constants.Program, buf)
+	_, err = l.requestStream(9, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4187,7 +4188,7 @@ func (l *Libvirt) DomainCreateXML(XMLDesc string, Flags DomainCreateFlags) (rDom
 	}
 
 	var r response
-	r, err = l.request(10, constants.Program, buf)
+	r, err = l.requestStream(10, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4218,7 +4219,7 @@ func (l *Libvirt) DomainDefineXML(XML string) (rDom Domain, err error) {
 	}
 
 	var r response
-	r, err = l.request(11, constants.Program, buf)
+	r, err = l.requestStream(11, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4249,7 +4250,7 @@ func (l *Libvirt) DomainDestroy(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(12, constants.Program, buf)
+	_, err = l.requestStream(12, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4272,7 +4273,7 @@ func (l *Libvirt) DomainDetachDevice(Dom Domain, XML string) (err error) {
 	}
 
 
-	_, err = l.request(13, constants.Program, buf)
+	_, err = l.requestStream(13, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4295,7 +4296,7 @@ func (l *Libvirt) DomainGetXMLDesc(Dom Domain, Flags DomainXMLFlags) (rXML strin
 	}
 
 	var r response
-	r, err = l.request(14, constants.Program, buf)
+	r, err = l.requestStream(14, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4326,7 +4327,7 @@ func (l *Libvirt) DomainGetAutostart(Dom Domain) (rAutostart int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(15, constants.Program, buf)
+	r, err = l.requestStream(15, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4357,7 +4358,7 @@ func (l *Libvirt) DomainGetInfo(Dom Domain) (rState uint8, rMaxMem uint64, rMemo
 	}
 
 	var r response
-	r, err = l.request(16, constants.Program, buf)
+	r, err = l.requestStream(16, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4408,7 +4409,7 @@ func (l *Libvirt) DomainGetMaxMemory(Dom Domain) (rMemory uint64, err error) {
 	}
 
 	var r response
-	r, err = l.request(17, constants.Program, buf)
+	r, err = l.requestStream(17, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4439,7 +4440,7 @@ func (l *Libvirt) DomainGetMaxVcpus(Dom Domain) (rNum int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(18, constants.Program, buf)
+	r, err = l.requestStream(18, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4470,7 +4471,7 @@ func (l *Libvirt) DomainGetOsType(Dom Domain) (rType string, err error) {
 	}
 
 	var r response
-	r, err = l.request(19, constants.Program, buf)
+	r, err = l.requestStream(19, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4503,7 +4504,7 @@ func (l *Libvirt) DomainGetVcpus(Dom Domain, Maxinfo int32, Maplen int32) (rInfo
 	}
 
 	var r response
-	r, err = l.request(20, constants.Program, buf)
+	r, err = l.requestStream(20, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4539,7 +4540,7 @@ func (l *Libvirt) ConnectListDefinedDomains(Maxnames int32) (rNames []string, er
 	}
 
 	var r response
-	r, err = l.request(21, constants.Program, buf)
+	r, err = l.requestStream(21, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4570,7 +4571,7 @@ func (l *Libvirt) DomainLookupByID(ID int32) (rDom Domain, err error) {
 	}
 
 	var r response
-	r, err = l.request(22, constants.Program, buf)
+	r, err = l.requestStream(22, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4601,7 +4602,7 @@ func (l *Libvirt) DomainLookupByName(Name string) (rDom Domain, err error) {
 	}
 
 	var r response
-	r, err = l.request(23, constants.Program, buf)
+	r, err = l.requestStream(23, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4632,7 +4633,7 @@ func (l *Libvirt) DomainLookupByUUID(UUID UUID) (rDom Domain, err error) {
 	}
 
 	var r response
-	r, err = l.request(24, constants.Program, buf)
+	r, err = l.requestStream(24, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4654,7 +4655,7 @@ func (l *Libvirt) ConnectNumOfDefinedDomains() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(25, constants.Program, buf)
+	r, err = l.requestStream(25, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4687,7 +4688,7 @@ func (l *Libvirt) DomainPinVcpu(Dom Domain, Vcpu uint32, Cpumap []byte) (err err
 	}
 
 
-	_, err = l.request(26, constants.Program, buf)
+	_, err = l.requestStream(26, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4710,7 +4711,7 @@ func (l *Libvirt) DomainReboot(Dom Domain, Flags DomainRebootFlagValues) (err er
 	}
 
 
-	_, err = l.request(27, constants.Program, buf)
+	_, err = l.requestStream(27, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4732,7 +4733,7 @@ func (l *Libvirt) DomainResume(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(28, constants.Program, buf)
+	_, err = l.requestStream(28, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4755,7 +4756,7 @@ func (l *Libvirt) DomainSetAutostart(Dom Domain, Autostart int32) (err error) {
 	}
 
 
-	_, err = l.request(29, constants.Program, buf)
+	_, err = l.requestStream(29, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4778,7 +4779,7 @@ func (l *Libvirt) DomainSetMaxMemory(Dom Domain, Memory uint64) (err error) {
 	}
 
 
-	_, err = l.request(30, constants.Program, buf)
+	_, err = l.requestStream(30, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4801,7 +4802,7 @@ func (l *Libvirt) DomainSetMemory(Dom Domain, Memory uint64) (err error) {
 	}
 
 
-	_, err = l.request(31, constants.Program, buf)
+	_, err = l.requestStream(31, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4824,7 +4825,7 @@ func (l *Libvirt) DomainSetVcpus(Dom Domain, Nvcpus uint32) (err error) {
 	}
 
 
-	_, err = l.request(32, constants.Program, buf)
+	_, err = l.requestStream(32, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4846,7 +4847,7 @@ func (l *Libvirt) DomainShutdown(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(33, constants.Program, buf)
+	_, err = l.requestStream(33, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4868,7 +4869,7 @@ func (l *Libvirt) DomainSuspend(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(34, constants.Program, buf)
+	_, err = l.requestStream(34, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4890,7 +4891,7 @@ func (l *Libvirt) DomainUndefine(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(35, constants.Program, buf)
+	_, err = l.requestStream(35, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4912,7 +4913,7 @@ func (l *Libvirt) ConnectListDefinedNetworks(Maxnames int32) (rNames []string, e
 	}
 
 	var r response
-	r, err = l.request(36, constants.Program, buf)
+	r, err = l.requestStream(36, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4943,7 +4944,7 @@ func (l *Libvirt) ConnectListDomains(Maxids int32) (rIds []int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(37, constants.Program, buf)
+	r, err = l.requestStream(37, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -4974,7 +4975,7 @@ func (l *Libvirt) ConnectListNetworks(Maxnames int32) (rNames []string, err erro
 	}
 
 	var r response
-	r, err = l.request(38, constants.Program, buf)
+	r, err = l.requestStream(38, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5005,7 +5006,7 @@ func (l *Libvirt) NetworkCreate(Net Network) (err error) {
 	}
 
 
-	_, err = l.request(39, constants.Program, buf)
+	_, err = l.requestStream(39, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5027,7 +5028,7 @@ func (l *Libvirt) NetworkCreateXML(XML string) (rNet Network, err error) {
 	}
 
 	var r response
-	r, err = l.request(40, constants.Program, buf)
+	r, err = l.requestStream(40, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5058,7 +5059,7 @@ func (l *Libvirt) NetworkDefineXML(XML string) (rNet Network, err error) {
 	}
 
 	var r response
-	r, err = l.request(41, constants.Program, buf)
+	r, err = l.requestStream(41, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5089,7 +5090,7 @@ func (l *Libvirt) NetworkDestroy(Net Network) (err error) {
 	}
 
 
-	_, err = l.request(42, constants.Program, buf)
+	_, err = l.requestStream(42, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5112,7 +5113,7 @@ func (l *Libvirt) NetworkGetXMLDesc(Net Network, Flags uint32) (rXML string, err
 	}
 
 	var r response
-	r, err = l.request(43, constants.Program, buf)
+	r, err = l.requestStream(43, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5143,7 +5144,7 @@ func (l *Libvirt) NetworkGetAutostart(Net Network) (rAutostart int32, err error)
 	}
 
 	var r response
-	r, err = l.request(44, constants.Program, buf)
+	r, err = l.requestStream(44, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5174,7 +5175,7 @@ func (l *Libvirt) NetworkGetBridgeName(Net Network) (rName string, err error) {
 	}
 
 	var r response
-	r, err = l.request(45, constants.Program, buf)
+	r, err = l.requestStream(45, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5205,7 +5206,7 @@ func (l *Libvirt) NetworkLookupByName(Name string) (rNet Network, err error) {
 	}
 
 	var r response
-	r, err = l.request(46, constants.Program, buf)
+	r, err = l.requestStream(46, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5236,7 +5237,7 @@ func (l *Libvirt) NetworkLookupByUUID(UUID UUID) (rNet Network, err error) {
 	}
 
 	var r response
-	r, err = l.request(47, constants.Program, buf)
+	r, err = l.requestStream(47, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5268,7 +5269,7 @@ func (l *Libvirt) NetworkSetAutostart(Net Network, Autostart int32) (err error)
 	}
 
 
-	_, err = l.request(48, constants.Program, buf)
+	_, err = l.requestStream(48, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5290,7 +5291,7 @@ func (l *Libvirt) NetworkUndefine(Net Network) (err error) {
 	}
 
 
-	_, err = l.request(49, constants.Program, buf)
+	_, err = l.requestStream(49, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5303,7 +5304,7 @@ func (l *Libvirt) ConnectNumOfDefinedNetworks() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(50, constants.Program, buf)
+	r, err = l.requestStream(50, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5325,7 +5326,7 @@ func (l *Libvirt) ConnectNumOfDomains() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(51, constants.Program, buf)
+	r, err = l.requestStream(51, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5347,7 +5348,7 @@ func (l *Libvirt) ConnectNumOfNetworks() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(52, constants.Program, buf)
+	r, err = l.requestStream(52, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5380,7 +5381,7 @@ func (l *Libvirt) DomainCoreDump(Dom Domain, To string, Flags DomainCoreDumpFlag
 	}
 
 
-	_, err = l.request(53, constants.Program, buf)
+	_, err = l.requestStream(53, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5402,7 +5403,7 @@ func (l *Libvirt) DomainRestore(From string) (err error) {
 	}
 
 
-	_, err = l.request(54, constants.Program, buf)
+	_, err = l.requestStream(54, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5425,7 +5426,7 @@ func (l *Libvirt) DomainSave(Dom Domain, To string) (err error) {
 	}
 
 
-	_, err = l.request(55, constants.Program, buf)
+	_, err = l.requestStream(55, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5447,7 +5448,7 @@ func (l *Libvirt) DomainGetSchedulerType(Dom Domain) (rType string, rNparams int
 	}
 
 	var r response
-	r, err = l.request(56, constants.Program, buf)
+	r, err = l.requestStream(56, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5484,7 +5485,7 @@ func (l *Libvirt) DomainGetSchedulerParameters(Dom Domain, Nparams int32) (rPara
 	}
 
 	var r response
-	r, err = l.request(57, constants.Program, buf)
+	r, err = l.requestStream(57, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5517,7 +5518,7 @@ func (l *Libvirt) DomainSetSchedulerParameters(Dom Domain, Params []TypedParam)
 	}
 
 
-	_, err = l.request(58, constants.Program, buf)
+	_, err = l.requestStream(58, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5530,7 +5531,7 @@ func (l *Libvirt) ConnectGetHostname() (rHostname string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(59, constants.Program, buf)
+	r, err = l.requestStream(59, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5561,7 +5562,7 @@ func (l *Libvirt) ConnectSupportsFeature(Feature int32) (rSupported int32, err e
 	}
 
 	var r response
-	r, err = l.request(60, constants.Program, buf)
+	r, err = l.requestStream(60, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5595,7 +5596,7 @@ func (l *Libvirt) DomainMigratePrepare(UriIn OptString, Flags uint64, Dname OptS
 	}
 
 	var r response
-	r, err = l.request(61, constants.Program, buf)
+	r, err = l.requestStream(61, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5636,7 +5637,7 @@ func (l *Libvirt) DomainMigratePerform(Dom Domain, Cookie []byte, Uri string, Fl
 	}
 
 
-	_, err = l.request(62, constants.Program, buf)
+	_, err = l.requestStream(62, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5661,7 +5662,7 @@ func (l *Libvirt) DomainMigrateFinish(Dname string, Cookie []byte, Uri string, F
 	}
 
 	var r response
-	r, err = l.request(63, constants.Program, buf)
+	r, err = l.requestStream(63, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5693,7 +5694,7 @@ func (l *Libvirt) DomainBlockStats(Dom Domain, Path string) (rRdReq int64, rRdBy
 	}
 
 	var r response
-	r, err = l.request(64, constants.Program, buf)
+	r, err = l.requestStream(64, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5745,7 +5746,7 @@ func (l *Libvirt) DomainInterfaceStats(Dom Domain, Device string) (rRxBytes int6
 	}
 
 	var r response
-	r, err = l.request(65, constants.Program, buf)
+	r, err = l.requestStream(65, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5802,7 +5803,7 @@ func (l *Libvirt) AuthList() (rTypes []AuthType, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(66, constants.Program, buf)
+	r, err = l.requestStream(66, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5824,7 +5825,7 @@ func (l *Libvirt) AuthSaslInit() (rMechlist string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(67, constants.Program, buf)
+	r, err = l.requestStream(67, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5857,7 +5858,7 @@ func (l *Libvirt) AuthSaslStart(Mech string, Nil int32, Data []int8) (rComplete
 	}
 
 	var r response
-	r, err = l.request(68, constants.Program, buf)
+	r, err = l.requestStream(68, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5899,7 +5900,7 @@ func (l *Libvirt) AuthSaslStep(Nil int32, Data []int8) (rComplete int32, rNil in
 	}
 
 	var r response
-	r, err = l.request(69, constants.Program, buf)
+	r, err = l.requestStream(69, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5931,7 +5932,7 @@ func (l *Libvirt) AuthPolkit() (rComplete int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(70, constants.Program, buf)
+	r, err = l.requestStream(70, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5953,7 +5954,7 @@ func (l *Libvirt) ConnectNumOfStoragePools() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(71, constants.Program, buf)
+	r, err = l.requestStream(71, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -5984,7 +5985,7 @@ func (l *Libvirt) ConnectListStoragePools(Maxnames int32) (rNames []string, err
 	}
 
 	var r response
-	r, err = l.request(72, constants.Program, buf)
+	r, err = l.requestStream(72, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6006,7 +6007,7 @@ func (l *Libvirt) ConnectNumOfDefinedStoragePools() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(73, constants.Program, buf)
+	r, err = l.requestStream(73, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6037,7 +6038,7 @@ func (l *Libvirt) ConnectListDefinedStoragePools(Maxnames int32) (rNames []strin
 	}
 
 	var r response
-	r, err = l.request(74, constants.Program, buf)
+	r, err = l.requestStream(74, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6070,7 +6071,7 @@ func (l *Libvirt) ConnectFindStoragePoolSources(Type string, SrcSpec OptString,
 	}
 
 	var r response
-	r, err = l.request(75, constants.Program, buf)
+	r, err = l.requestStream(75, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6102,7 +6103,7 @@ func (l *Libvirt) StoragePoolCreateXML(XML string, Flags StoragePoolCreateFlags)
 	}
 
 	var r response
-	r, err = l.request(76, constants.Program, buf)
+	r, err = l.requestStream(76, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6134,7 +6135,7 @@ func (l *Libvirt) StoragePoolDefineXML(XML string, Flags uint32) (rPool StorageP
 	}
 
 	var r response
-	r, err = l.request(77, constants.Program, buf)
+	r, err = l.requestStream(77, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6166,7 +6167,7 @@ func (l *Libvirt) StoragePoolCreate(Pool StoragePool, Flags StoragePoolCreateFla
 	}
 
 
-	_, err = l.request(78, constants.Program, buf)
+	_, err = l.requestStream(78, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6189,7 +6190,7 @@ func (l *Libvirt) StoragePoolBuild(Pool StoragePool, Flags StoragePoolBuildFlags
 	}
 
 
-	_, err = l.request(79, constants.Program, buf)
+	_, err = l.requestStream(79, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6211,7 +6212,7 @@ func (l *Libvirt) StoragePoolDestroy(Pool StoragePool) (err error) {
 	}
 
 
-	_, err = l.request(80, constants.Program, buf)
+	_, err = l.requestStream(80, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6234,7 +6235,7 @@ func (l *Libvirt) StoragePoolDelete(Pool StoragePool, Flags StoragePoolDeleteFla
 	}
 
 
-	_, err = l.request(81, constants.Program, buf)
+	_, err = l.requestStream(81, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6256,7 +6257,7 @@ func (l *Libvirt) StoragePoolUndefine(Pool StoragePool) (err error) {
 	}
 
 
-	_, err = l.request(82, constants.Program, buf)
+	_, err = l.requestStream(82, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6279,7 +6280,7 @@ func (l *Libvirt) StoragePoolRefresh(Pool StoragePool, Flags uint32) (err error)
 	}
 
 
-	_, err = l.request(83, constants.Program, buf)
+	_, err = l.requestStream(83, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6301,7 +6302,7 @@ func (l *Libvirt) StoragePoolLookupByName(Name string) (rPool StoragePool, err e
 	}
 
 	var r response
-	r, err = l.request(84, constants.Program, buf)
+	r, err = l.requestStream(84, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6332,7 +6333,7 @@ func (l *Libvirt) StoragePoolLookupByUUID(UUID UUID) (rPool StoragePool, err err
 	}
 
 	var r response
-	r, err = l.request(85, constants.Program, buf)
+	r, err = l.requestStream(85, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6363,7 +6364,7 @@ func (l *Libvirt) StoragePoolLookupByVolume(Vol StorageVol) (rPool StoragePool,
 	}
 
 	var r response
-	r, err = l.request(86, constants.Program, buf)
+	r, err = l.requestStream(86, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6394,7 +6395,7 @@ func (l *Libvirt) StoragePoolGetInfo(Pool StoragePool) (rState uint8, rCapacity
 	}
 
 	var r response
-	r, err = l.request(87, constants.Program, buf)
+	r, err = l.requestStream(87, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6441,7 +6442,7 @@ func (l *Libvirt) StoragePoolGetXMLDesc(Pool StoragePool, Flags StorageXMLFlags)
 	}
 
 	var r response
-	r, err = l.request(88, constants.Program, buf)
+	r, err = l.requestStream(88, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6472,7 +6473,7 @@ func (l *Libvirt) StoragePoolGetAutostart(Pool StoragePool) (rAutostart int32, e
 	}
 
 	var r response
-	r, err = l.request(89, constants.Program, buf)
+	r, err = l.requestStream(89, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6504,7 +6505,7 @@ func (l *Libvirt) StoragePoolSetAutostart(Pool StoragePool, Autostart int32) (er
 	}
 
 
-	_, err = l.request(90, constants.Program, buf)
+	_, err = l.requestStream(90, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6526,7 +6527,7 @@ func (l *Libvirt) StoragePoolNumOfVolumes(Pool StoragePool) (rNum int32, err err
 	}
 
 	var r response
-	r, err = l.request(91, constants.Program, buf)
+	r, err = l.requestStream(91, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6558,7 +6559,7 @@ func (l *Libvirt) StoragePoolListVolumes(Pool StoragePool, Maxnames int32) (rNam
 	}
 
 	var r response
-	r, err = l.request(92, constants.Program, buf)
+	r, err = l.requestStream(92, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6591,7 +6592,7 @@ func (l *Libvirt) StorageVolCreateXML(Pool StoragePool, XML string, Flags Storag
 	}
 
 	var r response
-	r, err = l.request(93, constants.Program, buf)
+	r, err = l.requestStream(93, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6623,7 +6624,7 @@ func (l *Libvirt) StorageVolDelete(Vol StorageVol, Flags StorageVolDeleteFlags)
 	}
 
 
-	_, err = l.request(94, constants.Program, buf)
+	_, err = l.requestStream(94, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6646,7 +6647,7 @@ func (l *Libvirt) StorageVolLookupByName(Pool StoragePool, Name string) (rVol St
 	}
 
 	var r response
-	r, err = l.request(95, constants.Program, buf)
+	r, err = l.requestStream(95, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6677,7 +6678,7 @@ func (l *Libvirt) StorageVolLookupByKey(Key string) (rVol StorageVol, err error)
 	}
 
 	var r response
-	r, err = l.request(96, constants.Program, buf)
+	r, err = l.requestStream(96, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6708,7 +6709,7 @@ func (l *Libvirt) StorageVolLookupByPath(Path string) (rVol StorageVol, err erro
 	}
 
 	var r response
-	r, err = l.request(97, constants.Program, buf)
+	r, err = l.requestStream(97, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6739,7 +6740,7 @@ func (l *Libvirt) StorageVolGetInfo(Vol StorageVol) (rType int8, rCapacity uint6
 	}
 
 	var r response
-	r, err = l.request(98, constants.Program, buf)
+	r, err = l.requestStream(98, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6781,7 +6782,7 @@ func (l *Libvirt) StorageVolGetXMLDesc(Vol StorageVol, Flags uint32) (rXML strin
 	}
 
 	var r response
-	r, err = l.request(99, constants.Program, buf)
+	r, err = l.requestStream(99, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6812,7 +6813,7 @@ func (l *Libvirt) StorageVolGetPath(Vol StorageVol) (rName string, err error) {
 	}
 
 	var r response
-	r, err = l.request(100, constants.Program, buf)
+	r, err = l.requestStream(100, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6844,7 +6845,7 @@ func (l *Libvirt) NodeGetCellsFreeMemory(StartCell int32, Maxcells int32) (rCell
 	}
 
 	var r response
-	r, err = l.request(101, constants.Program, buf)
+	r, err = l.requestStream(101, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6866,7 +6867,7 @@ func (l *Libvirt) NodeGetFreeMemory() (rFreeMem uint64, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(102, constants.Program, buf)
+	r, err = l.requestStream(102, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6901,7 +6902,7 @@ func (l *Libvirt) DomainBlockPeek(Dom Domain, Path string, Offset uint64, Size u
 	}
 
 	var r response
-	r, err = l.request(103, constants.Program, buf)
+	r, err = l.requestStream(103, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6935,7 +6936,7 @@ func (l *Libvirt) DomainMemoryPeek(Dom Domain, Offset uint64, Size uint32, Flags
 	}
 
 	var r response
-	r, err = l.request(104, constants.Program, buf)
+	r, err = l.requestStream(104, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6957,7 +6958,7 @@ func (l *Libvirt) ConnectDomainEventRegister() (rCbRegistered int32, err error)
 	var buf []byte
 
 	var r response
-	r, err = l.request(105, constants.Program, buf)
+	r, err = l.requestStream(105, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -6979,7 +6980,7 @@ func (l *Libvirt) ConnectDomainEventDeregister() (rCbRegistered int32, err error
 	var buf []byte
 
 	var r response
-	r, err = l.request(106, constants.Program, buf)
+	r, err = l.requestStream(106, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7001,7 +7002,7 @@ func (l *Libvirt) DomainEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(107, constants.Program, buf)
+	_, err = l.requestStream(107, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7027,7 +7028,7 @@ func (l *Libvirt) DomainMigratePrepare2(UriIn OptString, Flags uint64, Dname Opt
 	}
 
 	var r response
-	r, err = l.request(108, constants.Program, buf)
+	r, err = l.requestStream(108, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7067,7 +7068,7 @@ func (l *Libvirt) DomainMigrateFinish2(Dname string, Cookie []byte, Uri string,
 	}
 
 	var r response
-	r, err = l.request(109, constants.Program, buf)
+	r, err = l.requestStream(109, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7089,7 +7090,7 @@ func (l *Libvirt) ConnectGetUri() (rUri string, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(110, constants.Program, buf)
+	r, err = l.requestStream(110, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7121,7 +7122,7 @@ func (l *Libvirt) NodeNumOfDevices(Cap OptString, Flags uint32) (rNum int32, err
 	}
 
 	var r response
-	r, err = l.request(111, constants.Program, buf)
+	r, err = l.requestStream(111, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7154,7 +7155,7 @@ func (l *Libvirt) NodeListDevices(Cap OptString, Maxnames int32, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(112, constants.Program, buf)
+	r, err = l.requestStream(112, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7185,7 +7186,7 @@ func (l *Libvirt) NodeDeviceLookupByName(Name string) (rDev NodeDevice, err erro
 	}
 
 	var r response
-	r, err = l.request(113, constants.Program, buf)
+	r, err = l.requestStream(113, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7217,7 +7218,7 @@ func (l *Libvirt) NodeDeviceGetXMLDesc(Name string, Flags uint32) (rXML string,
 	}
 
 	var r response
-	r, err = l.request(114, constants.Program, buf)
+	r, err = l.requestStream(114, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7248,7 +7249,7 @@ func (l *Libvirt) NodeDeviceGetParent(Name string) (rParent OptString, err error
 	}
 
 	var r response
-	r, err = l.request(115, constants.Program, buf)
+	r, err = l.requestStream(115, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7279,7 +7280,7 @@ func (l *Libvirt) NodeDeviceNumOfCaps(Name string) (rNum int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(116, constants.Program, buf)
+	r, err = l.requestStream(116, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7311,7 +7312,7 @@ func (l *Libvirt) NodeDeviceListCaps(Name string, Maxnames int32) (rNames []stri
 	}
 
 	var r response
-	r, err = l.request(117, constants.Program, buf)
+	r, err = l.requestStream(117, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7342,7 +7343,7 @@ func (l *Libvirt) NodeDeviceDettach(Name string) (err error) {
 	}
 
 
-	_, err = l.request(118, constants.Program, buf)
+	_, err = l.requestStream(118, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7364,7 +7365,7 @@ func (l *Libvirt) NodeDeviceReAttach(Name string) (err error) {
 	}
 
 
-	_, err = l.request(119, constants.Program, buf)
+	_, err = l.requestStream(119, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7386,7 +7387,7 @@ func (l *Libvirt) NodeDeviceReset(Name string) (err error) {
 	}
 
 
-	_, err = l.request(120, constants.Program, buf)
+	_, err = l.requestStream(120, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7408,7 +7409,7 @@ func (l *Libvirt) DomainGetSecurityLabel(Dom Domain) (rLabel []int8, rEnforcing
 	}
 
 	var r response
-	r, err = l.request(121, constants.Program, buf)
+	r, err = l.requestStream(121, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7435,7 +7436,7 @@ func (l *Libvirt) NodeGetSecurityModel() (rModel []int8, rDoi []int8, err error)
 	var buf []byte
 
 	var r response
-	r, err = l.request(122, constants.Program, buf)
+	r, err = l.requestStream(122, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7472,7 +7473,7 @@ func (l *Libvirt) NodeDeviceCreateXML(XMLDesc string, Flags uint32) (rDev NodeDe
 	}
 
 	var r response
-	r, err = l.request(123, constants.Program, buf)
+	r, err = l.requestStream(123, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7503,7 +7504,7 @@ func (l *Libvirt) NodeDeviceDestroy(Name string) (err error) {
 	}
 
 
-	_, err = l.request(124, constants.Program, buf)
+	_, err = l.requestStream(124, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7528,7 +7529,7 @@ func (l *Libvirt) StorageVolCreateXMLFrom(Pool StoragePool, XML string, Clonevol
 	}
 
 	var r response
-	r, err = l.request(125, constants.Program, buf)
+	r, err = l.requestStream(125, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7550,7 +7551,7 @@ func (l *Libvirt) ConnectNumOfInterfaces() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(126, constants.Program, buf)
+	r, err = l.requestStream(126, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7581,7 +7582,7 @@ func (l *Libvirt) ConnectListInterfaces(Maxnames int32) (rNames []string, err er
 	}
 
 	var r response
-	r, err = l.request(127, constants.Program, buf)
+	r, err = l.requestStream(127, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7612,7 +7613,7 @@ func (l *Libvirt) InterfaceLookupByName(Name string) (rIface Interface, err erro
 	}
 
 	var r response
-	r, err = l.request(128, constants.Program, buf)
+	r, err = l.requestStream(128, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7643,7 +7644,7 @@ func (l *Libvirt) InterfaceLookupByMacString(Mac string) (rIface Interface, err
 	}
 
 	var r response
-	r, err = l.request(129, constants.Program, buf)
+	r, err = l.requestStream(129, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7675,7 +7676,7 @@ func (l *Libvirt) InterfaceGetXMLDesc(Iface Interface, Flags uint32) (rXML strin
 	}
 
 	var r response
-	r, err = l.request(130, constants.Program, buf)
+	r, err = l.requestStream(130, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7707,7 +7708,7 @@ func (l *Libvirt) InterfaceDefineXML(XML string, Flags uint32) (rIface Interface
 	}
 
 	var r response
-	r, err = l.request(131, constants.Program, buf)
+	r, err = l.requestStream(131, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7738,7 +7739,7 @@ func (l *Libvirt) InterfaceUndefine(Iface Interface) (err error) {
 	}
 
 
-	_, err = l.request(132, constants.Program, buf)
+	_, err = l.requestStream(132, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7761,7 +7762,7 @@ func (l *Libvirt) InterfaceCreate(Iface Interface, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(133, constants.Program, buf)
+	_, err = l.requestStream(133, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7784,7 +7785,7 @@ func (l *Libvirt) InterfaceDestroy(Iface Interface, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(134, constants.Program, buf)
+	_, err = l.requestStream(134, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7808,7 +7809,7 @@ func (l *Libvirt) ConnectDomainXMLFromNative(NativeFormat string, NativeConfig s
 	}
 
 	var r response
-	r, err = l.request(135, constants.Program, buf)
+	r, err = l.requestStream(135, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7841,7 +7842,7 @@ func (l *Libvirt) ConnectDomainXMLToNative(NativeFormat string, DomainXML string
 	}
 
 	var r response
-	r, err = l.request(136, constants.Program, buf)
+	r, err = l.requestStream(136, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7863,7 +7864,7 @@ func (l *Libvirt) ConnectNumOfDefinedInterfaces() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(137, constants.Program, buf)
+	r, err = l.requestStream(137, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7894,7 +7895,7 @@ func (l *Libvirt) ConnectListDefinedInterfaces(Maxnames int32) (rNames []string,
 	}
 
 	var r response
-	r, err = l.request(138, constants.Program, buf)
+	r, err = l.requestStream(138, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7916,7 +7917,7 @@ func (l *Libvirt) ConnectNumOfSecrets() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(139, constants.Program, buf)
+	r, err = l.requestStream(139, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7947,7 +7948,7 @@ func (l *Libvirt) ConnectListSecrets(Maxuuids int32) (rUuids []string, err error
 	}
 
 	var r response
-	r, err = l.request(140, constants.Program, buf)
+	r, err = l.requestStream(140, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -7978,7 +7979,7 @@ func (l *Libvirt) SecretLookupByUUID(UUID UUID) (rOptSecret Secret, err error) {
 	}
 
 	var r response
-	r, err = l.request(141, constants.Program, buf)
+	r, err = l.requestStream(141, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8010,7 +8011,7 @@ func (l *Libvirt) SecretDefineXML(XML string, Flags uint32) (rOptSecret Secret,
 	}
 
 	var r response
-	r, err = l.request(142, constants.Program, buf)
+	r, err = l.requestStream(142, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8042,7 +8043,7 @@ func (l *Libvirt) SecretGetXMLDesc(OptSecret Secret, Flags uint32) (rXML string,
 	}
 
 	var r response
-	r, err = l.request(143, constants.Program, buf)
+	r, err = l.requestStream(143, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8075,7 +8076,7 @@ func (l *Libvirt) SecretSetValue(OptSecret Secret, Value []byte, Flags uint32) (
 	}
 
 
-	_, err = l.request(144, constants.Program, buf)
+	_, err = l.requestStream(144, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8098,7 +8099,7 @@ func (l *Libvirt) SecretGetValue(OptSecret Secret, Flags uint32) (rValue []byte,
 	}
 
 	var r response
-	r, err = l.request(145, constants.Program, buf)
+	r, err = l.requestStream(145, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8129,7 +8130,7 @@ func (l *Libvirt) SecretUndefine(OptSecret Secret) (err error) {
 	}
 
 
-	_, err = l.request(146, constants.Program, buf)
+	_, err = l.requestStream(146, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8152,7 +8153,7 @@ func (l *Libvirt) SecretLookupByUsage(UsageType int32, UsageID string) (rOptSecr
 	}
 
 	var r response
-	r, err = l.request(147, constants.Program, buf)
+	r, err = l.requestStream(147, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8170,7 +8171,7 @@ func (l *Libvirt) SecretLookupByUsage(UsageType int32, UsageID string) (rOptSecr
 }
 
 // DomainMigratePrepareTunnel is the go wrapper for REMOTE_PROC_DOMAIN_MIGRATE_PREPARE_TUNNEL.
-func (l *Libvirt) DomainMigratePrepareTunnel(Flags uint64, Dname OptString, Resource uint64, DomXML string) (err error) {
+func (l *Libvirt) DomainMigratePrepareTunnel(Flags uint64, outStream io.Reader, Dname OptString, Resource uint64, DomXML string) (err error) {
 	var buf []byte
 
 	args := DomainMigratePrepareTunnelArgs {
@@ -8186,7 +8187,7 @@ func (l *Libvirt) DomainMigratePrepareTunnel(Flags uint64, Dname OptString, Reso
 	}
 
 
-	_, err = l.request(148, constants.Program, buf)
+	_, err = l.requestStream(148, constants.Program, buf, outStream, nil)
 	if err != nil {
 		return
 	}
@@ -8199,7 +8200,7 @@ func (l *Libvirt) ConnectIsSecure() (rSecure int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(149, constants.Program, buf)
+	r, err = l.requestStream(149, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8230,7 +8231,7 @@ func (l *Libvirt) DomainIsActive(Dom Domain) (rActive int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(150, constants.Program, buf)
+	r, err = l.requestStream(150, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8261,7 +8262,7 @@ func (l *Libvirt) DomainIsPersistent(Dom Domain) (rPersistent int32, err error)
 	}
 
 	var r response
-	r, err = l.request(151, constants.Program, buf)
+	r, err = l.requestStream(151, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8292,7 +8293,7 @@ func (l *Libvirt) NetworkIsActive(Net Network) (rActive int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(152, constants.Program, buf)
+	r, err = l.requestStream(152, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8323,7 +8324,7 @@ func (l *Libvirt) NetworkIsPersistent(Net Network) (rPersistent int32, err error
 	}
 
 	var r response
-	r, err = l.request(153, constants.Program, buf)
+	r, err = l.requestStream(153, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8354,7 +8355,7 @@ func (l *Libvirt) StoragePoolIsActive(Pool StoragePool) (rActive int32, err erro
 	}
 
 	var r response
-	r, err = l.request(154, constants.Program, buf)
+	r, err = l.requestStream(154, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8385,7 +8386,7 @@ func (l *Libvirt) StoragePoolIsPersistent(Pool StoragePool) (rPersistent int32,
 	}
 
 	var r response
-	r, err = l.request(155, constants.Program, buf)
+	r, err = l.requestStream(155, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8416,7 +8417,7 @@ func (l *Libvirt) InterfaceIsActive(Iface Interface) (rActive int32, err error)
 	}
 
 	var r response
-	r, err = l.request(156, constants.Program, buf)
+	r, err = l.requestStream(156, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8438,7 +8439,7 @@ func (l *Libvirt) ConnectGetLibVersion() (rLibVer uint64, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(157, constants.Program, buf)
+	r, err = l.requestStream(157, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8470,7 +8471,7 @@ func (l *Libvirt) ConnectCompareCPU(XML string, Flags ConnectCompareCPUFlags) (r
 	}
 
 	var r response
-	r, err = l.request(158, constants.Program, buf)
+	r, err = l.requestStream(158, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8503,7 +8504,7 @@ func (l *Libvirt) DomainMemoryStats(Dom Domain, MaxStats uint32, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(159, constants.Program, buf)
+	r, err = l.requestStream(159, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8536,7 +8537,7 @@ func (l *Libvirt) DomainAttachDeviceFlags(Dom Domain, XML string, Flags uint32)
 	}
 
 
-	_, err = l.request(160, constants.Program, buf)
+	_, err = l.requestStream(160, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8560,7 +8561,7 @@ func (l *Libvirt) DomainDetachDeviceFlags(Dom Domain, XML string, Flags uint32)
 	}
 
 
-	_, err = l.request(161, constants.Program, buf)
+	_, err = l.requestStream(161, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8583,7 +8584,7 @@ func (l *Libvirt) ConnectBaselineCPU(XMLCPUs []string, Flags ConnectBaselineCPUF
 	}
 
 	var r response
-	r, err = l.request(162, constants.Program, buf)
+	r, err = l.requestStream(162, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8614,7 +8615,7 @@ func (l *Libvirt) DomainGetJobInfo(Dom Domain) (rType int32, rTimeElapsed uint64
 	}
 
 	var r response
-	r, err = l.request(163, constants.Program, buf)
+	r, err = l.requestStream(163, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8700,7 +8701,7 @@ func (l *Libvirt) DomainAbortJob(Dom Domain) (err error) {
 	}
 
 
-	_, err = l.request(164, constants.Program, buf)
+	_, err = l.requestStream(164, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8723,7 +8724,7 @@ func (l *Libvirt) StorageVolWipe(Vol StorageVol, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(165, constants.Program, buf)
+	_, err = l.requestStream(165, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8747,7 +8748,7 @@ func (l *Libvirt) DomainMigrateSetMaxDowntime(Dom Domain, Downtime uint64, Flags
 	}
 
 
-	_, err = l.request(166, constants.Program, buf)
+	_, err = l.requestStream(166, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8769,7 +8770,7 @@ func (l *Libvirt) ConnectDomainEventRegisterAny(EventID int32) (err error) {
 	}
 
 
-	_, err = l.request(167, constants.Program, buf)
+	_, err = l.requestStream(167, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8791,7 +8792,7 @@ func (l *Libvirt) ConnectDomainEventDeregisterAny(EventID int32) (err error) {
 	}
 
 
-	_, err = l.request(168, constants.Program, buf)
+	_, err = l.requestStream(168, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8804,7 +8805,7 @@ func (l *Libvirt) DomainEventReboot() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(169, constants.Program, buf)
+	_, err = l.requestStream(169, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8817,7 +8818,7 @@ func (l *Libvirt) DomainEventRtcChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(170, constants.Program, buf)
+	_, err = l.requestStream(170, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8830,7 +8831,7 @@ func (l *Libvirt) DomainEventWatchdog() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(171, constants.Program, buf)
+	_, err = l.requestStream(171, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8843,7 +8844,7 @@ func (l *Libvirt) DomainEventIOError() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(172, constants.Program, buf)
+	_, err = l.requestStream(172, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8856,7 +8857,7 @@ func (l *Libvirt) DomainEventGraphics() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(173, constants.Program, buf)
+	_, err = l.requestStream(173, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8880,7 +8881,7 @@ func (l *Libvirt) DomainUpdateDeviceFlags(Dom Domain, XML string, Flags DomainDe
 	}
 
 
-	_, err = l.request(174, constants.Program, buf)
+	_, err = l.requestStream(174, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8902,7 +8903,7 @@ func (l *Libvirt) NwfilterLookupByName(Name string) (rOptNwfilter Nwfilter, err
 	}
 
 	var r response
-	r, err = l.request(175, constants.Program, buf)
+	r, err = l.requestStream(175, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8933,7 +8934,7 @@ func (l *Libvirt) NwfilterLookupByUUID(UUID UUID) (rOptNwfilter Nwfilter, err er
 	}
 
 	var r response
-	r, err = l.request(176, constants.Program, buf)
+	r, err = l.requestStream(176, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8965,7 +8966,7 @@ func (l *Libvirt) NwfilterGetXMLDesc(OptNwfilter Nwfilter, Flags uint32) (rXML s
 	}
 
 	var r response
-	r, err = l.request(177, constants.Program, buf)
+	r, err = l.requestStream(177, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -8987,7 +8988,7 @@ func (l *Libvirt) ConnectNumOfNwfilters() (rNum int32, err error) {
 	var buf []byte
 
 	var r response
-	r, err = l.request(178, constants.Program, buf)
+	r, err = l.requestStream(178, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9018,7 +9019,7 @@ func (l *Libvirt) ConnectListNwfilters(Maxnames int32) (rNames []string, err err
 	}
 
 	var r response
-	r, err = l.request(179, constants.Program, buf)
+	r, err = l.requestStream(179, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9049,7 +9050,7 @@ func (l *Libvirt) NwfilterDefineXML(XML string) (rOptNwfilter Nwfilter, err erro
 	}
 
 	var r response
-	r, err = l.request(180, constants.Program, buf)
+	r, err = l.requestStream(180, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9080,7 +9081,7 @@ func (l *Libvirt) NwfilterUndefine(OptNwfilter Nwfilter) (err error) {
 	}
 
 
-	_, err = l.request(181, constants.Program, buf)
+	_, err = l.requestStream(181, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9103,7 +9104,7 @@ func (l *Libvirt) DomainManagedSave(Dom Domain, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(182, constants.Program, buf)
+	_, err = l.requestStream(182, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9126,7 +9127,7 @@ func (l *Libvirt) DomainHasManagedSaveImage(Dom Domain, Flags uint32) (rResult i
 	}
 
 	var r response
-	r, err = l.request(183, constants.Program, buf)
+	r, err = l.requestStream(183, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9158,7 +9159,7 @@ func (l *Libvirt) DomainManagedSaveRemove(Dom Domain, Flags uint32) (err error)
 	}
 
 
-	_, err = l.request(184, constants.Program, buf)
+	_, err = l.requestStream(184, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9182,7 +9183,7 @@ func (l *Libvirt) DomainSnapshotCreateXML(Dom Domain, XMLDesc string, Flags uint
 	}
 
 	var r response
-	r, err = l.request(185, constants.Program, buf)
+	r, err = l.requestStream(185, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9214,7 +9215,7 @@ func (l *Libvirt) DomainSnapshotGetXMLDesc(Snap DomainSnapshot, Flags uint32) (r
 	}
 
 	var r response
-	r, err = l.request(186, constants.Program, buf)
+	r, err = l.requestStream(186, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9246,7 +9247,7 @@ func (l *Libvirt) DomainSnapshotNum(Dom Domain, Flags uint32) (rNum int32, err e
 	}
 
 	var r response
-	r, err = l.request(187, constants.Program, buf)
+	r, err = l.requestStream(187, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9279,7 +9280,7 @@ func (l *Libvirt) DomainSnapshotListNames(Dom Domain, Maxnames int32, Flags uint
 	}
 
 	var r response
-	r, err = l.request(188, constants.Program, buf)
+	r, err = l.requestStream(188, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9312,7 +9313,7 @@ func (l *Libvirt) DomainSnapshotLookupByName(Dom Domain, Name string, Flags uint
 	}
 
 	var r response
-	r, err = l.request(189, constants.Program, buf)
+	r, err = l.requestStream(189, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9344,7 +9345,7 @@ func (l *Libvirt) DomainHasCurrentSnapshot(Dom Domain, Flags uint32) (rResult in
 	}
 
 	var r response
-	r, err = l.request(190, constants.Program, buf)
+	r, err = l.requestStream(190, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9376,7 +9377,7 @@ func (l *Libvirt) DomainSnapshotCurrent(Dom Domain, Flags uint32) (rSnap DomainS
 	}
 
 	var r response
-	r, err = l.request(191, constants.Program, buf)
+	r, err = l.requestStream(191, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9408,7 +9409,7 @@ func (l *Libvirt) DomainRevertToSnapshot(Snap DomainSnapshot, Flags uint32) (err
 	}
 
 
-	_, err = l.request(192, constants.Program, buf)
+	_, err = l.requestStream(192, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9431,7 +9432,7 @@ func (l *Libvirt) DomainSnapshotDelete(Snap DomainSnapshot, Flags DomainSnapshot
 	}
 
 
-	_, err = l.request(193, constants.Program, buf)
+	_, err = l.requestStream(193, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9455,7 +9456,7 @@ func (l *Libvirt) DomainGetBlockInfo(Dom Domain, Path string, Flags uint32) (rAl
 	}
 
 	var r response
-	r, err = l.request(194, constants.Program, buf)
+	r, err = l.requestStream(194, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9487,7 +9488,7 @@ func (l *Libvirt) DomainEventIOErrorReason() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(195, constants.Program, buf)
+	_, err = l.requestStream(195, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9510,7 +9511,7 @@ func (l *Libvirt) DomainCreateWithFlags(Dom Domain, Flags uint32) (rDom Domain,
 	}
 
 	var r response
-	r, err = l.request(196, constants.Program, buf)
+	r, err = l.requestStream(196, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9543,7 +9544,7 @@ func (l *Libvirt) DomainSetMemoryParameters(Dom Domain, Params []TypedParam, Fla
 	}
 
 
-	_, err = l.request(197, constants.Program, buf)
+	_, err = l.requestStream(197, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9567,7 +9568,7 @@ func (l *Libvirt) DomainGetMemoryParameters(Dom Domain, Nparams int32, Flags uin
 	}
 
 	var r response
-	r, err = l.request(198, constants.Program, buf)
+	r, err = l.requestStream(198, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9606,7 +9607,7 @@ func (l *Libvirt) DomainSetVcpusFlags(Dom Domain, Nvcpus uint32, Flags uint32) (
 	}
 
 
-	_, err = l.request(199, constants.Program, buf)
+	_, err = l.requestStream(199, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9629,7 +9630,7 @@ func (l *Libvirt) DomainGetVcpusFlags(Dom Domain, Flags uint32) (rNum int32, err
 	}
 
 	var r response
-	r, err = l.request(200, constants.Program, buf)
+	r, err = l.requestStream(200, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9647,7 +9648,7 @@ func (l *Libvirt) DomainGetVcpusFlags(Dom Domain, Flags uint32) (rNum int32, err
 }
 
 // DomainOpenConsole is the go wrapper for REMOTE_PROC_DOMAIN_OPEN_CONSOLE.
-func (l *Libvirt) DomainOpenConsole(Dom Domain, DevName OptString, Flags uint32) (err error) {
+func (l *Libvirt) DomainOpenConsole(Dom Domain, DevName OptString, inStream io.Writer, Flags uint32) (err error) {
 	var buf []byte
 
 	args := DomainOpenConsoleArgs {
@@ -9662,7 +9663,7 @@ func (l *Libvirt) DomainOpenConsole(Dom Domain, DevName OptString, Flags uint32)
 	}
 
 
-	_, err = l.request(201, constants.Program, buf)
+	_, err = l.requestStream(201, constants.Program, buf, nil, inStream)
 	if err != nil {
 		return
 	}
@@ -9684,7 +9685,7 @@ func (l *Libvirt) DomainIsUpdated(Dom Domain) (rUpdated int32, err error) {
 	}
 
 	var r response
-	r, err = l.request(202, constants.Program, buf)
+	r, err = l.requestStream(202, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9715,7 +9716,7 @@ func (l *Libvirt) ConnectGetSysinfo(Flags uint32) (rSysinfo string, err error) {
 	}
 
 	var r response
-	r, err = l.request(203, constants.Program, buf)
+	r, err = l.requestStream(203, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9748,7 +9749,7 @@ func (l *Libvirt) DomainSetMemoryFlags(Dom Domain, Memory uint64, Flags uint32)
 	}
 
 
-	_, err = l.request(204, constants.Program, buf)
+	_, err = l.requestStream(204, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9772,7 +9773,7 @@ func (l *Libvirt) DomainSetBlkioParameters(Dom Domain, Params []TypedParam, Flag
 	}
 
 
-	_, err = l.request(205, constants.Program, buf)
+	_, err = l.requestStream(205, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9796,7 +9797,7 @@ func (l *Libvirt) DomainGetBlkioParameters(Dom Domain, Nparams int32, Flags uint
 	}
 
 	var r response
-	r, err = l.request(206, constants.Program, buf)
+	r, err = l.requestStream(206, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9835,7 +9836,7 @@ func (l *Libvirt) DomainMigrateSetMaxSpeed(Dom Domain, Bandwidth uint64, Flags u
 	}
 
 
-	_, err = l.request(207, constants.Program, buf)
+	_, err = l.requestStream(207, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9844,7 +9845,7 @@ func (l *Libvirt) DomainMigrateSetMaxSpeed(Dom Domain, Bandwidth uint64, Flags u
 }
 
 // StorageVolUpload is the go wrapper for REMOTE_PROC_STORAGE_VOL_UPLOAD.
-func (l *Libvirt) StorageVolUpload(Vol StorageVol, Offset uint64, Length uint64, Flags uint32) (err error) {
+func (l *Libvirt) StorageVolUpload(Vol StorageVol, outStream io.Reader, Offset uint64, Length uint64, Flags uint32) (err error) {
 	var buf []byte
 
 	args := StorageVolUploadArgs {
@@ -9860,7 +9861,7 @@ func (l *Libvirt) StorageVolUpload(Vol StorageVol, Offset uint64, Length uint64,
 	}
 
 
-	_, err = l.request(208, constants.Program, buf)
+	_, err = l.requestStream(208, constants.Program, buf, outStream, nil)
 	if err != nil {
 		return
 	}
@@ -9869,7 +9870,7 @@ func (l *Libvirt) StorageVolUpload(Vol StorageVol, Offset uint64, Length uint64,
 }
 
 // StorageVolDownload is the go wrapper for REMOTE_PROC_STORAGE_VOL_DOWNLOAD.
-func (l *Libvirt) StorageVolDownload(Vol StorageVol, Offset uint64, Length uint64, Flags uint32) (err error) {
+func (l *Libvirt) StorageVolDownload(Vol StorageVol, inStream io.Writer, Offset uint64, Length uint64, Flags uint32) (err error) {
 	var buf []byte
 
 	args := StorageVolDownloadArgs {
@@ -9885,7 +9886,7 @@ func (l *Libvirt) StorageVolDownload(Vol StorageVol, Offset uint64, Length uint6
 	}
 
 
-	_, err = l.request(209, constants.Program, buf)
+	_, err = l.requestStream(209, constants.Program, buf, nil, inStream)
 	if err != nil {
 		return
 	}
@@ -9908,7 +9909,7 @@ func (l *Libvirt) DomainInjectNmi(Dom Domain, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(210, constants.Program, buf)
+	_, err = l.requestStream(210, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -9917,7 +9918,7 @@ func (l *Libvirt) DomainInjectNmi(Dom Domain, Flags uint32) (err error) {
 }
 
 // DomainScreenshot is the go wrapper for REMOTE_PROC_DOMAIN_SCREENSHOT.
-func (l *Libvirt) DomainScreenshot(Dom Domain, Screen uint32, Flags uint32) (rMime OptString, err error) {
+func (l *Libvirt) DomainScreenshot(Dom Domain, inStream io.Writer, Screen uint32, Flags uint32) (rMime OptString, err error) {
 	var buf []byte
 
 	args := DomainScreenshotArgs {
@@ -9932,7 +9933,7 @@ func (l *Libvirt) DomainScreenshot(Dom Domain, Screen uint32, Flags uint32) (rMi
 	}
 
 	var r response
-	r, err = l.request(211, constants.Program, buf)
+	r, err = l.requestStream(211, constants.Program, buf, nil, inStream)
 	if err != nil {
 		return
 	}
@@ -9964,7 +9965,7 @@ func (l *Libvirt) DomainGetState(Dom Domain, Flags uint32) (rState int32, rReaso
 	}
 
 	var r response
-	r, err = l.request(212, constants.Program, buf)
+	r, err = l.requestStream(212, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10004,7 +10005,7 @@ func (l *Libvirt) DomainMigrateBegin3(Dom Domain, Xmlin OptString, Flags uint64,
 	}
 
 	var r response
-	r, err = l.request(213, constants.Program, buf)
+	r, err = l.requestStream(213, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10045,7 +10046,7 @@ func (l *Libvirt) DomainMigratePrepare3(CookieIn []byte, UriIn OptString, Flags
 	}
 
 	var r response
-	r, err = l.request(214, constants.Program, buf)
+	r, err = l.requestStream(214, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10068,7 +10069,7 @@ func (l *Libvirt) DomainMigratePrepare3(CookieIn []byte, UriIn OptString, Flags
 }
 
 // DomainMigratePrepareTunnel3 is the go wrapper for REMOTE_PROC_DOMAIN_MIGRATE_PREPARE_TUNNEL3.
-func (l *Libvirt) DomainMigratePrepareTunnel3(CookieIn []byte, Flags uint64, Dname OptString, Resource uint64, DomXML string) (rCookieOut []byte, err error) {
+func (l *Libvirt) DomainMigratePrepareTunnel3(CookieIn []byte, outStream io.Reader, Flags uint64, Dname OptString, Resource uint64, DomXML string) (rCookieOut []byte, err error) {
 	var buf []byte
 
 	args := DomainMigratePrepareTunnel3Args {
@@ -10085,7 +10086,7 @@ func (l *Libvirt) DomainMigratePrepareTunnel3(CookieIn []byte, Flags uint64, Dna
 	}
 
 	var r response
-	r, err = l.request(215, constants.Program, buf)
+	r, err = l.requestStream(215, constants.Program, buf, outStream, nil)
 	if err != nil {
 		return
 	}
@@ -10123,7 +10124,7 @@ func (l *Libvirt) DomainMigratePerform3(Dom Domain, Xmlin OptString, CookieIn []
 	}
 
 	var r response
-	r, err = l.request(216, constants.Program, buf)
+	r, err = l.requestStream(216, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10159,7 +10160,7 @@ func (l *Libvirt) DomainMigrateFinish3(Dname string, CookieIn []byte, Dconnuri O
 	}
 
 	var r response
-	r, err = l.request(217, constants.Program, buf)
+	r, err = l.requestStream(217, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10198,7 +10199,7 @@ func (l *Libvirt) DomainMigrateConfirm3(Dom Domain, CookieIn []byte, Flags uint6
 	}
 
 
-	_, err = l.request(218, constants.Program, buf)
+	_, err = l.requestStream(218, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10222,7 +10223,7 @@ func (l *Libvirt) DomainSetSchedulerParametersFlags(Dom Domain, Params []TypedPa
 	}
 
 
-	_, err = l.request(219, constants.Program, buf)
+	_, err = l.requestStream(219, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10244,7 +10245,7 @@ func (l *Libvirt) InterfaceChangeBegin(Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(220, constants.Program, buf)
+	_, err = l.requestStream(220, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10266,7 +10267,7 @@ func (l *Libvirt) InterfaceChangeCommit(Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(221, constants.Program, buf)
+	_, err = l.requestStream(221, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10288,7 +10289,7 @@ func (l *Libvirt) InterfaceChangeRollback(Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(222, constants.Program, buf)
+	_, err = l.requestStream(222, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10312,7 +10313,7 @@ func (l *Libvirt) DomainGetSchedulerParametersFlags(Dom Domain, Nparams int32, F
 	}
 
 	var r response
-	r, err = l.request(223, constants.Program, buf)
+	r, err = l.requestStream(223, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10335,7 +10336,7 @@ func (l *Libvirt) DomainEventControlError() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(224, constants.Program, buf)
+	_, err = l.requestStream(224, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10360,7 +10361,7 @@ func (l *Libvirt) DomainPinVcpuFlags(Dom Domain, Vcpu uint32, Cpumap []byte, Fla
 	}
 
 
-	_, err = l.request(225, constants.Program, buf)
+	_, err = l.requestStream(225, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10386,7 +10387,7 @@ func (l *Libvirt) DomainSendKey(Dom Domain, Codeset uint32, Holdtime uint32, Key
 	}
 
 
-	_, err = l.request(226, constants.Program, buf)
+	_, err = l.requestStream(226, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10410,7 +10411,7 @@ func (l *Libvirt) NodeGetCPUStats(CPUNum int32, Nparams int32, Flags uint32) (rP
 	}
 
 	var r response
-	r, err = l.request(227, constants.Program, buf)
+	r, err = l.requestStream(227, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10448,7 +10449,7 @@ func (l *Libvirt) NodeGetMemoryStats(Nparams int32, CellNum int32, Flags uint32)
 	}
 
 	var r response
-	r, err = l.request(228, constants.Program, buf)
+	r, err = l.requestStream(228, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10485,7 +10486,7 @@ func (l *Libvirt) DomainGetControlInfo(Dom Domain, Flags uint32) (rState uint32,
 	}
 
 	var r response
-	r, err = l.request(229, constants.Program, buf)
+	r, err = l.requestStream(229, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10529,7 +10530,7 @@ func (l *Libvirt) DomainGetVcpuPinInfo(Dom Domain, Ncpumaps int32, Maplen int32,
 	}
 
 	var r response
-	r, err = l.request(230, constants.Program, buf)
+	r, err = l.requestStream(230, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10566,7 +10567,7 @@ func (l *Libvirt) DomainUndefineFlags(Dom Domain, Flags DomainUndefineFlagsValue
 	}
 
 
-	_, err = l.request(231, constants.Program, buf)
+	_, err = l.requestStream(231, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10591,7 +10592,7 @@ func (l *Libvirt) DomainSaveFlags(Dom Domain, To string, Dxml OptString, Flags u
 	}
 
 
-	_, err = l.request(232, constants.Program, buf)
+	_, err = l.requestStream(232, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10615,7 +10616,7 @@ func (l *Libvirt) DomainRestoreFlags(From string, Dxml OptString, Flags uint32)
 	}
 
 
-	_, err = l.request(233, constants.Program, buf)
+	_, err = l.requestStream(233, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10638,7 +10639,7 @@ func (l *Libvirt) DomainDestroyFlags(Dom Domain, Flags DomainDestroyFlagsValues)
 	}
 
 
-	_, err = l.request(234, constants.Program, buf)
+	_, err = l.requestStream(234, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10661,7 +10662,7 @@ func (l *Libvirt) DomainSaveImageGetXMLDesc(File string, Flags uint32) (rXML str
 	}
 
 	var r response
-	r, err = l.request(235, constants.Program, buf)
+	r, err = l.requestStream(235, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10694,7 +10695,7 @@ func (l *Libvirt) DomainSaveImageDefineXML(File string, Dxml string, Flags uint3
 	}
 
 
-	_, err = l.request(236, constants.Program, buf)
+	_, err = l.requestStream(236, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10718,7 +10719,7 @@ func (l *Libvirt) DomainBlockJobAbort(Dom Domain, Path string, Flags DomainBlock
 	}
 
 
-	_, err = l.request(237, constants.Program, buf)
+	_, err = l.requestStream(237, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10742,7 +10743,7 @@ func (l *Libvirt) DomainGetBlockJobInfo(Dom Domain, Path string, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(238, constants.Program, buf)
+	r, err = l.requestStream(238, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10796,7 +10797,7 @@ func (l *Libvirt) DomainBlockJobSetSpeed(Dom Domain, Path string, Bandwidth uint
 	}
 
 
-	_, err = l.request(239, constants.Program, buf)
+	_, err = l.requestStream(239, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10821,7 +10822,7 @@ func (l *Libvirt) DomainBlockPull(Dom Domain, Path string, Bandwidth uint64, Fla
 	}
 
 
-	_, err = l.request(240, constants.Program, buf)
+	_, err = l.requestStream(240, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10834,7 +10835,7 @@ func (l *Libvirt) DomainEventBlockJob() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(241, constants.Program, buf)
+	_, err = l.requestStream(241, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10857,7 +10858,7 @@ func (l *Libvirt) DomainMigrateGetMaxSpeed(Dom Domain, Flags uint32) (rBandwidth
 	}
 
 	var r response
-	r, err = l.request(242, constants.Program, buf)
+	r, err = l.requestStream(242, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10891,7 +10892,7 @@ func (l *Libvirt) DomainBlockStatsFlags(Dom Domain, Path string, Nparams int32,
 	}
 
 	var r response
-	r, err = l.request(243, constants.Program, buf)
+	r, err = l.requestStream(243, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10929,7 +10930,7 @@ func (l *Libvirt) DomainSnapshotGetParent(Snap DomainSnapshot, Flags uint32) (rS
 	}
 
 	var r response
-	r, err = l.request(244, constants.Program, buf)
+	r, err = l.requestStream(244, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10961,7 +10962,7 @@ func (l *Libvirt) DomainReset(Dom Domain, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(245, constants.Program, buf)
+	_, err = l.requestStream(245, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -10984,7 +10985,7 @@ func (l *Libvirt) DomainSnapshotNumChildren(Snap DomainSnapshot, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(246, constants.Program, buf)
+	r, err = l.requestStream(246, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11017,7 +11018,7 @@ func (l *Libvirt) DomainSnapshotListChildrenNames(Snap DomainSnapshot, Maxnames
 	}
 
 	var r response
-	r, err = l.request(247, constants.Program, buf)
+	r, err = l.requestStream(247, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11039,7 +11040,7 @@ func (l *Libvirt) DomainEventDiskChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(248, constants.Program, buf)
+	_, err = l.requestStream(248, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11063,7 +11064,7 @@ func (l *Libvirt) DomainOpenGraphics(Dom Domain, Idx uint32, Flags DomainOpenGra
 	}
 
 
-	_, err = l.request(249, constants.Program, buf)
+	_, err = l.requestStream(249, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11087,7 +11088,7 @@ func (l *Libvirt) NodeSuspendForDuration(Target uint32, Duration uint64, Flags u
 	}
 
 
-	_, err = l.request(250, constants.Program, buf)
+	_, err = l.requestStream(250, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11112,7 +11113,7 @@ func (l *Libvirt) DomainBlockResize(Dom Domain, Disk string, Size uint64, Flags
 	}
 
 
-	_, err = l.request(251, constants.Program, buf)
+	_, err = l.requestStream(251, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11137,7 +11138,7 @@ func (l *Libvirt) DomainSetBlockIOTune(Dom Domain, Disk string, Params []TypedPa
 	}
 
 
-	_, err = l.request(252, constants.Program, buf)
+	_, err = l.requestStream(252, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11162,7 +11163,7 @@ func (l *Libvirt) DomainGetBlockIOTune(Dom Domain, Disk OptString, Nparams int32
 	}
 
 	var r response
-	r, err = l.request(253, constants.Program, buf)
+	r, err = l.requestStream(253, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11201,7 +11202,7 @@ func (l *Libvirt) DomainSetNumaParameters(Dom Domain, Params []TypedParam, Flags
 	}
 
 
-	_, err = l.request(254, constants.Program, buf)
+	_, err = l.requestStream(254, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11225,7 +11226,7 @@ func (l *Libvirt) DomainGetNumaParameters(Dom Domain, Nparams int32, Flags uint3
 	}
 
 	var r response
-	r, err = l.request(255, constants.Program, buf)
+	r, err = l.requestStream(255, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11265,7 +11266,7 @@ func (l *Libvirt) DomainSetInterfaceParameters(Dom Domain, Device string, Params
 	}
 
 
-	_, err = l.request(256, constants.Program, buf)
+	_, err = l.requestStream(256, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11290,7 +11291,7 @@ func (l *Libvirt) DomainGetInterfaceParameters(Dom Domain, Device string, Nparam
 	}
 
 	var r response
-	r, err = l.request(257, constants.Program, buf)
+	r, err = l.requestStream(257, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11328,7 +11329,7 @@ func (l *Libvirt) DomainShutdownFlags(Dom Domain, Flags DomainShutdownFlagValues
 	}
 
 
-	_, err = l.request(258, constants.Program, buf)
+	_, err = l.requestStream(258, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11352,7 +11353,7 @@ func (l *Libvirt) StorageVolWipePattern(Vol StorageVol, Algorithm uint32, Flags
 	}
 
 
-	_, err = l.request(259, constants.Program, buf)
+	_, err = l.requestStream(259, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11376,7 +11377,7 @@ func (l *Libvirt) StorageVolResize(Vol StorageVol, Capacity uint64, Flags Storag
 	}
 
 
-	_, err = l.request(260, constants.Program, buf)
+	_, err = l.requestStream(260, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11401,7 +11402,7 @@ func (l *Libvirt) DomainPmSuspendForDuration(Dom Domain, Target uint32, Duration
 	}
 
 
-	_, err = l.request(261, constants.Program, buf)
+	_, err = l.requestStream(261, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11427,7 +11428,7 @@ func (l *Libvirt) DomainGetCPUStats(Dom Domain, Nparams uint32, StartCPU int32,
 	}
 
 	var r response
-	r, err = l.request(262, constants.Program, buf)
+	r, err = l.requestStream(262, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11466,7 +11467,7 @@ func (l *Libvirt) DomainGetDiskErrors(Dom Domain, Maxerrors uint32, Flags uint32
 	}
 
 	var r response
-	r, err = l.request(263, constants.Program, buf)
+	r, err = l.requestStream(263, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11507,7 +11508,7 @@ func (l *Libvirt) DomainSetMetadata(Dom Domain, Type int32, Metadata OptString,
 	}
 
 
-	_, err = l.request(264, constants.Program, buf)
+	_, err = l.requestStream(264, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11532,7 +11533,7 @@ func (l *Libvirt) DomainGetMetadata(Dom Domain, Type int32, Uri OptString, Flags
 	}
 
 	var r response
-	r, err = l.request(265, constants.Program, buf)
+	r, err = l.requestStream(265, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11567,7 +11568,7 @@ func (l *Libvirt) DomainBlockRebase(Dom Domain, Path string, Base OptString, Ban
 	}
 
 
-	_, err = l.request(266, constants.Program, buf)
+	_, err = l.requestStream(266, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11590,7 +11591,7 @@ func (l *Libvirt) DomainPmWakeup(Dom Domain, Flags uint32) (err error) {
 	}
 
 
-	_, err = l.request(267, constants.Program, buf)
+	_, err = l.requestStream(267, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11603,7 +11604,7 @@ func (l *Libvirt) DomainEventTrayChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(268, constants.Program, buf)
+	_, err = l.requestStream(268, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11616,7 +11617,7 @@ func (l *Libvirt) DomainEventPmwakeup() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(269, constants.Program, buf)
+	_, err = l.requestStream(269, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11629,7 +11630,7 @@ func (l *Libvirt) DomainEventPmsuspend() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(270, constants.Program, buf)
+	_, err = l.requestStream(270, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11652,7 +11653,7 @@ func (l *Libvirt) DomainSnapshotIsCurrent(Snap DomainSnapshot, Flags uint32) (rC
 	}
 
 	var r response
-	r, err = l.request(271, constants.Program, buf)
+	r, err = l.requestStream(271, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11684,7 +11685,7 @@ func (l *Libvirt) DomainSnapshotHasMetadata(Snap DomainSnapshot, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(272, constants.Program, buf)
+	r, err = l.requestStream(272, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11716,7 +11717,7 @@ func (l *Libvirt) ConnectListAllDomains(NeedResults int32, Flags ConnectListAllD
 	}
 
 	var r response
-	r, err = l.request(273, constants.Program, buf)
+	r, err = l.requestStream(273, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11754,7 +11755,7 @@ func (l *Libvirt) DomainListAllSnapshots(Dom Domain, NeedResults int32, Flags ui
 	}
 
 	var r response
-	r, err = l.request(274, constants.Program, buf)
+	r, err = l.requestStream(274, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11792,7 +11793,7 @@ func (l *Libvirt) DomainSnapshotListAllChildren(Snapshot DomainSnapshot, NeedRes
 	}
 
 	var r response
-	r, err = l.request(275, constants.Program, buf)
+	r, err = l.requestStream(275, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11819,7 +11820,7 @@ func (l *Libvirt) DomainEventBalloonChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(276, constants.Program, buf)
+	_, err = l.requestStream(276, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11842,7 +11843,7 @@ func (l *Libvirt) DomainGetHostname(Dom Domain, Flags uint32) (rHostname string,
 	}
 
 	var r response
-	r, err = l.request(277, constants.Program, buf)
+	r, err = l.requestStream(277, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11873,7 +11874,7 @@ func (l *Libvirt) DomainGetSecurityLabelList(Dom Domain) (rLabels []DomainGetSec
 	}
 
 	var r response
-	r, err = l.request(278, constants.Program, buf)
+	r, err = l.requestStream(278, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11911,7 +11912,7 @@ func (l *Libvirt) DomainPinEmulator(Dom Domain, Cpumap []byte, Flags DomainModif
 	}
 
 
-	_, err = l.request(279, constants.Program, buf)
+	_, err = l.requestStream(279, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11935,7 +11936,7 @@ func (l *Libvirt) DomainGetEmulatorPinInfo(Dom Domain, Maplen int32, Flags Domai
 	}
 
 	var r response
-	r, err = l.request(280, constants.Program, buf)
+	r, err = l.requestStream(280, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -11972,7 +11973,7 @@ func (l *Libvirt) ConnectListAllStoragePools(NeedResults int32, Flags ConnectLis
 	}
 
 	var r response
-	r, err = l.request(281, constants.Program, buf)
+	r, err = l.requestStream(281, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12010,7 +12011,7 @@ func (l *Libvirt) StoragePoolListAllVolumes(Pool StoragePool, NeedResults int32,
 	}
 
 	var r response
-	r, err = l.request(282, constants.Program, buf)
+	r, err = l.requestStream(282, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12047,7 +12048,7 @@ func (l *Libvirt) ConnectListAllNetworks(NeedResults int32, Flags ConnectListAll
 	}
 
 	var r response
-	r, err = l.request(283, constants.Program, buf)
+	r, err = l.requestStream(283, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12084,7 +12085,7 @@ func (l *Libvirt) ConnectListAllInterfaces(NeedResults int32, Flags ConnectListA
 	}
 
 	var r response
-	r, err = l.request(284, constants.Program, buf)
+	r, err = l.requestStream(284, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12121,7 +12122,7 @@ func (l *Libvirt) ConnectListAllNodeDevices(NeedResults int32, Flags uint32) (rD
 	}
 
 	var r response
-	r, err = l.request(285, constants.Program, buf)
+	r, err = l.requestStream(285, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12158,7 +12159,7 @@ func (l *Libvirt) ConnectListAllNwfilters(NeedResults int32, Flags uint32) (rFil
 	}
 
 	var r response
-	r, err = l.request(286, constants.Program, buf)
+	r, err = l.requestStream(286, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12195,7 +12196,7 @@ func (l *Libvirt) ConnectListAllSecrets(NeedResults int32, Flags ConnectListAllS
 	}
 
 	var r response
-	r, err = l.request(287, constants.Program, buf)
+	r, err = l.requestStream(287, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12232,7 +12233,7 @@ func (l *Libvirt) NodeSetMemoryParameters(Params []TypedParam, Flags uint32) (er
 	}
 
 
-	_, err = l.request(288, constants.Program, buf)
+	_, err = l.requestStream(288, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12255,7 +12256,7 @@ func (l *Libvirt) NodeGetMemoryParameters(Nparams int32, Flags uint32) (rParams
 	}
 
 	var r response
-	r, err = l.request(289, constants.Program, buf)
+	r, err = l.requestStream(289, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12297,7 +12298,7 @@ func (l *Libvirt) DomainBlockCommit(Dom Domain, Disk string, Base OptString, Top
 	}
 
 
-	_, err = l.request(290, constants.Program, buf)
+	_, err = l.requestStream(290, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12324,7 +12325,7 @@ func (l *Libvirt) NetworkUpdate(Net Network, Command uint32, Section uint32, Par
 	}
 
 
-	_, err = l.request(291, constants.Program, buf)
+	_, err = l.requestStream(291, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12337,7 +12338,7 @@ func (l *Libvirt) DomainEventPmsuspendDisk() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(292, constants.Program, buf)
+	_, err = l.requestStream(292, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12361,7 +12362,7 @@ func (l *Libvirt) NodeGetCPUMap(NeedMap int32, NeedOnline int32, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(293, constants.Program, buf)
+	r, err = l.requestStream(293, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12405,7 +12406,7 @@ func (l *Libvirt) DomainFstrim(Dom Domain, MountPoint OptString, Minimum uint64,
 	}
 
 
-	_, err = l.request(294, constants.Program, buf)
+	_, err = l.requestStream(294, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12430,7 +12431,7 @@ func (l *Libvirt) DomainSendProcessSignal(Dom Domain, PidValue int64, Signum uin
 	}
 
 
-	_, err = l.request(295, constants.Program, buf)
+	_, err = l.requestStream(295, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12439,7 +12440,7 @@ func (l *Libvirt) DomainSendProcessSignal(Dom Domain, PidValue int64, Signum uin
 }
 
 // DomainOpenChannel is the go wrapper for REMOTE_PROC_DOMAIN_OPEN_CHANNEL.
-func (l *Libvirt) DomainOpenChannel(Dom Domain, Name OptString, Flags DomainChannelFlags) (err error) {
+func (l *Libvirt) DomainOpenChannel(Dom Domain, Name OptString, inStream io.Writer, Flags DomainChannelFlags) (err error) {
 	var buf []byte
 
 	args := DomainOpenChannelArgs {
@@ -12454,7 +12455,7 @@ func (l *Libvirt) DomainOpenChannel(Dom Domain, Name OptString, Flags DomainChan
 	}
 
 
-	_, err = l.request(296, constants.Program, buf)
+	_, err = l.requestStream(296, constants.Program, buf, nil, inStream)
 	if err != nil {
 		return
 	}
@@ -12478,7 +12479,7 @@ func (l *Libvirt) NodeDeviceLookupScsiHostByWwn(Wwnn string, Wwpn string, Flags
 	}
 
 	var r response
-	r, err = l.request(297, constants.Program, buf)
+	r, err = l.requestStream(297, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12510,7 +12511,7 @@ func (l *Libvirt) DomainGetJobStats(Dom Domain, Flags DomainGetJobStatsFlags) (r
 	}
 
 	var r response
-	r, err = l.request(298, constants.Program, buf)
+	r, err = l.requestStream(298, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12548,7 +12549,7 @@ func (l *Libvirt) DomainMigrateGetCompressionCache(Dom Domain, Flags uint32) (rC
 	}
 
 	var r response
-	r, err = l.request(299, constants.Program, buf)
+	r, err = l.requestStream(299, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12581,7 +12582,7 @@ func (l *Libvirt) DomainMigrateSetCompressionCache(Dom Domain, CacheSize uint64,
 	}
 
 
-	_, err = l.request(300, constants.Program, buf)
+	_, err = l.requestStream(300, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12605,7 +12606,7 @@ func (l *Libvirt) NodeDeviceDetachFlags(Name string, DriverName OptString, Flags
 	}
 
 
-	_, err = l.request(301, constants.Program, buf)
+	_, err = l.requestStream(301, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12629,7 +12630,7 @@ func (l *Libvirt) DomainMigrateBegin3Params(Dom Domain, Params []TypedParam, Fla
 	}
 
 	var r response
-	r, err = l.request(302, constants.Program, buf)
+	r, err = l.requestStream(302, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12667,7 +12668,7 @@ func (l *Libvirt) DomainMigratePrepare3Params(Params []TypedParam, CookieIn []by
 	}
 
 	var r response
-	r, err = l.request(303, constants.Program, buf)
+	r, err = l.requestStream(303, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12705,7 +12706,7 @@ func (l *Libvirt) DomainMigratePrepareTunnel3Params(Params []TypedParam, CookieI
 	}
 
 	var r response
-	r, err = l.request(304, constants.Program, buf)
+	r, err = l.requestStream(304, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12740,7 +12741,7 @@ func (l *Libvirt) DomainMigratePerform3Params(Dom Domain, Dconnuri OptString, Pa
 	}
 
 	var r response
-	r, err = l.request(305, constants.Program, buf)
+	r, err = l.requestStream(305, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12774,7 +12775,7 @@ func (l *Libvirt) DomainMigrateFinish3Params(Params []TypedParam, CookieIn []byt
 	}
 
 	var r response
-	r, err = l.request(306, constants.Program, buf)
+	r, err = l.requestStream(306, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12814,7 +12815,7 @@ func (l *Libvirt) DomainMigrateConfirm3Params(Dom Domain, Params []TypedParam, C
 	}
 
 
-	_, err = l.request(307, constants.Program, buf)
+	_, err = l.requestStream(307, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12838,7 +12839,7 @@ func (l *Libvirt) DomainSetMemoryStatsPeriod(Dom Domain, Period int32, Flags Dom
 	}
 
 
-	_, err = l.request(308, constants.Program, buf)
+	_, err = l.requestStream(308, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12861,7 +12862,7 @@ func (l *Libvirt) DomainCreateXMLWithFiles(XMLDesc string, Flags DomainCreateFla
 	}
 
 	var r response
-	r, err = l.request(309, constants.Program, buf)
+	r, err = l.requestStream(309, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12893,7 +12894,7 @@ func (l *Libvirt) DomainCreateWithFiles(Dom Domain, Flags DomainCreateFlags) (rD
 	}
 
 	var r response
-	r, err = l.request(310, constants.Program, buf)
+	r, err = l.requestStream(310, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12915,7 +12916,7 @@ func (l *Libvirt) DomainEventDeviceRemoved() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(311, constants.Program, buf)
+	_, err = l.requestStream(311, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12939,7 +12940,7 @@ func (l *Libvirt) ConnectGetCPUModelNames(Arch string, NeedResults int32, Flags
 	}
 
 	var r response
-	r, err = l.request(312, constants.Program, buf)
+	r, err = l.requestStream(312, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -12976,7 +12977,7 @@ func (l *Libvirt) ConnectNetworkEventRegisterAny(EventID int32, Net OptNetwork)
 	}
 
 	var r response
-	r, err = l.request(313, constants.Program, buf)
+	r, err = l.requestStream(313, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13007,7 +13008,7 @@ func (l *Libvirt) ConnectNetworkEventDeregisterAny(CallbackID int32) (err error)
 	}
 
 
-	_, err = l.request(314, constants.Program, buf)
+	_, err = l.requestStream(314, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13020,7 +13021,7 @@ func (l *Libvirt) NetworkEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(315, constants.Program, buf)
+	_, err = l.requestStream(315, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13043,7 +13044,7 @@ func (l *Libvirt) ConnectDomainEventCallbackRegisterAny(EventID int32, Dom OptDo
 	}
 
 	var r response
-	r, err = l.request(316, constants.Program, buf)
+	r, err = l.requestStream(316, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13074,7 +13075,7 @@ func (l *Libvirt) ConnectDomainEventCallbackDeregisterAny(CallbackID int32) (err
 	}
 
 
-	_, err = l.request(317, constants.Program, buf)
+	_, err = l.requestStream(317, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13087,7 +13088,7 @@ func (l *Libvirt) DomainEventCallbackLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(318, constants.Program, buf)
+	_, err = l.requestStream(318, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13100,7 +13101,7 @@ func (l *Libvirt) DomainEventCallbackReboot() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(319, constants.Program, buf)
+	_, err = l.requestStream(319, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13113,7 +13114,7 @@ func (l *Libvirt) DomainEventCallbackRtcChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(320, constants.Program, buf)
+	_, err = l.requestStream(320, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13126,7 +13127,7 @@ func (l *Libvirt) DomainEventCallbackWatchdog() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(321, constants.Program, buf)
+	_, err = l.requestStream(321, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13139,7 +13140,7 @@ func (l *Libvirt) DomainEventCallbackIOError() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(322, constants.Program, buf)
+	_, err = l.requestStream(322, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13152,7 +13153,7 @@ func (l *Libvirt) DomainEventCallbackGraphics() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(323, constants.Program, buf)
+	_, err = l.requestStream(323, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13165,7 +13166,7 @@ func (l *Libvirt) DomainEventCallbackIOErrorReason() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(324, constants.Program, buf)
+	_, err = l.requestStream(324, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13178,7 +13179,7 @@ func (l *Libvirt) DomainEventCallbackControlError() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(325, constants.Program, buf)
+	_, err = l.requestStream(325, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13191,7 +13192,7 @@ func (l *Libvirt) DomainEventCallbackBlockJob() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(326, constants.Program, buf)
+	_, err = l.requestStream(326, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13204,7 +13205,7 @@ func (l *Libvirt) DomainEventCallbackDiskChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(327, constants.Program, buf)
+	_, err = l.requestStream(327, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13217,7 +13218,7 @@ func (l *Libvirt) DomainEventCallbackTrayChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(328, constants.Program, buf)
+	_, err = l.requestStream(328, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13230,7 +13231,7 @@ func (l *Libvirt) DomainEventCallbackPmwakeup() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(329, constants.Program, buf)
+	_, err = l.requestStream(329, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13243,7 +13244,7 @@ func (l *Libvirt) DomainEventCallbackPmsuspend() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(330, constants.Program, buf)
+	_, err = l.requestStream(330, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13256,7 +13257,7 @@ func (l *Libvirt) DomainEventCallbackBalloonChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(331, constants.Program, buf)
+	_, err = l.requestStream(331, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13269,7 +13270,7 @@ func (l *Libvirt) DomainEventCallbackPmsuspendDisk() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(332, constants.Program, buf)
+	_, err = l.requestStream(332, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13282,7 +13283,7 @@ func (l *Libvirt) DomainEventCallbackDeviceRemoved() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(333, constants.Program, buf)
+	_, err = l.requestStream(333, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13307,7 +13308,7 @@ func (l *Libvirt) DomainCoreDumpWithFormat(Dom Domain, To string, Dumpformat uin
 	}
 
 
-	_, err = l.request(334, constants.Program, buf)
+	_, err = l.requestStream(334, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13331,7 +13332,7 @@ func (l *Libvirt) DomainFsfreeze(Dom Domain, Mountpoints []string, Flags uint32)
 	}
 
 	var r response
-	r, err = l.request(335, constants.Program, buf)
+	r, err = l.requestStream(335, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13364,7 +13365,7 @@ func (l *Libvirt) DomainFsthaw(Dom Domain, Mountpoints []string, Flags uint32) (
 	}
 
 	var r response
-	r, err = l.request(336, constants.Program, buf)
+	r, err = l.requestStream(336, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13396,7 +13397,7 @@ func (l *Libvirt) DomainGetTime(Dom Domain, Flags uint32) (rSeconds int64, rNsec
 	}
 
 	var r response
-	r, err = l.request(337, constants.Program, buf)
+	r, err = l.requestStream(337, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13435,7 +13436,7 @@ func (l *Libvirt) DomainSetTime(Dom Domain, Seconds int64, Nseconds uint32, Flag
 	}
 
 
-	_, err = l.request(338, constants.Program, buf)
+	_, err = l.requestStream(338, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13448,7 +13449,7 @@ func (l *Libvirt) DomainEventBlockJob2() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(339, constants.Program, buf)
+	_, err = l.requestStream(339, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13473,7 +13474,7 @@ func (l *Libvirt) NodeGetFreePages(Pages []uint32, StartCell int32, CellCount ui
 	}
 
 	var r response
-	r, err = l.request(340, constants.Program, buf)
+	r, err = l.requestStream(340, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13507,7 +13508,7 @@ func (l *Libvirt) NetworkGetDhcpLeases(Net Network, Mac OptString, NeedResults i
 	}
 
 	var r response
-	r, err = l.request(341, constants.Program, buf)
+	r, err = l.requestStream(341, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13547,7 +13548,7 @@ func (l *Libvirt) ConnectGetDomainCapabilities(Emulatorbin OptString, Arch OptSt
 	}
 
 	var r response
-	r, err = l.request(342, constants.Program, buf)
+	r, err = l.requestStream(342, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13580,7 +13581,7 @@ func (l *Libvirt) DomainOpenGraphicsFd(Dom Domain, Idx uint32, Flags DomainOpenG
 	}
 
 
-	_, err = l.request(343, constants.Program, buf)
+	_, err = l.requestStream(343, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13604,7 +13605,7 @@ func (l *Libvirt) ConnectGetAllDomainStats(Doms []Domain, Stats uint32, Flags Co
 	}
 
 	var r response
-	r, err = l.request(344, constants.Program, buf)
+	r, err = l.requestStream(344, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13639,7 +13640,7 @@ func (l *Libvirt) DomainBlockCopy(Dom Domain, Path string, Destxml string, Param
 	}
 
 
-	_, err = l.request(345, constants.Program, buf)
+	_, err = l.requestStream(345, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13652,7 +13653,7 @@ func (l *Libvirt) DomainEventCallbackTunable() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(346, constants.Program, buf)
+	_, err = l.requestStream(346, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13678,7 +13679,7 @@ func (l *Libvirt) NodeAllocPages(PageSizes []uint32, PageCounts []uint64, StartC
 	}
 
 	var r response
-	r, err = l.request(347, constants.Program, buf)
+	r, err = l.requestStream(347, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13700,7 +13701,7 @@ func (l *Libvirt) DomainEventCallbackAgentLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(348, constants.Program, buf)
+	_, err = l.requestStream(348, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13723,7 +13724,7 @@ func (l *Libvirt) DomainGetFsinfo(Dom Domain, Flags uint32) (rInfo []DomainFsinf
 	}
 
 	var r response
-	r, err = l.request(349, constants.Program, buf)
+	r, err = l.requestStream(349, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13760,7 +13761,7 @@ func (l *Libvirt) DomainDefineXMLFlags(XML string, Flags DomainDefineFlags) (rDo
 	}
 
 	var r response
-	r, err = l.request(350, constants.Program, buf)
+	r, err = l.requestStream(350, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13792,7 +13793,7 @@ func (l *Libvirt) DomainGetIothreadInfo(Dom Domain, Flags DomainModificationImpa
 	}
 
 	var r response
-	r, err = l.request(351, constants.Program, buf)
+	r, err = l.requestStream(351, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13831,7 +13832,7 @@ func (l *Libvirt) DomainPinIothread(Dom Domain, IothreadsID uint32, Cpumap []byt
 	}
 
 
-	_, err = l.request(352, constants.Program, buf)
+	_, err = l.requestStream(352, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13855,7 +13856,7 @@ func (l *Libvirt) DomainInterfaceAddresses(Dom Domain, Source uint32, Flags uint
 	}
 
 	var r response
-	r, err = l.request(353, constants.Program, buf)
+	r, err = l.requestStream(353, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13877,7 +13878,7 @@ func (l *Libvirt) DomainEventCallbackDeviceAdded() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(354, constants.Program, buf)
+	_, err = l.requestStream(354, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13901,7 +13902,7 @@ func (l *Libvirt) DomainAddIothread(Dom Domain, IothreadID uint32, Flags DomainM
 	}
 
 
-	_, err = l.request(355, constants.Program, buf)
+	_, err = l.requestStream(355, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13925,7 +13926,7 @@ func (l *Libvirt) DomainDelIothread(Dom Domain, IothreadID uint32, Flags DomainM
 	}
 
 
-	_, err = l.request(356, constants.Program, buf)
+	_, err = l.requestStream(356, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13950,7 +13951,7 @@ func (l *Libvirt) DomainSetUserPassword(Dom Domain, User OptString, Password Opt
 	}
 
 
-	_, err = l.request(357, constants.Program, buf)
+	_, err = l.requestStream(357, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13974,7 +13975,7 @@ func (l *Libvirt) DomainRename(Dom Domain, NewName OptString, Flags uint32) (rRe
 	}
 
 	var r response
-	r, err = l.request(358, constants.Program, buf)
+	r, err = l.requestStream(358, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -13996,7 +13997,7 @@ func (l *Libvirt) DomainEventCallbackMigrationIteration() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(359, constants.Program, buf)
+	_, err = l.requestStream(359, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14009,7 +14010,7 @@ func (l *Libvirt) ConnectRegisterCloseCallback() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(360, constants.Program, buf)
+	_, err = l.requestStream(360, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14022,7 +14023,7 @@ func (l *Libvirt) ConnectUnregisterCloseCallback() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(361, constants.Program, buf)
+	_, err = l.requestStream(361, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14035,7 +14036,7 @@ func (l *Libvirt) ConnectEventConnectionClosed() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(362, constants.Program, buf)
+	_, err = l.requestStream(362, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14048,7 +14049,7 @@ func (l *Libvirt) DomainEventCallbackJobCompleted() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(363, constants.Program, buf)
+	_, err = l.requestStream(363, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14071,7 +14072,7 @@ func (l *Libvirt) DomainMigrateStartPostCopy(Dom Domain, Flags uint32) (err erro
 	}
 
 
-	_, err = l.request(364, constants.Program, buf)
+	_, err = l.requestStream(364, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14094,7 +14095,7 @@ func (l *Libvirt) DomainGetPerfEvents(Dom Domain, Flags DomainModificationImpact
 	}
 
 	var r response
-	r, err = l.request(365, constants.Program, buf)
+	r, err = l.requestStream(365, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14128,7 +14129,7 @@ func (l *Libvirt) DomainSetPerfEvents(Dom Domain, Params []TypedParam, Flags Dom
 	}
 
 
-	_, err = l.request(366, constants.Program, buf)
+	_, err = l.requestStream(366, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14141,7 +14142,7 @@ func (l *Libvirt) DomainEventCallbackDeviceRemovalFailed() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(367, constants.Program, buf)
+	_, err = l.requestStream(367, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14164,7 +14165,7 @@ func (l *Libvirt) ConnectStoragePoolEventRegisterAny(EventID int32, Pool OptStor
 	}
 
 	var r response
-	r, err = l.request(368, constants.Program, buf)
+	r, err = l.requestStream(368, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14195,7 +14196,7 @@ func (l *Libvirt) ConnectStoragePoolEventDeregisterAny(CallbackID int32) (err er
 	}
 
 
-	_, err = l.request(369, constants.Program, buf)
+	_, err = l.requestStream(369, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14208,7 +14209,7 @@ func (l *Libvirt) StoragePoolEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(370, constants.Program, buf)
+	_, err = l.requestStream(370, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14231,7 +14232,7 @@ func (l *Libvirt) DomainGetGuestVcpus(Dom Domain, Flags uint32) (rParams []Typed
 	}
 
 	var r response
-	r, err = l.request(371, constants.Program, buf)
+	r, err = l.requestStream(371, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14266,7 +14267,7 @@ func (l *Libvirt) DomainSetGuestVcpus(Dom Domain, Cpumap string, State int32, Fl
 	}
 
 
-	_, err = l.request(372, constants.Program, buf)
+	_, err = l.requestStream(372, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14279,7 +14280,7 @@ func (l *Libvirt) StoragePoolEventRefresh() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(373, constants.Program, buf)
+	_, err = l.requestStream(373, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14302,7 +14303,7 @@ func (l *Libvirt) ConnectNodeDeviceEventRegisterAny(EventID int32, Dev OptNodeDe
 	}
 
 	var r response
-	r, err = l.request(374, constants.Program, buf)
+	r, err = l.requestStream(374, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14333,7 +14334,7 @@ func (l *Libvirt) ConnectNodeDeviceEventDeregisterAny(CallbackID int32) (err err
 	}
 
 
-	_, err = l.request(375, constants.Program, buf)
+	_, err = l.requestStream(375, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14346,7 +14347,7 @@ func (l *Libvirt) NodeDeviceEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(376, constants.Program, buf)
+	_, err = l.requestStream(376, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14359,7 +14360,7 @@ func (l *Libvirt) NodeDeviceEventUpdate() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(377, constants.Program, buf)
+	_, err = l.requestStream(377, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14382,7 +14383,7 @@ func (l *Libvirt) StorageVolGetInfoFlags(Vol StorageVol, Flags uint32) (rType in
 	}
 
 	var r response
-	r, err = l.request(378, constants.Program, buf)
+	r, err = l.requestStream(378, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14414,7 +14415,7 @@ func (l *Libvirt) DomainEventCallbackMetadataChange() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(379, constants.Program, buf)
+	_, err = l.requestStream(379, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14437,7 +14438,7 @@ func (l *Libvirt) ConnectSecretEventRegisterAny(EventID int32, OptSecret OptSecr
 	}
 
 	var r response
-	r, err = l.request(380, constants.Program, buf)
+	r, err = l.requestStream(380, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14468,7 +14469,7 @@ func (l *Libvirt) ConnectSecretEventDeregisterAny(CallbackID int32) (err error)
 	}
 
 
-	_, err = l.request(381, constants.Program, buf)
+	_, err = l.requestStream(381, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14481,7 +14482,7 @@ func (l *Libvirt) SecretEventLifecycle() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(382, constants.Program, buf)
+	_, err = l.requestStream(382, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14494,7 +14495,7 @@ func (l *Libvirt) SecretEventValueChanged() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(383, constants.Program, buf)
+	_, err = l.requestStream(383, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14519,7 +14520,7 @@ func (l *Libvirt) DomainSetVcpu(Dom Domain, Cpumap string, State int32, Flags Do
 	}
 
 
-	_, err = l.request(384, constants.Program, buf)
+	_, err = l.requestStream(384, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14532,7 +14533,7 @@ func (l *Libvirt) DomainEventBlockThreshold() (err error) {
 	var buf []byte
 
 
-	_, err = l.request(385, constants.Program, buf)
+	_, err = l.requestStream(385, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14557,7 +14558,7 @@ func (l *Libvirt) DomainSetBlockThreshold(Dom Domain, Dev string, Threshold uint
 	}
 
 
-	_, err = l.request(386, constants.Program, buf)
+	_, err = l.requestStream(386, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14580,7 +14581,7 @@ func (l *Libvirt) DomainMigrateGetMaxDowntime(Dom Domain, Flags uint32) (rDownti
 	}
 
 	var r response
-	r, err = l.request(387, constants.Program, buf)
+	r, err = l.requestStream(387, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14612,7 +14613,7 @@ func (l *Libvirt) DomainManagedSaveGetXMLDesc(Dom Domain, Flags DomainXMLFlags)
 	}
 
 	var r response
-	r, err = l.request(388, constants.Program, buf)
+	r, err = l.requestStream(388, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14645,7 +14646,7 @@ func (l *Libvirt) DomainManagedSaveDefineXML(Dom Domain, Dxml OptString, Flags D
 	}
 
 
-	_, err = l.request(389, constants.Program, buf)
+	_, err = l.requestStream(389, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}
@@ -14670,7 +14671,7 @@ func (l *Libvirt) DomainSetLifecycleAction(Dom Domain, Type uint32, Action uint3
 	}
 
 
-	_, err = l.request(390, constants.Program, buf)
+	_, err = l.requestStream(390, constants.Program, buf, nil, nil)
 	if err != nil {
 		return
 	}