File tree Expand file tree Collapse file tree 1 file changed +18
-19
lines changed Expand file tree Collapse file tree 1 file changed +18
-19
lines changed Original file line number Diff line number Diff line change @@ -6329,25 +6329,24 @@ where
63296329 let mut new_events = VecDeque::new();
63306330 let mut failed_forwards = Vec::new();
63316331 let mut phantom_receives: Vec<PerSourcePendingForward> = Vec::new();
6332- {
6333- let mut forward_htlcs = new_hash_map();
6334- mem::swap(&mut forward_htlcs, &mut self.forward_htlcs.lock().unwrap());
6335-
6336- for (short_chan_id, mut pending_forwards) in forward_htlcs {
6337- if short_chan_id != 0 {
6338- self.process_forward_htlcs(
6339- short_chan_id,
6340- &mut pending_forwards,
6341- &mut failed_forwards,
6342- &mut phantom_receives,
6343- );
6344- } else {
6345- self.process_receive_htlcs(
6346- &mut pending_forwards,
6347- &mut new_events,
6348- &mut failed_forwards,
6349- );
6350- }
6332+
6333+ let mut forward_htlcs = new_hash_map();
6334+ mem::swap(&mut forward_htlcs, &mut self.forward_htlcs.lock().unwrap());
6335+
6336+ for (short_chan_id, mut pending_forwards) in forward_htlcs {
6337+ if short_chan_id != 0 {
6338+ self.process_forward_htlcs(
6339+ short_chan_id,
6340+ &mut pending_forwards,
6341+ &mut failed_forwards,
6342+ &mut phantom_receives,
6343+ );
6344+ } else {
6345+ self.process_receive_htlcs(
6346+ &mut pending_forwards,
6347+ &mut new_events,
6348+ &mut failed_forwards,
6349+ );
63516350 }
63526351 }
63536352
You can’t perform that action at this time.
0 commit comments