Commit dfe55ed2 authored by Daniel P. Berrange's avatar Daniel P. Berrange

Add examples for using streams with storage volume upload/download

parent 2066677a
#!/usr/bin/perl
use strict;
use warnings;
use Sys::Virt;
my $c = Sys::Virt->new(uri => "qemu:///session");
my $st = $c->new_stream();
die "syntax: $0 VOL-PATH OUTPUT-FILE" unless int(@ARGV) == 2;
my $volpath = shift @ARGV;
my $f = shift @ARGV;
my $vol = $c->get_storage_volume_by_path($volpath);
open FILE, ">$f" or die "cannot create $f: $!";
sub foo {
my $st = shift;
my $data = shift;
my $nbytes = shift;
return syswrite FILE, $data, $nbytes;
};
eval {
$vol->download($st, 0, 0);
$st->recv_all(\&foo);
$st->finish();
};
if ($@) {
unlink $f if $@;
close FILE;
die $@;
}
close FILE or die "cannot save $f: $!";
#!/usr/bin/perl
use strict;
use warnings;
use Sys::Virt;
Sys::Virt::Event::register_default();
my $c = Sys::Virt->new(uri => "qemu:///session");
my $st = $c->new_stream(Sys::Virt::Stream::NONBLOCK);
die "syntax: $0 VOL-PATH OUTPUT-FILE" unless int(@ARGV) == 2;
my $volpath = shift @ARGV;
my $f = shift @ARGV;
my $vol = $c->get_storage_volume_by_path($volpath);
my $quit = 0;
open FILE, ">$f" or die "cannot create $f: $!";
sub streamevent {
my $st = shift;
my $events = shift;
if ($events & (Sys::Virt::Stream::EVENT_HANGUP |
Sys::Virt::Stream::EVENT_ERROR)) {
$quit = 1;
return;
}
my $data;
my $rv = $st->recv($data, 1024);
if ($rv == 0) {
$quit = 1;
$st->remove_callback();
return;
}
while ($rv > 0) {
my $ret = syswrite FILE, $data, $rv;
$data = substr $data, $ret;
$rv -= $ret;
}
}
eval {
$vol->download($st, 0, 0);
$st->add_callback(Sys::Virt::Stream::EVENT_READABLE, \&streamevent);
while (!$quit) {
Sys::Virt::Event::run_default();
}
$st->finish();
};
if ($@) {
unlink $f if $@;
close FILE;
die $@;
}
close FILE or die "cannot save $f: $!";
#!/usr/bin/perl
use strict;
use warnings;
use Sys::Virt;
my $c = Sys::Virt->new(uri => "qemu:///session");
my $st = $c->new_stream();
die "syntax: $0 VOL-PATH OUTPUT-FILE" unless int(@ARGV) == 2;
my $volpath = shift @ARGV;
my $f = shift @ARGV;
my $vol = $c->get_storage_volume_by_path($volpath);
open FILE, ">$f" or die "cannot create $f: $!";
eval {
$vol->download($st, 0, 0);
while (1) {
my $nbytes = 1024;
my $data;
my $rv = $st->recv($data, $nbytes);
last if $rv == 0;
while ($rv > 0) {
my $done = syswrite FILE, $data, $rv;
if ($done) {
$data = substr $data, $done;
$rv -= $done;
}
}
}
$st->finish();
};
if ($@) {
unlink $f if $@;
close FILE;
die $@;
}
close FILE or die "cannot save $f: $!";
#!/usr/bin/perl
use strict;
use warnings;
use Sys::Virt;
my $c = Sys::Virt->new(uri => "qemu:///session");
my $st = $c->new_stream();
die "syntax: $0 VOL-PATH INPUT-FILE" unless int(@ARGV) == 2;
my $volpath = shift @ARGV;
my $f = shift @ARGV;
my $vol = $c->get_storage_volume_by_path($volpath);
open FILE, "<$f" or die "cannot open $f: $!";
sub foo {
my $st = shift;
my $data = shift;
my $nbytes = shift;
return sysread FILE, $data, $nbytes;
};
eval {
$vol->upload($st, 0, 0);
$st->send_all(\&foo);
$st->finish();
};
if ($@) {
close FILE;
die $@;
}
close FILE or die "cannot save $f: $!";
#!/usr/bin/perl
use strict;
use warnings;
use Sys::Virt;
Sys::Virt::Event::register_default();
my $c = Sys::Virt->new(uri => "qemu:///session");
my $st = $c->new_stream(Sys::Virt::Stream::NONBLOCK);
die "syntax: $0 VOL-PATH INPUT-FILE" unless int(@ARGV) == 2;
my $volpath = shift @ARGV;
my $f = shift @ARGV;
my $vol = $c->get_storage_volume_by_path($volpath);
my $quit = 0;
open FILE, "<$f" or die "cannot open $f: $!";
my $nextdata;
my $nextdatalen;
sub moredata {
return if $nextdatalen;
$nextdatalen = sysread FILE, $nextdata, 1024;
}
sub streamevent {
my $st = shift;
my $events = shift;
if ($events & (Sys::Virt::Stream::EVENT_HANGUP |
Sys::Virt::Stream::EVENT_ERROR)) {
$quit = 1;
return;
}
&moredata;
if ($nextdatalen == 0) {
$quit = 1;
$st->remove_callback();
return;
}
my $rv = $st->send($nextdata, $nextdatalen);
if ($rv > 0) {
$nextdata = substr $nextdata, $rv;
$nextdatalen -= $rv;
}
}
eval {
$vol->upload($st, 0, 0);
$st->add_callback(Sys::Virt::Stream::EVENT_WRITABLE, \&streamevent);
while (!$quit) {
Sys::Virt::Event::run_default();
}
$st->finish();
};
if ($@) {
close FILE;
die $@;
}
close FILE or die "cannot save $f: $!";
#!/usr/bin/perl
use strict;
use warnings;
use Sys::Virt;
my $c = Sys::Virt->new(uri => "qemu:///session");
my $st = $c->new_stream();
die "syntax: $0 VOL-PATH INPUT-FILE" unless int(@ARGV) == 2;
my $volpath = shift @ARGV;
my $f = shift @ARGV;
my $vol = $c->get_storage_volume_by_path($volpath);
open FILE, "<$f" or die "cannot open $f: $!";
eval {
$vol->upload($st, 0, 0);
while (1) {
my $nbytes = 1024;
my $data;
my $rv = sysread FILE, $data, $nbytes;
if ($rv < 0) {
die "cannot read $f: $!";
}
last if $rv == 0;
while ($rv > 0) {
my $done = $st->send($data, $rv);
if ($done) {
$data = substr $data, $done;
$rv -= $done;
}
}
}
$st->finish();
};
if ($@) {
close FILE;
die $@;
}
close FILE or die "cannot save $f: $!";
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment