Deuxfleurs/garage
48
56
Fork 73
Code Issues 100 Pull requests 13 Releases 30 Wiki Activity

K2V #293

Merged
lx merged 68 commits from k2v into main 2022-05-10 11:16:58 +00:00
Conversation 0 Commits 68 Files changed 83 +2 -2
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit cc8b13f808 - Show all commits

4
src/model/index_counter.rs
View file

@ -179,7 +179,7 @@ impl<T: CounterSchema> IndexCounter<T> {
let pk = pk.clone(); let pk = pk.clone();
let sk = sk.clone(); let sk = sk.clone();
tokio::spawn(async move { tokio::spawn(async move {
let dist_entry = new_entry.to_counter_entry::<T>(this_node, pk, sk); let dist_entry = new_entry.into_counter_entry::<T>(this_node, pk, sk);
if let Err(e) = table.insert(&dist_entry).await { if let Err(e) = table.insert(&dist_entry).await {
warn!("({}) Could not propagate counter value: {}", T::NAME, e); warn!("({}) Could not propagate counter value: {}", T::NAME, e);
} }
@ -195,7 +195,7 @@ struct LocalCounterEntry {
} }
impl LocalCounterEntry { impl LocalCounterEntry {
fn to_counter_entry<T: CounterSchema>( fn into_counter_entry<T: CounterSchema>(
self, self,
this_node: Uuid, this_node: Uuid,
pk: T::P, pk: T::P,