开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 游戏 > 模拟服务器 > 查看源码
Multicaster.cpp
资源名称：SwordOnline.rar　[点击查看]
上传用户：dzyhzl
上传日期：2019-04-29
资源大小：56270k
文件大小：2k
源码类别：

模拟服务器

开发平台：

C/C++

Multicaster.cpp：源码内容
  2. #include "Multicaster.h"
  4. bool Multicaster::subscribe (MulticastObserver *observer, std::string address)
  5. {
  6.     AddressSpace::iterator  it = m_addresses.find (address);
  8.     if (it == m_addresses.end ())
  9.     {
  10.         m_addresses.insert (std::pair<std::string, Subscriptions> (address, Subscriptions ()));       
  11.         it = m_addresses.find (address);
  13.         if (it == m_addresses.end ())
  14.             return false;
  15.     }
  17.     (*it).second.push_back (observer);
  18.     return true;
  20. }
  23. bool Multicaster::unsubscribe (MulticastObserver *observer, std::string address)
  24. {
  25.     AddressSpace::iterator  it = m_addresses.find (address);
  27.     if (it == m_addresses.end ())
  28.         return false;
  30.     unsubscribe ((*it).second, observer);
  32.     return true;
  34. }
  36. bool Multicaster::publish (MulticastObserver *publisher, std::string address, Value value)
  37. {
  38.     AddressSpace::iterator  it = m_addresses.find (address);
  40.     if (it == m_addresses.end ())
  41.         return false;
  43.     Subscriptions& subscriptions = (*it).second;
  45.     for (Subscriptions::iterator subit = subscriptions.begin ();
  46.             subit != subscriptions.end ();
  47.             ++subit) {
  48.  
  49.         MulticastObserver *subscriber = *subit;
  51.         if (subscriber != publisher)
  52.             subscriber->accept (address, value);
  53.         
  54.     } 
  56.     return true;
  57. }
  60. void Multicaster::unsubscribeFromAll (MulticastObserver *observer)
  61. {
  62.     for (AddressSpace::iterator it = m_addresses.begin ();
  63.             it != m_addresses.end ();
  64.             ++it)
  65.         unsubscribe ((*it).second, observer);
  66. }
  69. void Multicaster::unsubscribe (Subscriptions& subscriptions, MulticastObserver *observerToRemove)
  70. {
  71.     for (Subscriptions::iterator it = subscriptions.begin (); it != subscriptions.end (); ) {
  72.         if (*it == observerToRemove)
  73.             it = subscriptions.erase (it);
  74.         else
  75.             it++;
  76.     }
  78. }