update_manager.cpp

这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用于网络游戏医学图像网关的高qos要求.更详细的内容可阅读相应的材料

// Update_Manager.cpp,v 1.2 2003/10/15 18:06:29 huangming Exp

#include "Update_Manager.h"

ACE_RCSID (EventChannel,
           Update_Manager,
           "Update_Manager.cpp,v 1.2 2003/10/15 18:06:29 huangming Exp")


Update_Manager::Update_Manager(ACE_Auto_Event& evt,
                               int num_backups,
                               int transaction_depth,
                               bool& success)
: evt_(evt)
, replied_(num_backups)
, suicide_condition_(num_backups)
, num_backups_(num_backups)
, transaction_level_(transaction_depth)
, success_(success)
{
  suicide_condition_.flip();
  signal_condition_.resize(transaction_depth, true);
  signal_condition_.resize(num_backups);
}

Update_Manager::~Update_Manager()
{
}

void Update_Manager::handle_reply(int id)
{
  ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
  replied_[id] = true;

  if ((replied_ & signal_condition_) == signal_condition_) {
    success_ = true;
    evt_.signal();
  }
  if (replied_ == suicide_condition_)
    delete this;
}

void Update_Manager::handle_exception(int id)
{
  ACE_Guard<ACE_Thread_Mutex> guard(mutex_);
  replied_[id] = true;
  ++transaction_level_;

  if (num_backups_ > transaction_level_) {
    signal_condition_[transaction_level_]=true;
  }
  else {
    success_ = false;
    evt_.signal();
  }
  if (replied_ == suicide_condition_)
    delete this;
}