CAT_TOM/pyasic
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fixed a bug with configuring and scanning

Browse Source
This commit is contained in:
UpstreamData
2021-12-21 16:20:29 -07:00
parent 475fe1769d
commit 8ea97d9cfe
2 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
cfg_util/func/__init__.py
View File

@@ -99,14 +99,14 @@ async def send_config(ips: list, config):
for ip in ips: for ip in ips:
tasks.append(miner_factory.get_miner(ip)) tasks.append(miner_factory.get_miner(ip))
miners = await asyncio.gather(*tasks) miners = await asyncio.gather(*tasks)
tasks = [] config_tasks = []
for miner in miners: for miner in miners:
if len(tasks) < CONFIG_THREADS: if len(config_tasks) < CONFIG_THREADS:
tasks.append(miner.send_config(config)) config_tasks.append(miner.send_config(config))
else: else:
await asyncio.gather(*tasks) await asyncio.gather(*config_tasks)
tasks = [] config_tasks = []
await asyncio.gather(*tasks) await asyncio.gather(*config_tasks)
await update_ui_with_data("status", "") await update_ui_with_data("status", "")

3
network/__init__.py
View File

@@ -39,7 +39,8 @@ class MinerNetwork:
miner_ips_scan = await asyncio.gather(*scan_tasks) miner_ips_scan = await asyncio.gather(*scan_tasks)
miner_ips.extend(miner_ips_scan) miner_ips.extend(miner_ips_scan)
scan_tasks = [] scan_tasks = []
await asyncio.gather(*scan_tasks) miner_ips_scan = await asyncio.gather(*scan_tasks)
miner_ips.extend(miner_ips_scan)
miner_ips = list(filter(None, miner_ips)) miner_ips = list(filter(None, miner_ips))
print(f"Found {len(miner_ips)} connected miners...") print(f"Found {len(miner_ips)} connected miners...")
create_miners_tasks = [] create_miners_tasks = []