Registry fast path for stop_process/start_process.

Author: dtzxporter

CHANGELOG.md

@@ -6,6 +6,11 @@
 
 ### Fixed
 
+# 0.1.34
+
+### Changed
+- Registry `stop_process`/`start_process` now has a fast path to check if a local registry has/doesn't have the process.
+
 # 0.1.33
 
 ### Added

Cargo.toml

@@ -33,8 +33,8 @@ tracing = { version = "0.1", default-features = false, features = ["std"] }
 tracing-subscriber = "0.3"
 dashmap = "6.0.1"
 
-hydra-macros = { version = "0.1.33", path = "./hydra-macros" }
-hydra = { version = "0.1.33", path = "./hydra", default-features = false }
+hydra-macros = { version = "0.1.34", path = "./hydra-macros" }
+hydra = { version = "0.1.34", path = "./hydra", default-features = false }
 
 [profile.release]
 lto = "fat"

hydra-macros/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "hydra-macros"
-version = "0.1.33"
+version = "0.1.34"
 edition = "2021"
 license.workspace = true
 repository.workspace = true

hydra-websockets/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "hydra-websockets"
-version = "0.1.33"
+version = "0.1.34"
 edition = "2021"
 readme = "./README.md"
 license.workspace = true

hydra/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "hydra"
-version = "0.1.33"
+version = "0.1.34"
 edition = "2021"
 readme.workspace = true
 license.workspace = true

hydra/src/registry.rs

@@ -197,7 +197,16 @@ impl Registry {
     ) -> Result<Pid, RegistryError> {
         use RegistryMessage::*;
 
-        match Registry::call(registry, Start(key.into()), None).await? {
+        let registry = registry.into();
+        let key = key.into();
+
+        if let Dest::Named(registry, Node::Local) = &registry {
+            if let Some(pid) = lookup_process(registry, &key) {
+                return Err(RegistryError::AlreadyStarted(pid));
+            }
+        }
+
+        match Registry::call(registry, Start(key), None).await? {
             StartSuccess(pid) => Ok(pid),
             StartError(error) => Err(error),
             _ => unreachable!(),
@@ -215,7 +224,16 @@ impl Registry {
     ) -> Result<(), RegistryError> {
         use RegistryMessage::*;
 
-        match Registry::call(registry, Stop(key.into()), None).await? {
+        let registry = registry.into();
+        let key = key.into();
+
+        if let Dest::Named(registry, Node::Local) = &registry {
+            if lookup_process(registry, &key).is_none() {
+                return Err(RegistryError::NotFound);
+            }
+        }
+
+        match Registry::call(registry, Stop(key), None).await? {
             StopSuccess => Ok(()),
             StopError(error) => Err(error),
             _ => unreachable!(),