more renames

Signed-off-by: Bugen Zhao <[email protected]>
risingwavelabs · Jan 23, 2025 · f43a615 · f43a615
1 parent fa964a9
commit f43a615
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 8 deletions.
diff --git a/src/frontend/src/observer/observer_manager.rs b/src/frontend/src/observer/observer_manager.rs
@@ -151,7 +151,7 @@ impl ObserverState for FrontendObserverNode {
             session_params,
             version,
             secrets,
-            cluster_cpu_core_count,
+            compute_node_total_cpu_count,
         } = snapshot;
 
         for db in databases {
@@ -213,7 +213,7 @@ impl ObserverState for FrontendObserverNode {
         *self.session_params.write() =
             serde_json::from_str(&session_params.unwrap().params).unwrap();
         LocalSecretManager::global().init_secrets(secrets);
-        LicenseManager::get().update_cpu_core_count(cluster_cpu_core_count as _);
+        LicenseManager::get().update_cpu_core_count(compute_node_total_cpu_count as _);
     }
 }
 

diff --git a/src/meta/service/src/notification_service.rs b/src/meta/service/src/notification_service.rs
@@ -224,7 +224,7 @@ impl NotificationServiceImpl {
                 catalog_version,
                 ..Default::default()
             }),
-            cluster_cpu_core_count: compute_node_total_cpu_count as _,
+            compute_node_total_cpu_count: compute_node_total_cpu_count as _,
             ..Default::default()
         })
     }
@@ -300,7 +300,7 @@ impl NotificationServiceImpl {
             serving_worker_slot_mappings,
             streaming_worker_slot_mappings,
             session_params,
-            cluster_cpu_core_count: compute_node_total_cpu_count as _,
+            compute_node_total_cpu_count: compute_node_total_cpu_count as _,
             ..Default::default()
         })
     }
@@ -328,7 +328,7 @@ impl NotificationServiceImpl {
             hummock_write_limits: Some(WriteLimits {
                 write_limits: hummock_write_limits,
             }),
-            cluster_cpu_core_count: compute_node_total_cpu_count as _,
+            compute_node_total_cpu_count: compute_node_total_cpu_count as _,
             ..Default::default()
         })
     }
@@ -343,7 +343,7 @@ impl NotificationServiceImpl {
                 catalog_version,
                 ..Default::default()
             }),
-            cluster_cpu_core_count: compute_node_total_cpu_count as _,
+            compute_node_total_cpu_count: compute_node_total_cpu_count as _,
             ..Default::default()
         })
     }

diff --git a/src/storage/compactor/src/compactor_observer/observer_manager.rs b/src/storage/compactor/src/compactor_observer/observer_manager.rs
@@ -77,7 +77,7 @@ impl ObserverState for CompactorObserverNode {
         self.handle_catalog_snapshot(snapshot.tables);
         let snapshot_version = snapshot.version.unwrap();
         self.version = snapshot_version.catalog_version;
-        LicenseManager::get().update_cpu_core_count(snapshot.cluster_cpu_core_count as _);
+        LicenseManager::get().update_cpu_core_count(snapshot.compute_node_total_cpu_count as _);
     }
 }
 

diff --git a/src/storage/src/hummock/observer_manager.rs b/src/storage/src/hummock/observer_manager.rs
@@ -137,7 +137,7 @@ impl ObserverState for HummockObserverNode {
             });
         let snapshot_version = snapshot.version.unwrap();
         self.version = snapshot_version.catalog_version;
-        LicenseManager::get().update_cpu_core_count(snapshot.cluster_cpu_core_count as _);
+        LicenseManager::get().update_cpu_core_count(snapshot.compute_node_total_cpu_count as _);
     }
 }