Chia-Network/chia-blockchain
1
0
Fork 0
mirror of https://github.com/Chia-Network/chia-blockchain.git synced 2024-09-20 08:05:33 +03:00
Code Issues Packages Projects Releases Wiki Activity

Merge commit 'cbf971e7f5bbbbcf64d3e8571fb82c14592c53b2' into checkpoint/main_from_release_2.0.0_cbf971e7f5bbbbcf64d3e8571fb82c14592c53b2

Browse Source
This commit is contained in:
Amine Khaldi 2023-08-16 21:00:57 +01:00
commit fddfd0c755
No known key found for this signature in database
GPG Key ID: B1C074FFC904E2D9
1 changed files with 20 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
chia/plotting/manager.py
View File

@ -46,6 +46,7 @@ class PlotManager:
_refresh_callback: Callable
_initial: bool
max_compression_level_allowed: int
context_count: int
def __init__(
self,
@ -79,6 +80,7 @@ class PlotManager:
self._refresh_callback = refresh_callback
self._initial = True
self.max_compression_level_allowed = 0
self.context_count = 0
def __enter__(self):
self._lock.acquire()
@ -118,6 +120,7 @@ class PlotManager:
f"Falling back to CPU harvesting: {context_count} decompressors count, {thread_count} threads."
)
self.max_compression_level_allowed = max_compression_level_allowed
self.context_count = context_count
return HarvestingMode.GPU if is_using_gpu else HarvestingMode.CPU
def reset(self) -> None:
@ -337,17 +340,28 @@ class PlotManager:
"We assume the file is being copied."
)
return None
elif level > self.max_compression_level_allowed:
log.warning(
f"Not farming plot {file_path}. Plot compression level: {level}, "
f"max compression level allowed: {self.max_compression_level_allowed}."
)
return None
cache_entry = CacheEntry.from_disk_prover(prover)
self.cache.update(file_path, cache_entry)
assert cache_entry is not None
level = cache_entry.prover.get_compression_level()
if level > self.max_compression_level_allowed:
log.warning(
f"Not farming plot {file_path}. Plot compression level: {level}, "
f"max compression level allowed: {self.max_compression_level_allowed}."
)
return None
if level > 0 and self.context_count == 0:
log.warning(
f"Not farming compressed plot {file_path}. Plot compression level: {level}, "
f"because parallel_decompressor_count is set to 0 in config.yaml. Use a non-zero value"
" to start harvesting compressed plots."
)
return None
# Only use plots that correct keys associated with them
if cache_entry.farmer_public_key not in self.farmer_public_keys:
log.warning(f"Plot {file_path} has a farmer public key that is not in the farmer's pk list.")