[zion] Add a port send syscall

This commit is contained in:
Drew Galbraith 2023-06-17 01:05:10 -07:00
parent cc191cd6bb
commit 857b7fae03
4 changed files with 33 additions and 0 deletions

View File

@ -94,6 +94,9 @@ void ZThreadExit();
uint64_t* actual_caps); uint64_t* actual_caps);
[[nodiscard]] z_err_t ZPortCreate(uint64_t* port_cap); [[nodiscard]] z_err_t ZPortCreate(uint64_t* port_cap);
[[nodiscard]] z_err_t ZPortSend(uint64_t port_cap, uint64_t num_bytes,
const uint8_t* bytes, uint64_t num_caps,
uint64_t* caps);
[[nodiscard]] z_err_t ZPortRecv(uint64_t port_cap, uint64_t num_bytes, [[nodiscard]] z_err_t ZPortRecv(uint64_t port_cap, uint64_t num_bytes,
uint8_t* bytes, uint64_t num_caps, uint8_t* bytes, uint64_t num_caps,
uint64_t* caps, uint64_t* type, uint64_t* caps, uint64_t* type,

View File

@ -204,6 +204,16 @@ z_err_t PortCreate(ZPortCreateResp* resp) {
return proc.AddNewCapability(port, ZC_WRITE | ZC_READ); return proc.AddNewCapability(port, ZC_WRITE | ZC_READ);
} }
z_err_t PortSend(ZPortSendReq* req) {
auto& proc = gScheduler->CurrentProcess();
auto port_cap = proc.GetCapability(req->port_cap);
RET_ERR(ValidateCap(port_cap, ZC_WRITE));
auto port = port_cap->obj<Port>();
RET_IF_NULL(port);
return port->Write(req->message);
}
z_err_t PortRecv(ZPortRecvReq* req) { z_err_t PortRecv(ZPortRecvReq* req) {
auto& proc = gScheduler->CurrentProcess(); auto& proc = gScheduler->CurrentProcess();
auto port_cap = proc.GetCapability(req->port_cap); auto port_cap = proc.GetCapability(req->port_cap);
@ -293,6 +303,8 @@ extern "C" z_err_t SyscallHandler(uint64_t call_id, void* req, void* resp) {
return ChannelRecv(reinterpret_cast<ZChannelRecvReq*>(req)); return ChannelRecv(reinterpret_cast<ZChannelRecvReq*>(req));
case Z_PORT_CREATE: case Z_PORT_CREATE:
return PortCreate(reinterpret_cast<ZPortCreateResp*>(resp)); return PortCreate(reinterpret_cast<ZPortCreateResp*>(resp));
case Z_PORT_SEND:
return PortSend(reinterpret_cast<ZPortSendReq*>(req));
case Z_PORT_RECV: case Z_PORT_RECV:
return PortRecv(reinterpret_cast<ZPortRecvReq*>(req)); return PortRecv(reinterpret_cast<ZPortRecvReq*>(req));
case Z_PORT_POLL: case Z_PORT_POLL:

View File

@ -170,6 +170,19 @@ z_err_t ZPortCreate(uint64_t* port_cap) {
return ret; return ret;
} }
z_err_t ZPortSend(uint64_t port_cap, uint64_t num_bytes, const uint8_t* bytes,
uint64_t num_caps, uint64_t* caps) {
ZPortSendReq req{.port_cap = port_cap,
.message = {
.type = 0,
.num_bytes = num_bytes,
.bytes = const_cast<uint8_t*>(bytes),
.num_caps = num_caps,
.caps = caps,
}};
return SysCall1(Z_PORT_SEND, &req);
}
z_err_t ZPortRecv(uint64_t port_cap, uint64_t num_bytes, uint8_t* bytes, z_err_t ZPortRecv(uint64_t port_cap, uint64_t num_bytes, uint8_t* bytes,
uint64_t num_caps, uint64_t* caps, uint64_t* type, uint64_t num_caps, uint64_t* caps, uint64_t* type,
uint64_t* actual_bytes, uint64_t* actual_caps) { uint64_t* actual_bytes, uint64_t* actual_caps) {

View File

@ -90,6 +90,11 @@ struct ZPortCreateResp {
uint64_t port_cap; uint64_t port_cap;
}; };
struct ZPortSendReq {
uint64_t port_cap;
ZMessage message;
};
struct ZPortRecvReq { struct ZPortRecvReq {
uint64_t port_cap; uint64_t port_cap;
ZMessage message; ZMessage message;