Messenger.h

Go to the documentation of this file.

//========================================================================
// Copyright (c) 2014-2015 Yannick Pflanzer <neo-engine.de>
//
// This software is provided 'as-is', without any express or implied
// warranty. In no event will the authors be held liable for any damages
// arising from the use of this software.
//
// Permission is granted to anyone to use this software for any purpose,
// including commercial applications, and to alter it and redistribute it
// freely, subject to the following restrictions:
//
// 1. The origin of this software must not be misrepresented; you must not
//    claim that you wrote the original software. If you use this software
//    in a product, an acknowledgment in the product documentation would
//    be appreciated but is not required.
//
// 2. Altered source versions must be plainly marked as such, and must not
//    be misrepresented as being the original software.
//
// 3. This notice may not be removed or altered from any source
//    distribution.
//
//========================================================================

#ifndef __MESSENGER_H__
#define __MESSENGER_H__

#include <string>
#include <map>
#include <deque>

namespace Neo
{

struct Message
{
    std::string message;
    std::string sender;
    unsigned int messageId;
    void* data;
};

class NEO_ENGINE_EXPORT Messenger
{
private:
    struct Inbox
    {
        std::string name;
        unsigned int id;

        std::deque<Message> messages;
    };

    std::map<std::string, Inbox> m_boxes;
    Semaphore* m_semaphore;

    void waitForAccess();
    void finishAccess();

    bool m_locked;

public:
    static Messenger* getInstance()
    {
        static Messenger m_instance;
        return &m_instance;
    }

    Messenger() : m_semaphore(NULL), m_locked(false) {}

    void addInbox(const char* name, unsigned int id);

    unsigned int getMessagesCount(const char* name);

    void sendMessage(const char* message, unsigned int messageId, void* data, const char* dest, const char* from);

    Message getNextMessage(const char* threadName);

    Message getNextMessage(const char* threadName, const char* sender);
};
}

#endif