提交 39ba2ea6 编写于 作者: P Peter Xu 提交者: Paolo Bonzini

Dump: add qmp command "query-dump"

When dump-guest-memory is requested with detach flag, after its
return, user could query its status using "query-dump" command (with
no argument). The result contains:

- status: current dump status
- completed: bytes written in the latest dump
- total: bytes to write in the latest dump

From completed and total, we could know how much work
finished by calculating:

  100.0 * completed / total (%)
Reviewed-by: NFam Zheng <famz@redhat.com>
Signed-off-by: NPeter Xu <peterx@redhat.com>
Message-Id: <1455772616-8668-10-git-send-email-peterx@redhat.com>
Signed-off-by: NPaolo Bonzini <pbonzini@redhat.com>
上级 2264c2c9
...@@ -1456,7 +1456,7 @@ static void dump_state_prepare(DumpState *s) ...@@ -1456,7 +1456,7 @@ static void dump_state_prepare(DumpState *s)
bool dump_in_progress(void) bool dump_in_progress(void)
{ {
DumpState *state = &dump_state_global; DumpState *state = &dump_state_global;
return (state->status == DUMP_STATUS_ACTIVE); return (atomic_read(&state->status) == DUMP_STATUS_ACTIVE);
} }
/* calculate total size of memory to be dumped (taking filter into /* calculate total size of memory to be dumped (taking filter into
...@@ -1669,9 +1669,12 @@ static void dump_process(DumpState *s, Error **errp) ...@@ -1669,9 +1669,12 @@ static void dump_process(DumpState *s, Error **errp)
create_vmcore(s, &local_err); create_vmcore(s, &local_err);
} }
s->status = (local_err ? DUMP_STATUS_FAILED : DUMP_STATUS_COMPLETED); /* make sure status is written after written_size updates */
error_propagate(errp, local_err); smp_wmb();
atomic_set(&s->status,
(local_err ? DUMP_STATUS_FAILED : DUMP_STATUS_COMPLETED));
error_propagate(errp, local_err);
dump_cleanup(s); dump_cleanup(s);
} }
...@@ -1689,6 +1692,18 @@ static void *dump_thread(void *data) ...@@ -1689,6 +1692,18 @@ static void *dump_thread(void *data)
return NULL; return NULL;
} }
DumpQueryResult *qmp_query_dump(Error **errp)
{
DumpQueryResult *result = g_new(DumpQueryResult, 1);
DumpState *state = &dump_state_global;
result->status = atomic_read(&state->status);
/* make sure we are reading status and written_size in order */
smp_rmb();
result->completed = state->written_size;
result->total = state->total_size;
return result;
}
void qmp_dump_guest_memory(bool paging, const char *file, void qmp_dump_guest_memory(bool paging, const char *file,
bool has_detach, bool detach, bool has_detach, bool detach,
bool has_begin, int64_t begin, bool has_length, bool has_begin, int64_t begin, bool has_length,
...@@ -1779,7 +1794,7 @@ void qmp_dump_guest_memory(bool paging, const char *file, ...@@ -1779,7 +1794,7 @@ void qmp_dump_guest_memory(bool paging, const char *file,
begin, length, &local_err); begin, length, &local_err);
if (local_err) { if (local_err) {
error_propagate(errp, local_err); error_propagate(errp, local_err);
s->status = DUMP_STATUS_FAILED; atomic_set(&s->status, DUMP_STATUS_FAILED);
return; return;
} }
......
...@@ -2196,7 +2196,8 @@ ...@@ -2196,7 +2196,8 @@
# is the fd's name. # is the fd's name.
# #
# @detach: #optional if true, QMP will return immediately rather than # @detach: #optional if true, QMP will return immediately rather than
# waiting for the dump to finish. (since 2.6). # waiting for the dump to finish. The user can track progress
# using "query-dump". (since 2.6).
# #
# @begin: #optional if specified, the starting physical address. # @begin: #optional if specified, the starting physical address.
# #
...@@ -2236,6 +2237,35 @@ ...@@ -2236,6 +2237,35 @@
{ 'enum': 'DumpStatus', { 'enum': 'DumpStatus',
'data': [ 'none', 'active', 'completed', 'failed' ] } 'data': [ 'none', 'active', 'completed', 'failed' ] }
##
# @DumpQueryResult
#
# The result format for 'query-dump'.
#
# @status: enum of @DumpStatus, which shows current dump status
#
# @completed: bytes written in latest dump (uncompressed)
#
# @total: total bytes to be written in latest dump (uncompressed)
#
# Since 2.6
##
{ 'struct': 'DumpQueryResult',
'data': { 'status': 'DumpStatus',
'completed': 'int',
'total': 'int' } }
##
# @query-dump
#
# Query latest dump status.
#
# Returns: A @DumpStatus object showing the dump status.
#
# Since: 2.6
##
{ 'command': 'query-dump', 'returns': 'DumpQueryResult' }
## ##
# @DumpGuestMemoryCapability: # @DumpGuestMemoryCapability:
# #
......
...@@ -856,7 +856,8 @@ Arguments: ...@@ -856,7 +856,8 @@ Arguments:
- "protocol": destination file(started with "file:") or destination file - "protocol": destination file(started with "file:") or destination file
descriptor (started with "fd:") (json-string) descriptor (started with "fd:") (json-string)
- "detach": if specified, command will return immediately, without waiting - "detach": if specified, command will return immediately, without waiting
for the dump to finish (json-bool) for the dump to finish. The user can track progress using
"query-dump". (json-bool)
- "begin": the starting physical address. It's optional, and should be specified - "begin": the starting physical address. It's optional, and should be specified
with length together (json-int) with length together (json-int)
- "length": the memory size, in bytes. It's optional, and should be specified - "length": the memory size, in bytes. It's optional, and should be specified
...@@ -894,6 +895,30 @@ Example: ...@@ -894,6 +895,30 @@ Example:
<- { "return": { "formats": <- { "return": { "formats":
["elf", "kdump-zlib", "kdump-lzo", "kdump-snappy"] } ["elf", "kdump-zlib", "kdump-lzo", "kdump-snappy"] }
EQMP
{
.name = "query-dump",
.args_type = "",
.params = "",
.help = "query background dump status",
.mhandler.cmd_new = qmp_marshal_query_dump,
},
SQMP
query-dump
----------
Query background dump status.
Arguments: None.
Example:
-> { "execute": "query-dump" }
<- { "return": { "status": "active", "completed": 1024000,
"total": 2048000 } }
EQMP EQMP
#if defined TARGET_S390X #if defined TARGET_S390X
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册