File tree Expand file tree Collapse file tree 1 file changed +17
-19
lines changed Expand file tree Collapse file tree 1 file changed +17
-19
lines changed Original file line number Diff line number Diff line change @@ -7070,25 +7070,23 @@ where
7070
7070
let mut new_events = VecDeque::new();
7071
7071
let mut failed_forwards = Vec::new();
7072
7072
let mut phantom_receives: Vec<PerSourcePendingForward> = Vec::new();
7073
- {
7074
- let mut forward_htlcs = new_hash_map();
7075
- mem::swap(&mut forward_htlcs, &mut self.forward_htlcs.lock().unwrap());
7076
-
7077
- for (short_chan_id, mut pending_forwards) in forward_htlcs {
7078
- if short_chan_id != 0 {
7079
- self.process_forward_htlcs(
7080
- short_chan_id,
7081
- &mut pending_forwards,
7082
- &mut failed_forwards,
7083
- &mut phantom_receives,
7084
- );
7085
- } else {
7086
- self.process_receive_htlcs(
7087
- &mut pending_forwards,
7088
- &mut new_events,
7089
- &mut failed_forwards,
7090
- );
7091
- }
7073
+ let mut forward_htlcs = new_hash_map();
7074
+ mem::swap(&mut forward_htlcs, &mut self.forward_htlcs.lock().unwrap());
7075
+
7076
+ for (short_chan_id, mut pending_forwards) in forward_htlcs {
7077
+ if short_chan_id != 0 {
7078
+ self.process_forward_htlcs(
7079
+ short_chan_id,
7080
+ &mut pending_forwards,
7081
+ &mut failed_forwards,
7082
+ &mut phantom_receives,
7083
+ );
7084
+ } else {
7085
+ self.process_receive_htlcs(
7086
+ &mut pending_forwards,
7087
+ &mut new_events,
7088
+ &mut failed_forwards,
7089
+ );
7092
7090
}
7093
7091
}
7094
7092
You can’t perform that action at this time.
0 commit comments