Add from_name api

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Change Log
 
+## 0.7.3 (17 November, 2024)
+
+- Added from_name() API method. It may be useful if the process name contains dots.
+
 ## 0.7.2 (15 October, 2024)
 
 - Event handler callback fro reporting process lifetime events revisited.

Project.toml

@@ -1,7 +1,7 @@
 name = "Visor"
 uuid = "cf786855-3531-4b86-ba6e-3e33dce7dcdb"
 authors = ["Attilio Donà"]
-version = "0.7.2"
+version = "0.7.3"
 
 [deps]
 DataStructures = "864edb3b-99cc-5e75-8d2d-829cb0a9cfe8"

src/Visor.jl

@@ -22,7 +22,7 @@ const STOP_WAITING_AFTER = Inf
 export application
 export call
 export cast
-export from
+export from, from_name
 export getphase
 export ifrestart
 export hassupervised
@@ -1101,6 +1101,31 @@ function from_path(start_node::Supervised, path)
     return nothing
 end
 
+"""
+    from_name(container::Supervised, name::AbstractString)
+
+Return the process identified by `name` that is supervised by `container` or
+nothing if such process does not exists.
+
+It may be useful in case the process name contains dots because it does not lookup the
+supervision hierarchy using the dot as separator between nodes.
+"""
+function from_name(container::Supervised, name::AbstractString)
+    if haskey(container.processes, name)
+        return container.processes[name]
+    else
+        return nothing
+    end
+end
+
+"""
+    from_name(name::AbstractString)
+
+Return the process supervised by the root supervisor that is identified by `name` or
+nothing if such process does not exists.
+"""
+from_name(name::AbstractString) = from_name(__ROOT__, name)
+
 """
     function receive(fn::Function, pd::Process)
 

test/test_hierarchy.jl

@@ -3,18 +3,19 @@ include("utils.jl")
 #         root
 #          /\
 #         /  \
-#       sv1  sv2    
+#       sv1  sv2
 #       /      \
 #    sv1-3      w3
-#     /\    
-#   w1  w2
+#     /\
+#   w1  w2 127.0.0.1
 #
 
 sv2_specs = [process("w3", worker; namedargs=(steps=10, check_interrupt_every=2))]
 
 sv3_specs = [
     process("w1", worker; namedargs=(steps=5, check_interrupt_every=1)),
     process("w2", worker; namedargs=(steps=10, check_interrupt_every=3)),
+    process("127.0.0.1", worker; namedargs=(steps=10, check_interrupt_every=3)),
 ]
 
 sv1_specs = [supervisor("sv1-3", sv3_specs; intensity=1)]
@@ -28,7 +29,7 @@ function getrunning(handle)
     sv = Visor.from_supervisor(handle, "sv1.sv1-3")
     nprocs = length(Visor.running_nodes(sv))
     @info "supervisor [$(sv.id)] running processes: $nprocs"
-    return ttrace["getrunning"] = nprocs == 1
+    return ttrace["getrunning"] = nprocs == 2
 end
 
 function shutdown_request(start_node, target_id::String)
@@ -44,6 +45,12 @@ handle = supervise(specs; wait=false)
 
 sv = from("sv1.sv1-3")
 
+proc = from_name(sv, "127.0.0.1")
+@test proc.id == "127.0.0.1"
+
+proc = from_name("127.0.0.1")
+@test proc === nothing
+
 # test internal method from_path
 # from_path is not thread safe, use from instead
 node = Visor.from_path(sv, ".")
@@ -58,12 +65,12 @@ t1 = Timer((tim) -> shutdown_request(handle, "sv1.sv1-3.w1"), 2)
 t2 = Timer((tim) -> getrunning(handle), 3)
 
 n = Visor.nproc(sv)
-@test n == 2
+@test n == 3
 
 wait(handle)
 
 for (tst, result) in ttrace
     @test result
 end
 
-shutdown()
+shutdown()