diff --git a/coordinator/src/db.rs b/coordinator/src/db.rs index 5784a5ff..77a12d8a 100644 --- a/coordinator/src/db.rs +++ b/coordinator/src/db.rs @@ -57,7 +57,7 @@ impl<D: Db> MainDb<D> { (bytes, tributaries) } - pub fn add_active_tributary(txn: &mut D::Transaction<'_>, spec: &TributarySpec) { + pub fn add_participating_in_tributary(txn: &mut D::Transaction<'_>, spec: &TributarySpec) { txn.put(Self::in_tributary_key(spec.set()), []); let key = Self::active_tributaries_key(); diff --git a/coordinator/src/substrate/mod.rs b/coordinator/src/substrate/mod.rs index ce4e7c4a..d25125a9 100644 --- a/coordinator/src/substrate/mod.rs +++ b/coordinator/src/substrate/mod.rs @@ -116,7 +116,7 @@ async fn handle_new_set<D: Db>( // If this txn doesn't finish, this will be re-fired // If we waited to save to the DB, this txn may be finished, preventing re-firing, yet the // prior fired event may have not been received yet - crate::MainDb::<D>::add_active_tributary(txn, &spec); + crate::MainDb::<D>::add_participating_in_tributary(txn, &spec); new_tributary_spec.send(spec).unwrap(); } else {