wg_message_server.h

// wg_message_server.h
//
// CMessageServer interface
//
//
// Copyright (c) 2002-2004 Rob Wiskow
// rob-dev@boxedchaos.com
//
// This library is free software; you can redistribute it and/or
// modify it under the terms of the GNU Lesser General Public
// License as published by the Free Software Foundation; either
// version 2.1 of the License, or (at your option) any later version.
//
// This library 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
// Lesser General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public
// License along with this library; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
//


#ifndef _WG_MESSAGE_SERVER_H_
#define _WG_MESSAGE_SERVER_H_


#include "wgui_include_config.h"
#include "wg_message.h"
#include <deque>
#include <map>
#include "SDL.h"
#include "SDL_thread.h"


namespace wGui
{

class CMessageClient;

struct s_MessageClientActive
{
     s_MessageClientActive(CMessageClient* pC, bool bW) :
          pClient(pC), bWaitingForMessage(bW)
     { }

     CMessageClient* pClient;  
     bool bWaitingForMessage;  
};

typedef std::multimap<unsigned char, s_MessageClientActive, std::greater<unsigned char> > t_MessageClientPriorityMap;

typedef std::map<wGui::CMessage::EMessageType, t_MessageClientPriorityMap> t_MessageClientMap;




class CMessageServer
{
protected:
     CMessageServer(void);

     virtual ~CMessageServer(void);


public:
     enum EClientPriority
     {
          PRIORITY_LAST = 0,  
          PRIORITY_LOW = 50,  
          PRIORITY_NORMAL = 100,  
          PRIORITY_HIGH = 150,  
          PRIORITY_FIRST = 255  
     };

     static CMessageServer& Instance(void);

     void RegisterMessageClient(CMessageClient* pClient, CMessage::EMessageType eMessageType, unsigned char Priority = PRIORITY_NORMAL);

     void DeregisterMessageClient(CMessageClient* pClient, CMessage::EMessageType eMessageType);

     void DeregisterMessageClient(CMessageClient* pClient);

     void DeliverMessage(void);

     void QueueMessage(CMessage* pMessage);

     bool MessageAvailable(void) { return m_MessageQueue.size() > 0; }

     void IgnoreAllNewMessages(bool bIgnore) { m_bIgnoreAllNewMessages = bIgnore; }


protected:
     static CMessageServer* m_pInstance;  
     std::deque<CMessage*> m_MessageQueue;  
     t_MessageClientMap m_MessageClients;  
     SDL_sem* m_pSemaphore;  
     bool m_bIgnoreAllNewMessages;  
};

}


#include "unit_tests/wg_message_server_unittests.h"

#endif // _WG_MESSAGE_SERVER_H_

---