mirror of
https://github.com/serai-dex/serai.git
synced 2025-12-08 12:19:24 +00:00
Rename add_active_tributary for clarity
This commit is contained in:
@@ -57,7 +57,7 @@ impl<D: Db> MainDb<D> {
|
|||||||
|
|
||||||
(bytes, tributaries)
|
(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()), []);
|
txn.put(Self::in_tributary_key(spec.set()), []);
|
||||||
|
|
||||||
let key = Self::active_tributaries_key();
|
let key = Self::active_tributaries_key();
|
||||||
|
|||||||
@@ -116,7 +116,7 @@ async fn handle_new_set<D: Db>(
|
|||||||
// If this txn doesn't finish, this will be re-fired
|
// 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
|
// 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
|
// 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();
|
new_tributary_spec.send(spec).unwrap();
|
||||||
} else {
|
} else {
|
||||||
|
|||||||
Reference in New Issue
Block a user