message.h

Go to the documentation of this file.

/*===========================================================================
     _____        _____        _____        _____
 ___|    _|__  __|_    |__  __|__   |__  __| __  |__  ______
|    \  /  | ||    \      ||     |     ||  |/ /     ||___   |
|     \/   | ||     \     ||     \     ||     \     ||___   |
|__/\__/|__|_||__|\__\  __||__|\__\  __||__|\__\  __||______|
    |_____|      |_____|      |_____|      |_____|

--[Mark3 Realtime Platform]--------------------------------------------------

Copyright (c) 2012 - 2019 m0slevin, all rights reserved.
See license.txt for more information
=========================================================================== */
#pragma once

#include "kerneltypes.h"
#include "mark3cfg.h"

#include "ll.h"
#include "ksemaphore.h"
#include "timerlist.h"

namespace Mark3
{
//---------------------------------------------------------------------------
class Message : public TypedLinkListNode<Message>
{
public:
    void* operator new(size_t sz, void* pv) { return reinterpret_cast<Message*>(pv); }
    void Init()
    {
        ClearNode();
        m_pvData  = nullptr;
        m_u16Code = 0;
    }

    void SetData(void* pvData_) { m_pvData = pvData_; }
    void* GetData() { return m_pvData; }
    void SetCode(uint16_t u16Code_) { m_u16Code = u16Code_; }
    uint16_t GetCode() { return m_u16Code; }

private:
    void* m_pvData;

    uint16_t m_u16Code;
};

//---------------------------------------------------------------------------
class MessagePool
{
public:
    void* operator new(size_t sz, void* pv) { return (MessagePool*)pv; }
    ~MessagePool() {}
    void Init();

    void Push(Message* pclMessage_);

    Message* Pop();

    Message* GetHead();

private:
    TypedDoubleLinkList<Message> m_clList;
};

//---------------------------------------------------------------------------
class MessageQueue
{
public:
    void* operator new(size_t sz, void* pv) { return (MessageQueue*)pv; }
    ~MessageQueue() {}

    void Init();

    Message* Receive();

    Message* Receive(uint32_t u32TimeWaitMS_);

    void Send(Message* pclSrc_);

    uint16_t GetCount();

private:
    Message* Receive_i(uint32_t u32TimeWaitMS_);

    Semaphore m_clSemaphore;

    TypedDoubleLinkList<Message> m_clLinkList;
};
} // namespace Mark3