ecg_cdr_message_receiver.i

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

// ECG_CDR_Message_Receiver.i,v 1.2 2003/06/18 22:08:59 bala Exp

ACE_INLINE
TAO_ECG_CDR_Message_Receiver::Requests::Requests (void)
  : fragmented_requests_ (0)
  , size_ (0)
  , id_range_low_ (0)
  , id_range_high_ (0)
  , min_purge_count_ (0)
{
}

// ****************************************************************

ACE_INLINE
TAO_ECG_CDR_Message_Receiver::TAO_ECG_CDR_Message_Receiver (CORBA::Boolean crc)
  : ignore_from_ ()
  , request_map_ ()
  /* , lock_ (0) */
  , max_requests_ (ECG_DEFAULT_MAX_FRAGMENTED_REQUESTS)
  , min_purge_count_ (ECG_DEFAULT_FRAGMENTED_REQUESTS_MIN_PURGE_COUNT)
  , check_crc_ (crc)
{
//    ACE_NEW (this->lock_,
//             ACE_Lock_Adapter<ACE_Null_Mutex>);
}

ACE_INLINE
TAO_ECG_CDR_Message_Receiver::~TAO_ECG_CDR_Message_Receiver (void)
{
  this->shutdown ();
}

ACE_INLINE void
TAO_ECG_CDR_Message_Receiver::init (TAO_ECG_Refcounted_Endpoint ignore_from
                                    /*, ACE_Lock *lock */)
{
  this->ignore_from_ = ignore_from;

//    if (lock)
//      {
//        delete this->lock_;
//        this->lock_ = lock;
//      }
}

ACE_INLINE void
TAO_ECG_CDR_Message_Receiver::shutdown (void)
{
  // ACE_GUARD (ACE_Lock, guard, *this->lock_);

  Request_Map::iterator end = this->request_map_.end ();
  for (Request_Map::iterator i =  this->request_map_.begin ();
       i != end;
       ++i)
    {
      delete (*i).int_id_;
      (*i).int_id_ = 0;
    }

  TAO_ECG_Refcounted_Endpoint empty_endpoint;
  this->ignore_from_ = empty_endpoint;
}