mirror of
https://github.com/zap-proto/ocaml-rpc.git
synced 2026-10-30 15:04:28 +00:00
Thomas Leonard
48d675b10e
This switches capnp-rpc from Lwt to Eio. One particularly nice side effect of this is that `Service.return_lwt` has gone, as there is no distinction now between concurrent and non-concurrent service methods.
85 lines
2.4 KiB
OCaml
85 lines
2.4 KiB
OCaml
open Capnp_core
|
|
|
|
include Capnp.Message.BytesMessage
|
|
|
|
module Exception = Capnp_rpc_proto.Exception
|
|
module Error = Capnp_rpc_proto.Error
|
|
module Log = Capnp_rpc_proto.Debug.Log
|
|
module RO_array = Capnp_rpc_proto.RO_array
|
|
module Debug = Capnp_rpc_proto.Debug
|
|
module Leak_handler = Leak_handler
|
|
|
|
module Capability = Capability
|
|
|
|
module StructRef = struct
|
|
type 'a t = Core_types.struct_ref
|
|
|
|
let inc_ref = Core_types.inc_ref
|
|
let dec_ref = Core_types.dec_ref
|
|
end
|
|
|
|
module Sturdy_ref = Sturdy_ref
|
|
|
|
module Untyped = struct
|
|
let struct_field t i =
|
|
(* todo: would be better to have a separate type for this *)
|
|
object (_ : Core_types.struct_ref)
|
|
method cap path = t#cap (Xform.Field i :: path)
|
|
method when_resolved _ = failwith "Can't use when_resolved on a sub-struct"
|
|
method response = failwith "Can't use response on a sub-struct"
|
|
method update_rc = failwith "Can't use rec-counts on a sub-struct"
|
|
method sealed_dispatch _ = None
|
|
method pp f = Fmt.pf f "pointer %d in %t" i t#pp
|
|
method blocker = failwith "struct_field: blocker"
|
|
method check_invariants = ()
|
|
end
|
|
|
|
let capability_field t f = t#cap [Xform.Field f]
|
|
|
|
let local = Service.local
|
|
|
|
type abstract_method_t = Service.abstract_method_t
|
|
|
|
let abstract_method x req release =
|
|
x (StructStorage.cast_reader req) release
|
|
|
|
let get_cap a i =
|
|
Core_types.Attachments.cap (Stdint.Uint32.to_int i) (Msg.unwrap_attachments a)
|
|
|
|
let add_cap a cap =
|
|
Core_types.Attachments.add_cap (Msg.unwrap_attachments a) cap |> Stdint.Uint32.of_int
|
|
|
|
let clear_cap a i =
|
|
Core_types.Attachments.clear_cap (Msg.unwrap_attachments a) (Stdint.Uint32.to_int i)
|
|
|
|
let unknown_interface ~interface_id _req release_params =
|
|
release_params ();
|
|
Core_types.fail ~ty:`Unimplemented "Unknown interface %a" Stdint.Uint64.printer interface_id
|
|
|
|
let unknown_method ~interface_id ~method_id _req release_params =
|
|
release_params ();
|
|
Core_types.fail ~ty:`Unimplemented "Unknown method %a.%d" Stdint.Uint64.printer interface_id method_id
|
|
|
|
class type generic_service = Service.generic
|
|
end
|
|
|
|
module Service = Service
|
|
|
|
module Private = Private
|
|
|
|
module Cast = struct
|
|
let cap_of_raw x = x
|
|
let cap_to_raw x = x
|
|
|
|
let sturdy_of_raw x = x
|
|
let sturdy_to_raw x = x
|
|
end
|
|
|
|
module Persistence = Persistence
|
|
|
|
module Std = struct
|
|
module Sturdy_ref = Sturdy_ref
|
|
module Capability = Capability
|
|
module Service = Service
|
|
end
|