[libvirt] [ruby-libvirt 2/2] Add volume upload example

[Guido Günther]

---
 examples/upload_volume.rb | 36 ++++++++++++++++++++++++++++++++++++
 1 file changed, 36 insertions(+)
 create mode 100644 examples/upload_volume.rb

diff --git a/examples/upload_volume.rb b/examples/upload_volume.rb
new file mode 100644
index 0000000..a051d46
--- /dev/null
+++ b/examples/upload_volume.rb
@@ -0,0 +1,36 @@
+require 'libvirt'
+
+abort("No file to upload given") unless ARGV.length > 0
+
+file_path = ARGV[0]
+
+c = Libvirt::open("qemu:///system")
+
+vol_xml = <<EOF
+<volume>
+  <name>#{File.basename(file_path)}</name>
+  <allocation unit="G">0</allocation>
+  <capacity unit="b">#{File.size(file_path)}</capacity>
+</volume>
+EOF
+
+pool = c.lookup_storage_pool_by_name("default")
+volume = pool.create_volume_xml(vol_xml)
+stream = c.stream
+
+image_file = File.open(file_path, "rb")
+volume.upload(stream, 0, image_file.size)
+stream.sendall do |_opaque, n|
+begin
+  r = image_file.read(n)
+  # This works with and without 03f18670c79e6664fb424d6731f95ea2be4531f4
+  r ? [r.length, r] : [0, ""]
+  # This works with 03f18670c79e6664fb424d6731f95ea2be4531f4 and matches the
+  # docs
+  r ? [0, r] : [0, ""]
+  rescue Exception => e
+    $stderr.puts "Got exception #{e}"
+    [-1, ""]
+  end
+end
+stream.finish
-- 
2.8.1