unistack-org/go-libvirt-plain
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix volume download

Browse Source
This commit is contained in:
Yuriy Taraday 2018-05-06 00:56:50 +04:00
parent 7442c709b1
commit 9adcb04498
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
rpc.go
View File

@ -310,6 +310,10 @@ func (l *Libvirt) processIncomingStream(c chan response, inStream io.Writer) (re
} }
// StatusError is handled in getResponse, so this is StatusContinue // StatusError is handled in getResponse, so this is StatusContinue
// StatusContinue is valid here only for stream packets // StatusContinue is valid here only for stream packets
// libvirtd breaks protocol and returns StatusContinue with empty Payload when stream finishes
if len(resp.Payload) == 0 {
return resp, nil
}
if inStream != nil { if inStream != nil {
_, err = inStream.Write(resp.Payload) _, err = inStream.Write(resp.Payload)
if err != nil { if err != nil {