Skip to content

Commit b22837d

Browse files
committed
f include ms/ns time parts when decaying
1 parent 80cb28f commit b22837d

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
@@ -1075,10 +1075,10 @@ impl<T: Time> ChannelLiquidity<T> {
10751075
}
10761076

10771077
fn decayed_offset(&self, offset: u64, decay_params: ProbabilisticScoringDecayParameters) -> u64 {
1078-
let half_life = decay_params.liquidity_offset_half_life.as_secs();
1079-
if half_life != 0 {
1080-
let elapsed_time = T::now().duration_since(self.last_updated).as_secs() as f64;
1081-
((offset as f64) * powf64(0.5, elapsed_time / (half_life as f64))) as u64
1078+
let half_life = decay_params.liquidity_offset_half_life.as_secs_f64();
1079+
if half_life != 0.0 {
1080+
let elapsed_time = T::now().duration_since(self.last_updated).as_secs_f64();
1081+
((offset as f64) * powf64(0.5, elapsed_time / half_life)) as u64
10821082
} else {
10831083
0
10841084
}
@@ -1502,8 +1502,8 @@ impl<G: Deref<Target = NetworkGraph<L>>, L: Deref, T: Time> ScoreUpdate for Prob
15021502
let elapsed_time =
15031503
T::now().duration_since(liquidity.offset_history_last_updated);
15041504
if elapsed_time > decay_params.historical_no_updates_half_life {
1505-
let half_life = decay_params.historical_no_updates_half_life.as_secs() as f64;
1506-
let divisor = powf64(2048.0, (elapsed_time.as_secs() as f64) / half_life) as u64;
1505+
let half_life = decay_params.historical_no_updates_half_life.as_secs_f64();
1506+
let divisor = powf64(2048.0, elapsed_time.as_secs_f64() / half_life) as u64;
15071507
for bucket in liquidity.min_liquidity_offset_history.buckets.iter_mut() {
15081508
*bucket = ((*bucket as u64) * 1024 / divisor) as u16;
15091509
}

0 commit comments

Comments
 (0)