提交 ca94dbc7 编写于 作者: K Kevin Wolf 提交者: Anthony Liguori

qemu-io: Implement bdrv_load_vmstate/bdrv_save_vmstate

The load_vmstate and save_vmstate functions are implemented as a
variation of the normal read/write operation, enabled by the -b option.
This is the same mechanism as is used to switch from read/write to
pread/pwrite.
Signed-off-by: NKevin Wolf <kwolf@redhat.com>
Signed-off-by: NAnthony Liguori <aliguori@us.ibm.com>
上级 bf4e5d92
...@@ -187,6 +187,22 @@ static int do_pwrite(char *buf, int64_t offset, int count, int *total) ...@@ -187,6 +187,22 @@ static int do_pwrite(char *buf, int64_t offset, int count, int *total)
return 1; return 1;
} }
static int do_load_vmstate(char *buf, int64_t offset, int count, int *total)
{
*total = bdrv_load_vmstate(bs, (uint8_t *)buf, offset, count);
if (*total < 0)
return *total;
return 1;
}
static int do_save_vmstate(char *buf, int64_t offset, int count, int *total)
{
*total = bdrv_save_vmstate(bs, (uint8_t *)buf, offset, count);
if (*total < 0)
return *total;
return 1;
}
#define NOT_DONE 0x7fffffff #define NOT_DONE 0x7fffffff
static void aio_rw_done(void *opaque, int ret) static void aio_rw_done(void *opaque, int ret)
{ {
...@@ -242,6 +258,7 @@ read_help(void) ...@@ -242,6 +258,7 @@ read_help(void)
"\n" "\n"
" Reads a segment of the currently open file, optionally dumping it to the\n" " Reads a segment of the currently open file, optionally dumping it to the\n"
" standard output stream (with -v option) for subsequent inspection.\n" " standard output stream (with -v option) for subsequent inspection.\n"
" -b, -- read from the VM state rather than the virtual disk\n"
" -C, -- report statistics in a machine parsable format\n" " -C, -- report statistics in a machine parsable format\n"
" -l, -- length for pattern verification (only with -P)\n" " -l, -- length for pattern verification (only with -P)\n"
" -p, -- use bdrv_pread to read the file\n" " -p, -- use bdrv_pread to read the file\n"
...@@ -257,7 +274,7 @@ read_f(int argc, char **argv) ...@@ -257,7 +274,7 @@ read_f(int argc, char **argv)
{ {
struct timeval t1, t2; struct timeval t1, t2;
int Cflag = 0, pflag = 0, qflag = 0, vflag = 0; int Cflag = 0, pflag = 0, qflag = 0, vflag = 0;
int Pflag = 0, sflag = 0, lflag = 0; int Pflag = 0, sflag = 0, lflag = 0, bflag = 0;
int c, cnt; int c, cnt;
char *buf; char *buf;
int64_t offset; int64_t offset;
...@@ -266,8 +283,11 @@ read_f(int argc, char **argv) ...@@ -266,8 +283,11 @@ read_f(int argc, char **argv)
int total = 0; int total = 0;
int pattern = 0, pattern_offset = 0, pattern_count = 0; int pattern = 0, pattern_offset = 0, pattern_count = 0;
while ((c = getopt(argc, argv, "Cl:pP:qs:v")) != EOF) { while ((c = getopt(argc, argv, "bCl:pP:qs:v")) != EOF) {
switch (c) { switch (c) {
case 'b':
bflag = 1;
break;
case 'C': case 'C':
Cflag = 1; Cflag = 1;
break; break;
...@@ -308,6 +328,11 @@ read_f(int argc, char **argv) ...@@ -308,6 +328,11 @@ read_f(int argc, char **argv)
if (optind != argc - 2) if (optind != argc - 2)
return command_usage(&read_cmd); return command_usage(&read_cmd);
if (bflag && pflag) {
printf("-b and -p cannot be specified at the same time\n");
return 0;
}
offset = cvtnum(argv[optind]); offset = cvtnum(argv[optind]);
if (offset < 0) { if (offset < 0) {
printf("non-numeric length argument -- %s\n", argv[optind]); printf("non-numeric length argument -- %s\n", argv[optind]);
...@@ -352,6 +377,8 @@ read_f(int argc, char **argv) ...@@ -352,6 +377,8 @@ read_f(int argc, char **argv)
gettimeofday(&t1, NULL); gettimeofday(&t1, NULL);
if (pflag) if (pflag)
cnt = do_pread(buf, offset, count, &total); cnt = do_pread(buf, offset, count, &total);
else if (bflag)
cnt = do_load_vmstate(buf, offset, count, &total);
else else
cnt = do_read(buf, offset, count, &total); cnt = do_read(buf, offset, count, &total);
gettimeofday(&t2, NULL); gettimeofday(&t2, NULL);
...@@ -394,7 +421,7 @@ static const cmdinfo_t read_cmd = { ...@@ -394,7 +421,7 @@ static const cmdinfo_t read_cmd = {
.cfunc = read_f, .cfunc = read_f,
.argmin = 2, .argmin = 2,
.argmax = -1, .argmax = -1,
.args = "[-aCpqv] [-P pattern [-s off] [-l len]] off len", .args = "[-abCpqv] [-P pattern [-s off] [-l len]] off len",
.oneline = "reads a number of bytes at a specified offset", .oneline = "reads a number of bytes at a specified offset",
.help = read_help, .help = read_help,
}; };
...@@ -534,6 +561,7 @@ write_help(void) ...@@ -534,6 +561,7 @@ write_help(void)
"\n" "\n"
" Writes into a segment of the currently open file, using a buffer\n" " Writes into a segment of the currently open file, using a buffer\n"
" filled with a set pattern (0xcdcdcdcd).\n" " filled with a set pattern (0xcdcdcdcd).\n"
" -b, -- write to the VM state rather than the virtual disk\n"
" -p, -- use bdrv_pwrite to write the file\n" " -p, -- use bdrv_pwrite to write the file\n"
" -P, -- use different pattern to fill file\n" " -P, -- use different pattern to fill file\n"
" -C, -- report statistics in a machine parsable format\n" " -C, -- report statistics in a machine parsable format\n"
...@@ -545,7 +573,7 @@ static int ...@@ -545,7 +573,7 @@ static int
write_f(int argc, char **argv) write_f(int argc, char **argv)
{ {
struct timeval t1, t2; struct timeval t1, t2;
int Cflag = 0, pflag = 0, qflag = 0; int Cflag = 0, pflag = 0, qflag = 0, bflag = 0;
int c, cnt; int c, cnt;
char *buf; char *buf;
int64_t offset; int64_t offset;
...@@ -554,8 +582,11 @@ write_f(int argc, char **argv) ...@@ -554,8 +582,11 @@ write_f(int argc, char **argv)
int total = 0; int total = 0;
int pattern = 0xcd; int pattern = 0xcd;
while ((c = getopt(argc, argv, "CpP:q")) != EOF) { while ((c = getopt(argc, argv, "bCpP:q")) != EOF) {
switch (c) { switch (c) {
case 'b':
bflag = 1;
break;
case 'C': case 'C':
Cflag = 1; Cflag = 1;
break; break;
...@@ -576,6 +607,11 @@ write_f(int argc, char **argv) ...@@ -576,6 +607,11 @@ write_f(int argc, char **argv)
if (optind != argc - 2) if (optind != argc - 2)
return command_usage(&write_cmd); return command_usage(&write_cmd);
if (bflag && pflag) {
printf("-b and -p cannot be specified at the same time\n");
return 0;
}
offset = cvtnum(argv[optind]); offset = cvtnum(argv[optind]);
if (offset < 0) { if (offset < 0) {
printf("non-numeric length argument -- %s\n", argv[optind]); printf("non-numeric length argument -- %s\n", argv[optind]);
...@@ -608,6 +644,8 @@ write_f(int argc, char **argv) ...@@ -608,6 +644,8 @@ write_f(int argc, char **argv)
gettimeofday(&t1, NULL); gettimeofday(&t1, NULL);
if (pflag) if (pflag)
cnt = do_pwrite(buf, offset, count, &total); cnt = do_pwrite(buf, offset, count, &total);
else if (bflag)
cnt = do_save_vmstate(buf, offset, count, &total);
else else
cnt = do_write(buf, offset, count, &total); cnt = do_write(buf, offset, count, &total);
gettimeofday(&t2, NULL); gettimeofday(&t2, NULL);
...@@ -636,7 +674,7 @@ static const cmdinfo_t write_cmd = { ...@@ -636,7 +674,7 @@ static const cmdinfo_t write_cmd = {
.cfunc = write_f, .cfunc = write_f,
.argmin = 2, .argmin = 2,
.argmax = -1, .argmax = -1,
.args = "[-aCpq] [-P pattern ] off len", .args = "[-abCpq] [-P pattern ] off len",
.oneline = "writes a number of bytes at a specified offset", .oneline = "writes a number of bytes at a specified offset",
.help = write_help, .help = write_help,
}; };
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册