interlink: fix shmem names in receiver/transmitter shutdown

snabbco · May 19, 2022 · 101911a · 101911a
1 parent 507173f
commit 101911a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/apps/interlink/receiver.lua b/src/apps/interlink/receiver.lua
@@ -46,8 +46,8 @@ end
 -- process termination.
 function Receiver.shutdown (pid)
    for _, queue in ipairs(shm.children("/"..pid.."/interlink/receiver")) do
-      local backlink = "/"..pid.."/interlink/receiver/"..queue..".interlink"
-      local shm_name = "/"..pid.."/group/interlink/"..queue..".interlink"
+      local backlink = "/"..pid.."/interlink/receiver/"..queue
+      local shm_name = "/"..pid.."/group/interlink/"..queue
       -- Call protected in case /<pid>/group is already unlinked.
       local ok, r = pcall(interlink.open, shm_name)
       if ok then interlink.detach_receiver(r, shm_name) end

diff --git a/src/apps/interlink/transmitter.lua b/src/apps/interlink/transmitter.lua
@@ -46,8 +46,8 @@ end
 -- process termination.
 function Transmitter.shutdown (pid)
    for _, queue in ipairs(shm.children("/"..pid.."/interlink/transmitter")) do
-      local backlink = "/"..pid.."/interlink/transmitter/"..queue..".interlink"
-      local shm_name = "/"..pid.."/group/interlink/"..queue..".interlink"
+      local backlink = "/"..pid.."/interlink/transmitter/"..queue
+      local shm_name = "/"..pid.."/group/interlink/"..queue
       -- Call protected in case /<pid>/group is already unlinked.
       local ok, r = pcall(interlink.open, shm_name)
       if ok then interlink.detach_transmitter(r, shm_name) end