grund-bus: Fix message dispatch.

src/impls/impl-skift/async.cpp

@@ -79,7 +79,7 @@ struct HjertSched : public Sys::Sched {
         while (_Embed::now() < until) {
             try$(_listener.poll(until));
             while (auto ev = _listener.next()) {
-                auto &prop = _promises.get(ev->cap);
+                auto prop = _promises.take(ev->cap);
                 try$(_listener.mute(ev->cap));
                 prop.resolve(Ok());
             }

src/srvs/grund-bus/bus.cpp

@@ -126,7 +126,7 @@ Async::Task<> Service::runAsync() {
 
 Res<> Service::dispatch(Sys::Message &msg) {
     logDebug("Dispatching message on service '{}'", _id);
-    return _con.send(msg.bytes, msg.handles);
+    return _con.send(sub(msg.bytes, msg.len), sub(msg.handles, msg.handlesLen));
 }
 
 // MARK: Bus -------------------------------------------------------------------
@@ -149,8 +149,9 @@ Karm::Res<> Bus::attach(Strong<Endpoint> endpoint) {
 }
 
 Res<> Bus::dispatch(Sys::Header &h, Sys::Message &msg) {
+    logDebug("dispatching message to {}", h.port);
     for (auto &endpoint : _endpoints) {
-        if (endpoint->_port == h.port)
+        if (endpoint->port() == h.port)
             return endpoint->dispatch(msg);
     }
     return Error::notFound("service not found");

src/srvs/grund-bus/bus.h

@@ -17,7 +17,7 @@ struct Endpoint : public Meta::Static {
         return Sys::Port{port++};
     }
 
-    Sys::Port _port;
+    Sys::Port _port = nextPort();
     Bus *_bus;
 
     virtual ~Endpoint() = default;