diff options
| author | Estevan Castilho <tevo@riajuu.net> | 2026-10-10 01:09:17 +0000 |
|---|---|---|
| committer | Estevan Castilho <tevo@riajuu.net> | 2026-10-10 01:09:17 +0000 |
| commit | 9be5137143177492e82dc25e6dbd3b82e3aa7e5d (patch) | |
| tree | d2206c6c67a395cc1e6f3b1e47c2da812a83bf96 /lib/kernel/Namespace.ml | |
| parent | bd152dc4311a117f125916e1f75cb5ce02752630 (diff) | |
| download | RNT-9be5137143177492e82dc25e6dbd3b82e3aa7e5d.tar.gz RNT-9be5137143177492e82dc25e6dbd3b82e3aa7e5d.zip | |
Make namespaces take ownership of the handles it is given
Diffstat (limited to '')
| -rw-r--r-- | lib/kernel/Namespace.ml | 15 | ||||
| -rw-r--r-- | lib/kernel/Namespace.mli | 2 |
2 files changed, 12 insertions, 5 deletions
diff --git a/lib/kernel/Namespace.ml b/lib/kernel/Namespace.ml index 340e813..c7cc627 100644 --- a/lib/kernel/Namespace.ml +++ b/lib/kernel/Namespace.ml @@ -1,18 +1,23 @@ 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 - match value with - | Some v -> Ok (BatMap.add key v e) - | None -> Ok (BatMap.remove key e) + 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 (Protocols.Handle.move v) e) + | None -> Ok (BatMap.remove key e) + end else Error () ) with | Ok _ -> Ok true diff --git a/lib/kernel/Namespace.mli b/lib/kernel/Namespace.mli index ec77724..9d4f343 100644 --- a/lib/kernel/Namespace.mli +++ b/lib/kernel/Namespace.mli @@ -2,6 +2,8 @@ class namespace : object inherit Protocols.Handle.obj inherit Protocols.Directory.implementation inherit Protocols.Registry.implementation + + method destroy : unit end val make : unit -> Protocols.Handle.t |
