TAO_CosEvent: CEC_Dispatching

00001 // -*- C++ -*-
00002 //
00003 // CEC_Dispatching_Task.i,v 1.5 2005/11/10 06:47:23 ossama Exp
00004 
00005 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
00006 
00007 ACE_INLINE
00008 TAO_CEC_Dispatching_Task::
00009 TAO_CEC_Dispatching_Task (ACE_Thread_Manager* thr_manager)
00010   :  ACE_Task<ACE_SYNCH> (thr_manager),
00011      allocator_ (0)
00012 {
00013 }
00014 
00015 // ****************************************************************
00016 
00017 ACE_INLINE
00018 TAO_CEC_Dispatch_Command::TAO_CEC_Dispatch_Command (ACE_Allocator *mb_allocator)
00019   :  ACE_Message_Block (mb_allocator)
00020 {
00021 }
00022 
00023 ACE_INLINE
00024 TAO_CEC_Dispatch_Command::TAO_CEC_Dispatch_Command (ACE_Data_Block *data_block,
00025                                                   ACE_Allocator *mb_allocator)
00026   :  ACE_Message_Block (data_block, 0, mb_allocator)
00027 {
00028 }
00029 
00030 // ****************************************************************
00031 
00032 ACE_INLINE
00033 TAO_CEC_Shutdown_Task_Command::
00034     TAO_CEC_Shutdown_Task_Command (ACE_Allocator *mb_allocator)
00035   :  TAO_CEC_Dispatch_Command (mb_allocator)
00036 {
00037 }
00038 
00039 // ****************************************************************
00040 
00041 ACE_INLINE
00042 TAO_CEC_Push_Command::TAO_CEC_Push_Command (TAO_CEC_ProxyPushSupplier* proxy,
00043                                             CORBA::Any& event,
00044                                             ACE_Data_Block* data_block,
00045                                             ACE_Allocator *mb_allocator)
00046   :  TAO_CEC_Dispatch_Command (data_block, mb_allocator),
00047      proxy_ (proxy)
00048 {
00049   //
00050   // Efficient copy, steal the buffer from <event>
00051   // We cannot do this on the initialization because get_buffer()
00052   // could get called first, effectively setting maximum() and
00053   // length() to 0!
00054   //
00055   // @@ TODO
00056   this->event_ = event;
00057 
00058   this->proxy_->_incr_refcnt ();
00059 }
00060 
00061 // ****************************************************************
00062 
00063 #if defined (TAO_HAS_TYPED_EVENT_CHANNEL)
00064 ACE_INLINE
00065 TAO_CEC_Invoke_Command::TAO_CEC_Invoke_Command (TAO_CEC_ProxyPushSupplier* proxy,
00066                                                 TAO_CEC_TypedEvent& typed_event,
00067                                                 ACE_Data_Block* data_block,
00068                                                 ACE_Allocator *mb_allocator)
00069   :  TAO_CEC_Dispatch_Command (data_block, mb_allocator),
00070      proxy_ (proxy)
00071 {
00072   //
00073   // Efficient copy, steal the buffer from <event>
00074   // We cannot do this on the initialization because get_buffer()
00075   // could get called first, effectively setting maximum() and
00076   // length() to 0!
00077   //
00078   // @@ TODO
00079   this->typed_event_ = typed_event;
00080 
00081   this->proxy_->_incr_refcnt ();
00082 }
00083 #endif /* TAO_HAS_TYPED_EVENT_CHANNEL */
00084 
00085 TAO_END_VERSIONED_NAMESPACE_DECL