cec_dispatching_task.i

来自「这是广泛使用的通信开源项目,对于大容量,高并发的通讯要求完全能够胜任,他广泛可用」· I 代码 · 共 80 行

// CEC_Dispatching_Task.i,v 1.4 2003/08/23 01:29:47 michel_j Exp

ACE_INLINE
TAO_CEC_Dispatching_Task::
TAO_CEC_Dispatching_Task (ACE_Thread_Manager* thr_manager)
  :  ACE_Task<ACE_SYNCH> (thr_manager),
     allocator_ (0)
{
}

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

ACE_INLINE
TAO_CEC_Dispatch_Command::TAO_CEC_Dispatch_Command (ACE_Allocator *mb_allocator)
  :  ACE_Message_Block (mb_allocator)
{
}

ACE_INLINE
TAO_CEC_Dispatch_Command::TAO_CEC_Dispatch_Command (ACE_Data_Block *data_block,
                                                  ACE_Allocator *mb_allocator)
  :  ACE_Message_Block (data_block, 0, mb_allocator)
{
}

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

ACE_INLINE
TAO_CEC_Shutdown_Task_Command::
    TAO_CEC_Shutdown_Task_Command (ACE_Allocator *mb_allocator)
  :  TAO_CEC_Dispatch_Command (mb_allocator)
{
}

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

ACE_INLINE
TAO_CEC_Push_Command::TAO_CEC_Push_Command (TAO_CEC_ProxyPushSupplier* proxy,
                                            CORBA::Any& event,
                                            ACE_Data_Block* data_block,
                                            ACE_Allocator *mb_allocator)
  :  TAO_CEC_Dispatch_Command (data_block, mb_allocator),
     proxy_ (proxy)
{
  //
  // Efficient copy, steal the buffer from <event>
  // We cannot do this on the initialization because get_buffer()
  // could get called first, effectively setting maximum() and
  // length() to 0!
  //
  // @@ TODO
  this->event_ = event;

  this->proxy_->_incr_refcnt ();
}

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

#if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
ACE_INLINE
TAO_CEC_Invoke_Command::TAO_CEC_Invoke_Command (TAO_CEC_ProxyPushSupplier* proxy,
                                                TAO_CEC_TypedEvent& typed_event,
                                                ACE_Data_Block* data_block,
                                                ACE_Allocator *mb_allocator)
  :  TAO_CEC_Dispatch_Command (data_block, mb_allocator),
     proxy_ (proxy)
{
  //
  // Efficient copy, steal the buffer from <event>
  // We cannot do this on the initialization because get_buffer()
  // could get called first, effectively setting maximum() and
  // length() to 0!
  //
  // @@ TODO
  this->typed_event_ = typed_event;

  this->proxy_->_incr_refcnt ();
}
#endif /* TAO_HAS_TYPED_EVENT_CHANNEL */