Skip to content

Commit 5d32c07

Browse files
committed
f include ms/ns time parts when decaying
1 parent 9d73fe6 commit 5d32c07

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

lightning/src/routing/scoring.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -1074,10 +1074,10 @@ impl<T: Time> ChannelLiquidity<T> {
10741074
}
10751075

10761076
fn decayed_offset(&self, offset: u64, decay_params: ProbabilisticScoringDecayParameters) -> u64 {
1077-
let half_life = decay_params.liquidity_offset_half_life.as_secs();
1078-
if half_life != 0 {
1079-
let elapsed_time = T::now().duration_since(self.last_updated).as_secs() as f64;
1080-
((offset as f64) * powf64(0.5, elapsed_time / (half_life as f64))) as u64
1077+
let half_life = decay_params.liquidity_offset_half_life.as_secs_f64();
1078+
if half_life != 0.0 {
1079+
let elapsed_time = T::now().duration_since(self.last_updated).as_secs_f64();
1080+
((offset as f64) * powf64(0.5, elapsed_time / half_life)) as u64
10811081
} else {
10821082
0
10831083
}
@@ -1508,8 +1508,8 @@ impl<G: Deref<Target = NetworkGraph<L>>, L: Deref, T: Time> ScoreUpdate for Prob
15081508
let elapsed_time =
15091509
T::now().duration_since(liquidity.offset_history_last_updated);
15101510
if elapsed_time > decay_params.historical_no_updates_half_life {
1511-
let half_life = decay_params.historical_no_updates_half_life.as_secs() as f64;
1512-
let divisor = powf64(2048.0, (elapsed_time.as_secs() as f64) / half_life) as u64;
1511+
let half_life = decay_params.historical_no_updates_half_life.as_secs_f64();
1512+
let divisor = powf64(2048.0, elapsed_time.as_secs_f64() / half_life) as u64;
15131513
for bucket in liquidity.min_liquidity_offset_history.buckets.iter_mut() {
15141514
*bucket = ((*bucket as u64) * 1024 / divisor) as u16;
15151515
}

0 commit comments

Comments
 (0)