revert worker process ipc signal suffix (#4323)

Author: RichardWooSJTU

fastdeploy/worker/worker_process.py

@@ -183,7 +183,7 @@ def init_health_status(self) -> None:
                 name="launched_expert_service_signal",
                 array=launched_expert_service_signal_data,
                 dtype=np.int32,
-                suffix=self.parallel_config.engine_worker_queue_port,
+                suffix=self.parallel_config.engine_pid,
                 create=False,
             )
             while self.launched_expert_service_signal.value[self.local_rank % self.max_chips_per_node] == 0:
@@ -200,7 +200,7 @@ def init_health_status(self) -> None:
             name="worker_ready_signal",
             array=workers_ready,
             dtype=np.int32,
-            suffix=self.parallel_config.engine_worker_queue_port,
+            suffix=self.parallel_config.engine_pid,
             create=False,
         )
         self.worker_ready_signal.value[self.local_rank % self.max_chips_per_node] = 1
@@ -418,7 +418,7 @@ def initialize_kv_cache(self) -> None:
                     name="get_profile_block_num",
                     array=get_profile_block_num,
                     dtype=np.int32,
-                    suffix=self.parallel_config.engine_worker_queue_port,
+                    suffix=self.parallel_config.engine_pid,
                     create=False,
                 )
                 self.get_profile_block_num_signal.value[0] = num_blocks_local
@@ -473,7 +473,7 @@ def load_model(self) -> None:
             name="loaded_model_signal",
             array=loaded_model_signal_data,
             dtype=np.int32,
-            suffix=self.parallel_config.engine_worker_queue_port,
+            suffix=self.parallel_config.engine_pid,
             create=False,
         )
         if self.ranks > 1: