shaba/libvirt
1
0
Fork 0
mirror of https://gitlab.com/libvirt/libvirt.git synced 2025-03-30 18:50:18 +03:00
Code Releases Activity

qemu: agent: Differentiate timeouts when syncing from command timeout

Browse Source 
As the guest agent code uses timeouts it is possible that we stop
waiting before the guest agent replies. If this happens while syncing
everything is okay because we didn't send any state-changing command.

In case when the timeout happens after a real command was transmitted
it's unknown if the guest-agent processed it or not.

Use the new special error code VIR_ERR_AGENT_COMMAND_TIMEOUT for cases
when we sent non-sync commands, so that the management applications or
users have possibility to react to this situation.

Signed-off-by: Peter Krempa <pkrempa@redhat.com>
Reviewed-by: Ján Tomko <jtomko@redhat.com>
This commit is contained in:
Peter Krempa 2025-03-20 15:17:11 +01:00
parent ae499e4536
commit 305e91dc21
1 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/qemu/qemu_agent.c
View File

@ -707,6 +707,7 @@ void qemuAgentClose(qemuAgent *agent)
* @msg: Message
* @seconds: number of seconds to wait for the result, it can be either
* -2, -1, 0 or positive.
* @report_sync: On timeout; report synchronization error instead of the normal error
*
* Send @msg to agent @agent. If @seconds is equal to
* VIR_DOMAIN_QEMU_AGENT_COMMAND_BLOCK(-2), this function will block forever
@ -720,9 +721,11 @@ void qemuAgentClose(qemuAgent *agent)
* -2 on timeout,
* -1 otherwise
*/
static int qemuAgentSend(qemuAgent *agent,
qemuAgentMessage *msg,
int seconds)
static int
qemuAgentSend(qemuAgent *agent,
qemuAgentMessage *msg,
int seconds,
bool report_sync)
{
int ret = -1;
unsigned long long then = 0;
@ -751,8 +754,15 @@ static int qemuAgentSend(qemuAgent *agent,
if ((then && virCondWaitUntil(&agent->notify, &agent->parent.lock, then) < 0) ||
(!then && virCondWait(&agent->notify, &agent->parent.lock) < 0)) {
if (errno == ETIMEDOUT) {
virReportError(VIR_ERR_AGENT_UNRESPONSIVE, "%s",
_("Guest agent not available for now"));
if (report_sync) {
virReportError(VIR_ERR_AGENT_UNRESPONSIVE,
_("guest agent didn't respond to synchronization within '%1$d' seconds"),
seconds);
} else {
virReportError(VIR_ERR_AGENT_COMMAND_TIMEOUT,
_("guest agent didn't respond to command within '%1$d' seconds"),
seconds);
}
ret = -2;
} else {
virReportSystemError(errno, "%s",
@ -817,7 +827,7 @@ qemuAgentGuestSyncSend(qemuAgent *agent,
VIR_DEBUG("Sending guest-sync command with ID: %llu", id);
rc = qemuAgentSend(agent, &sync_msg, timeout);
rc = qemuAgentSend(agent, &sync_msg, timeout, true);
rxObj = g_steal_pointer(&sync_msg.rxObject);
VIR_DEBUG("qemuAgentSend returned: %d", rc);
@ -1040,7 +1050,7 @@ qemuAgentCommandFull(qemuAgent *agent,
VIR_DEBUG("Send command '%s' for write, seconds = %d", cmdstr, seconds);
ret = qemuAgentSend(agent, &msg, seconds);
ret = qemuAgentSend(agent, &msg, seconds, false);
VIR_DEBUG("Receive command reply ret=%d rxObject=%p",
ret, msg.rxObject);