updater #1
@ -151,18 +151,18 @@ async fn update_vm_request(
|
|||||||
dtrfs_url: "thisIsMyNewURL".to_string(),
|
dtrfs_url: "thisIsMyNewURL".to_string(),
|
||||||
dtrfs_sha: "thisIsMyNewSha".to_string(),
|
dtrfs_sha: "thisIsMyNewSha".to_string(),
|
||||||
};
|
};
|
||||||
info!("Creating VM {req:?}");
|
info!("Updating VM {req:?}");
|
||||||
let result = client.update_vm(req).await;
|
let result = client.update_vm(req).await;
|
||||||
match result {
|
match result {
|
||||||
Ok(confirmation) => {
|
Ok(confirmation) => {
|
||||||
let confirmation = confirmation.into_inner();
|
let confirmation = confirmation.into_inner();
|
||||||
if confirmation.error.is_empty() {
|
if confirmation.error.is_empty() {
|
||||||
info!("Got VM confirmation: {confirmation:?}");
|
info!("Got VM update confirmation: {confirmation:?}");
|
||||||
} else {
|
} else {
|
||||||
warn!("Got VM confirmation error: {}", confirmation.error);
|
warn!("Got VM update confirmation error: {}", confirmation.error);
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
Err(e) => log::error!("Could not create vm: {e:?}"),
|
Err(e) => log::error!("Could not update vm: {e:?}"),
|
||||||
};
|
};
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
@ -155,7 +155,7 @@ async fn handle_update_vm_requests(
|
|||||||
info!("Sending UpdateVmResp: {confirmation:?}");
|
info!("Sending UpdateVmResp: {confirmation:?}");
|
||||||
let _ = resp.send(confirmation).await;
|
let _ = resp.send(confirmation).await;
|
||||||
};
|
};
|
||||||
warn!("vm request handler is ending");
|
warn!("update vm request handler is ending");
|
||||||
}
|
}
|
||||||
|
|
||||||
async fn send_confirmations_update(
|
async fn send_confirmations_update(
|
||||||
|
Loading…
Reference in New Issue
Block a user