ipc.h

Go to the documentation of this file.

 
#ifndef MAXOS_PROCESSES_IPC_H
#define MAXOS_PROCESSES_IPC_H
 
#include <cstdint>
#include <cstddef>
 
#include <libcommon/vector.h>
#include <libcommon/string.h>
#include <libcommon/buffer.h>
#include <libcommon/spinlock.h>
 
#include <memory/physical.h>
#include <memory/memoryIO.h>
#include <processes/resources/resource.h>
#include <processes/block.h>
 
namespace MaxOS::processes {
 
    typedef struct IPCIOVector {
 
        const void* address;
        size_t length;
 
    } ipc_iovec_t;
 
    class SharedMemory final : public resources::Resource {
 
        private:
            uintptr_t m_physical_address;
            size_t m_size;
 
            common::Map<size_t, uintptr_t> m_mappings;
 
        public:
            SharedMemory(const string& name, size_t size, resources::resource_type_t type);
            ~SharedMemory() final;
 
            void open(size_t flags) final;
            void close(size_t flags) final;
 
            int read(void* buffer, size_t size, size_t flags) final;
 
            [[nodiscard]] uintptr_t physical_address() const;
            [[nodiscard]] size_t size() const;
    };
 
    class SharedMessageEndpoint final : public resources::Resource {
 
        private:
            common::Vector<common::buffer_t*> m_queue { };
            BlockingLock m_message_lock;
 
        public:
            SharedMessageEndpoint(const string& name, size_t size, resources::resource_type_t type);
            ~SharedMessageEndpoint() final;
 
            void send(const ipc_iovec_t* vec, size_t count);
 
            int read(void* buffer, size_t size, size_t flags) final;
            int write(const void* buffer, size_t size, size_t flags) final;
    };
}
 
 
#endif // MAXOS_PROCESSES_IPC_H