47 lines
1.2 KiB
C++
47 lines
1.2 KiB
C++
#pragma once
|
|
|
|
#include <glacier/container/intrusive_list.h>
|
|
#include <glacier/memory/ref_ptr.h>
|
|
#include <glacier/status/error.h>
|
|
|
|
#include "lib/message_queue.h"
|
|
#include "object/ipc_object.h"
|
|
#include "object/kernel_object.h"
|
|
|
|
class Endpoint;
|
|
class ReplyPort;
|
|
|
|
template <>
|
|
struct KernelObjectTag<Endpoint> {
|
|
static const uint64_t type = KernelObject::ENDPOINT;
|
|
};
|
|
|
|
class Endpoint : public IpcObject {
|
|
public:
|
|
uint64_t TypeTag() override { return KernelObject::ENDPOINT; }
|
|
static uint64_t DefaultPermissions() {
|
|
return kZionPerm_Read | kZionPerm_Write | kZionPerm_Duplicate |
|
|
kZionPerm_Transmit;
|
|
}
|
|
|
|
static glcr::RefPtr<Endpoint> Create();
|
|
|
|
// FIXME: These are hacky "almost" overrides that could lead to bugs.
|
|
glcr::ErrorCode Send(uint64_t num_bytes, const void* data, uint64_t num_caps,
|
|
const z_cap_t* caps, z_cap_t reply_port_cap);
|
|
glcr::ErrorCode Recv(uint64_t* num_bytes, void* data, uint64_t* num_caps,
|
|
z_cap_t* caps, z_cap_t* reply_port_cap);
|
|
|
|
virtual MessageQueue& GetSendMessageQueue() override {
|
|
return message_queue_;
|
|
}
|
|
virtual MessageQueue& GetRecvMessageQueue() override {
|
|
return message_queue_;
|
|
}
|
|
|
|
private:
|
|
UnboundedMessageQueue message_queue_;
|
|
|
|
Endpoint() {}
|
|
};
|