I am using capnproto to send messages between several nodes. Each node can both send and receive messages from all others (and is connected to itself). The relevant code looks like this: (* sending *) let send_msg service (msg : Consensus.msg) = let send service = let open Api.Client.Hs.SendMsg …

I was able to fix this by separating out the ‘Sturdy_ref.with_cap_exn’ command into a separate connect and send. The new code looks like this: let rec connect service t = let* r = Sturdy_ref.connect service in match r with | Ok conn -> Lwt.return conn | Error _ -> let* () = Lwt_unix.s…

All of your nodes are created with Capnp_rpc_unix.client_only_vat, so none of them can accept a connection anyway. You need Capnp_rpc_unix.serve instead. For this in-process case, you’ll know when you’ve created all the vats and can send the messages then, but in a real system there’s no way to kno…

Waiting for Capnproto connection

Learning

Marchhill January 24, 2023, 2:36pm 3

Sorry I missed out part of my code that is important - I do use serve. How can I attempt to connect and retry?

Topic		Replies	Views
Lwt error using Capnproto to send messages Learning lwt , capnp	9	792	January 16, 2023
Capnproto sometimes very slow to send message Learning lwt , capnp	2	457	February 23, 2023
Capnp: Uri format and possible error cases for capabilities Learning capnp	3	883	March 26, 2020
Cap'n'proto beginner needs help Learning capnp	1	1332	October 15, 2019
[ANN] capnp-rpc 0.2 - persistence, encryption and access control Community announce , rpc , capnp	9	2779	October 3, 2017

Waiting for Capnproto connection

Related topics