event_utilities.i

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

/* -*- C++ -*- */
// Event_Utilities.i,v 1.9 2000/05/10 19:30:02 coryan Exp


ACE_INLINE int
ACE_ConsumerQOS_Factory::insert (RtecEventComm::EventSourceID source,
                                 RtecEventComm::EventType type,
                                 RtecBase::handle_t rt_info)
{
  RtecEventChannelAdmin::Dependency dependency;
  if (this->event_initializer_ != 0)
    (*this->event_initializer_) (dependency.event);
  dependency.event.header.source = source;
  dependency.event.header.type = type;
  //dependency.event.header.creation_time = 0;
  //dependency.event.header.ec_recv_time = 0;
  //dependency.event.header.ec_send_time = 0;
  dependency.rt_info = rt_info;
  return this->insert (dependency);
}

ACE_INLINE int
ACE_ConsumerQOS_Factory::insert_bitmasked_value (CORBA::ULong source_mask,
                                                 CORBA::ULong type_mask,
                                                 CORBA::ULong source_value,
                                                 CORBA::ULong type_value)

{
  RtecEventChannelAdmin::Dependency dependency;
  if (this->event_initializer_ != 0)
    (*this->event_initializer_) (dependency.event);
  dependency.event.header.type = ACE_ES_MASKED_TYPE_DESIGNATOR;
  dependency.event.header.source = 0;
  //dependency.event.header.creation_time = 0;
  //dependency.event.header.ec_recv_time = 0;
  //dependency.event.header.ec_send_time = 0;
  dependency.rt_info = 0;
  this->insert (dependency);

  dependency.event.header.source = source_mask;
  dependency.event.header.type = type_mask;
  this->insert (dependency);

  dependency.event.header.source = source_value;
  dependency.event.header.type = type_value;
  return this->insert (dependency);
}

ACE_INLINE int
ACE_ConsumerQOS_Factory::insert_null_terminator (void)
{
  RtecEventChannelAdmin::Dependency dependency;
  if (this->event_initializer_ != 0)
    (*this->event_initializer_) (dependency.event);
  dependency.event.header.type = ACE_ES_NULL_DESIGNATOR;
  dependency.event.header.source = 0;
  return this->insert (dependency);
}

ACE_INLINE int
ACE_ConsumerQOS_Factory::insert_type (RtecEventComm::EventType type,
                                      RtecBase::handle_t rt_info)
{
  RtecEventChannelAdmin::Dependency dependency;
  if (this->event_initializer_ != 0)
    (*this->event_initializer_) (dependency.event);
  dependency.event.header.source = ACE_ES_EVENT_SOURCE_ANY;
  dependency.event.header.type = type;
  //dependency.event.header.creation_time = 0;
  //dependency.event.header.ec_recv_time = 0;
  //dependency.event.header.ec_send_time = 0;
  dependency.rt_info = rt_info;
  return this->insert (dependency);
}

ACE_INLINE int
ACE_ConsumerQOS_Factory::insert_source (RtecEventComm::EventSourceID source,
                                        RtecBase::handle_t rt_info)
{
  RtecEventChannelAdmin::Dependency dependency;
  if (this->event_initializer_ != 0)
    (*this->event_initializer_) (dependency.event);
  dependency.event.header.source = source;
  dependency.event.header.type = ACE_ES_EVENT_ANY;
  //dependency.event.header.creation_time = 0;
  //dependency.event.header.ec_recv_time = 0;
  //dependency.event.header.ec_send_time = 0;
  dependency.rt_info = rt_info;
  return this->insert (dependency);
}

ACE_INLINE int
ACE_ConsumerQOS_Factory::insert_time (RtecEventComm::EventType type,
                                      RtecEventComm::Time interval,
                                      RtecBase::handle_t rt_info)
{
  RtecEventChannelAdmin::Dependency dependency;
  if (this->event_initializer_ != 0)
    (*this->event_initializer_) (dependency.event);
  dependency.event.header.source = ACE_ES_EVENT_SOURCE_ANY;
  dependency.event.header.type = type;
  dependency.event.header.creation_time = interval;
  //dependency.event.header.ec_recv_time = 0;
  //dependency.event.header.ec_send_time = 0;
  dependency.rt_info = rt_info;
  return this->insert (dependency);
}

ACE_INLINE int
ACE_ConsumerQOS_Factory::insert_act (RtecEventComm::EventData act)
{
  RtecEventChannelAdmin::Dependency dependency;
  if (this->event_initializer_ != 0)
    (*this->event_initializer_) (dependency.event);
  dependency.event.header.source = 0;
  dependency.event.header.type = ACE_ES_EVENT_ACT;
  //dependency.event.header.creation_time = 0;
  //dependency.event.header.ec_recv_time = 0;
  //dependency.event.header.ec_send_time = 0;
  dependency.event.data = act;
  return this->insert (dependency);
}

ACE_INLINE const RtecEventChannelAdmin::ConsumerQOS&
ACE_ConsumerQOS_Factory::get_ConsumerQOS (void)
{
  return qos_;
}

ACE_INLINE
ACE_ConsumerQOS_Factory::operator const RtecEventChannelAdmin::ConsumerQOS& (void)
{
  return qos_;
}

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

ACE_INLINE const RtecEventChannelAdmin::SupplierQOS&
ACE_SupplierQOS_Factory::get_SupplierQOS (void)
{
  return qos_;
}

ACE_INLINE
ACE_SupplierQOS_Factory::operator const RtecEventChannelAdmin::SupplierQOS& (void)
{
  return qos_;
}