fix up stuff

Author: hawkw

nexus/src/app/mod.rs

@@ -202,6 +202,8 @@ pub struct Nexus {
     default_region_allocation_strategy: RegionAllocationStrategy,
 
     /// Channel for notifying background task of change to opte v2p state
+    #[allow(dead_code)]
+    // XXX(eliza) do we need this or can we just activate the background task?
     v2p_notification_tx: tokio::sync::watch::Sender<()>,
 }
 

nexus/src/app/sagas/instance_update/destroyed.rs

@@ -5,19 +5,15 @@
 use super::ActionRegistry;
 use super::NexusActionContext;
 use super::NexusSaga;
-use super::STATE;
 use crate::app::sagas::declare_saga_actions;
 use crate::app::sagas::ActionError;
 use nexus_db_model::Generation;
 use nexus_db_model::Instance;
 use nexus_db_model::InstanceRuntimeState;
-use nexus_db_model::Vmm;
 use nexus_db_queries::authn;
 use nexus_db_queries::authz;
-use nexus_db_queries::db::datastore::InstanceAndVmms;
 use omicron_common::api::external;
 use omicron_common::api::external::Error;
-use omicron_common::api::external::InstanceState;
 use serde::{Deserialize, Serialize};
 use slog::info;
 use uuid::Uuid;
@@ -81,7 +77,7 @@ pub(super) struct Params {
 }
 
 #[derive(Debug)]
-pub(crate) struct SagaVmmDestroyed;
+pub(super) struct SagaVmmDestroyed;
 impl NexusSaga for SagaVmmDestroyed {
     const NAME: &'static str = "instance-update-vmm-destroyed";
     type Params = Params;
@@ -106,18 +102,6 @@ impl NexusSaga for SagaVmmDestroyed {
     }
 }
 
-fn get_destroyed_vmm(
-    sagactx: &NexusActionContext,
-) -> Result<Option<(Instance, Vmm)>, ActionError> {
-    let state = sagactx.lookup::<InstanceAndVmms>(STATE)?;
-    match state.active_vmm {
-        Some(vmm) if vmm.runtime.state.state() == &InstanceState::Destroyed => {
-            Ok(Some((state.instance, vmm)))
-        }
-        _ => Ok(None),
-    }
-}
-
 async fn siud_release_sled_resources(
     sagactx: NexusActionContext,
 ) -> Result<(), ActionError> {

nexus/src/app/sagas/instance_update/mod.rs

@@ -9,7 +9,6 @@ use super::{
 use crate::app::db::datastore::InstanceAndVmms;
 use crate::app::sagas::declare_saga_actions;
 use nexus_db_queries::{authn, authz};
-use nexus_types::identity::Resource;
 use omicron_common::api::external::InstanceState;
 use serde::{Deserialize, Serialize};
 use steno::{ActionError, DagBuilder, Node, SagaName};
@@ -38,7 +37,6 @@ struct RealParams {
 }
 
 const INSTANCE_LOCK_ID: &str = "saga_instance_lock_id";
-const STATE: &str = "state";
 
 // instance update saga: actions
 
@@ -63,7 +61,7 @@ declare_saga_actions! {
     // Become the instance updater
     BECOME_UPDATER -> "generation" {
         + siu_become_updater
-        - siu_lock_instance_undo
+        - siu_unbecome_updater
     }
 
     UNLOCK_INSTANCE -> "unlocked" {
@@ -84,7 +82,7 @@ impl NexusSaga for SagaInstanceUpdate {
     }
 
     fn make_saga_dag(
-        params: &Self::Params,
+        _params: &Self::Params,
         mut builder: DagBuilder,
     ) -> Result<steno::Dag, super::SagaInitError> {
         builder.append(Node::action(
@@ -214,7 +212,7 @@ async fn siu_fetch_state_and_start_real_saga(
             state,
         })
         .await
-        .map_err(ActionError::action_failed);
+        .map_err(ActionError::action_failed)?;
 
     Ok(())
 }