improvement: Correct disk healthy check min number config key

Author: zuston

src/config.rs

@@ -104,7 +104,7 @@ pub struct KerberosSecurityConfig {
 pub struct LocalfileStoreConfig {
     pub data_paths: Vec<String>,
     #[serde(default = "as_default_healthy_check_min_disks")]
-    pub healthy_check_min_disks: i32,
+    pub min_number_of_available_disks: i32,
     #[serde(default = "as_default_disk_high_watermark")]
     pub disk_high_watermark: f32,
     #[serde(default = "as_default_disk_low_watermark")]
@@ -144,7 +144,7 @@ impl LocalfileStoreConfig {
     pub fn new(data_paths: Vec<String>) -> Self {
         LocalfileStoreConfig {
             data_paths,
-            healthy_check_min_disks: as_default_healthy_check_min_disks(),
+            min_number_of_available_disks: as_default_healthy_check_min_disks(),
             disk_high_watermark: as_default_disk_high_watermark(),
             disk_low_watermark: as_default_disk_low_watermark(),
             disk_max_concurrency: as_default_disk_max_concurrency(),

src/store/localfile.rs

@@ -72,7 +72,7 @@ impl From<LocalDiskDelegator> for LockedObj {
 
 pub struct LocalFileStore {
     local_disks: Vec<LocalDiskDelegator>,
-    healthy_check_min_disks: i32,
+    min_number_of_available_disks: i32,
     runtime_manager: RuntimeManager,
     partition_locks: DashMap<String, Arc<RwLock<LockedObj>>>,
 }
@@ -93,7 +93,7 @@ impl LocalFileStore {
         }
         LocalFileStore {
             local_disks: local_disk_instances,
-            healthy_check_min_disks: 1,
+            min_number_of_available_disks: 1,
             runtime_manager,
             partition_locks: Default::default(),
         }
@@ -118,7 +118,7 @@ impl LocalFileStore {
         }
         LocalFileStore {
             local_disks: local_disk_instances,
-            healthy_check_min_disks: localfile_config.healthy_check_min_disks,
+            min_number_of_available_disks: localfile_config.min_number_of_available_disks,
             runtime_manager,
             partition_locks: Default::default(),
         }
@@ -171,9 +171,9 @@ impl LocalFileStore {
 
         debug!(
             "disk: available={}, healthy_check_min={}",
-            available, self.healthy_check_min_disks
+            available, self.min_number_of_available_disks
         );
-        Ok(available > self.healthy_check_min_disks)
+        Ok(available >= self.min_number_of_available_disks)
     }
 
     fn select_disk(&self, uid: &PartitionedUId) -> Result<LocalDiskDelegator, WorkerError> {