diff options
Diffstat (limited to 'lib/kernel/Namespace.ml')
| -rw-r--r-- | lib/kernel/Namespace.ml | 10 |
1 files changed, 7 insertions, 3 deletions
diff --git a/lib/kernel/Namespace.ml b/lib/kernel/Namespace.ml index 340e813..c7c0767 100644 --- a/lib/kernel/Namespace.ml +++ b/lib/kernel/Namespace.ml @@ -1,18 +1,22 @@ class namespace = object (self) - inherit Lifecycle.null + inherit Lifecycle.counted inherit Identity.of_id method to_string = "namespace" val entries : (string, Protocols.Handle.t) BatMap.t Atomic.t = Atomic.make BatMap.empty method protocols = Protocols.[Directory.make self; Registry.make self] + method destroy = Atomic.get entries |> BatMap.values |> BatEnum.iter Protocols.Handle.release method update key reference value = match Utilities.Atomic.mswap entries (fun e -> - if BatMap.find_opt key e = reference then + let existing = BatMap.find_opt key e in + if existing = reference then begin + Option.map Protocols.Handle.release existing |> ignore; match value with - | Some v -> Ok (BatMap.add key v e) + | Some v -> Ok (BatMap.add key (Protocols.Handle.move v) e) | None -> Ok (BatMap.remove key e) + end else Error () ) with | Ok _ -> Ok true |
