aljaz/plugins
1
0
Fork 0
mirror of https://github.com/aljazceru/plugins.git synced 2025-12-24 00:24:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

rebalance: fix potential looping mistakes

Browse Source
This commit is contained in:
Michael Schmoock
2021-02-03 10:47:18 +01:00
parent 5e00474390
commit cf9b942966
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
rebalance/rebalance.py
View File

@@ -299,7 +299,7 @@ def get_ideal_ratio(channels: list, enough_liquidity: Millisatoshi):
our = sum(ch["to_us_msat"] for ch in channels) our = sum(ch["to_us_msat"] for ch in channels)
total = sum(ch["total_msat"] for ch in channels) total = sum(ch["total_msat"] for ch in channels)
chs = list(channels) # get a copy! chs = list(channels) # get a copy!
while True: while len(chs) > 0:
ratio = int(our) / int(total) ratio = int(our) / int(total)
smallest_channel = min(chs, key=lambda ch: ch["total_msat"]) smallest_channel = min(chs, key=lambda ch: ch["total_msat"])
if smallest_channel["total_msat"] * min(ratio, 1 - ratio) > enough_liquidity: if smallest_channel["total_msat"] * min(ratio, 1 - ratio) > enough_liquidity:
@@ -408,6 +408,8 @@ def maybe_rebalance_once(plugin: Plugin, failed_pairs: list):
channels = get_open_channels(plugin) channels = get_open_channels(plugin)
for ch1 in channels: for ch1 in channels:
for ch2 in channels: for ch2 in channels:
if ch1 == ch2:
continue
result = maybe_rebalance_pairs(plugin, ch1, ch2, failed_pairs) result = maybe_rebalance_pairs(plugin, ch1, ch2, failed_pairs)
if result["success"] or plugin.rebalance_stop: if result["success"] or plugin.rebalance_stop:
return result return result