MessagePump.h

Go to the documentation of this file.

/*
* MessagePump - Message pump class. Will receive async messages from
*               and store them. The messages are forwared
*               to the handling classes by this class too.
*
* @Author Michael <Tharbas> Matzen
*
* This program is free software; you can redistribute it and/or modify it
* under the terms of the GNU General Public License as published by the Free
* Software Foundation; either version 2 of the License, or (at your option)
* any later version.
*
* This program is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
* more details.
*
* You should have received a copy of the GNU General Public License along with
* this program; if not, write to the Free Software Foundation, Inc., 51
* Franklin St, Fifth Floor, Boston, MA 02110, USA
* 
*/

#pragma once

#include "WindowsIncludes.h"
#include <tbb_thread.h>
#include <task_scheduler_init.h>
#include <concurrent_hash_map.h>
#include <concurrent_queue.h>
#include <task.h>
#include <stdio.h>
#include <string>

#include "Utils.h"
#include "SraNetworkShared.h"
#include "SraBaseMessage.h"
#include "SraPacket.h"

namespace SraNetwork
{
    class MessagePump
    {
    public:
        static MessagePump* Instance;

        void AddMessage(RakNet::Packet* packet);

        void Shutdown();

        
        static void Run();

    private:
        MessagePump(void);
        ~MessagePump(void);

        static tbb::concurrent_queue<MessageData> messageList;

        static bool isRunning;
        // A map of SraNetwork::MessageIdentifier->BaseMessageImpl
        static tbb::concurrent_hash_map<int, SraBaseMessage*>  messageProcessorTable;

    };
}