diff options
Diffstat (limited to 'TAO/orbsvcs/orbsvcs/CosEvent/CEC_Dispatching_Task.inl')
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/CosEvent/CEC_Dispatching_Task.inl | 85 |
1 files changed, 85 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Dispatching_Task.inl b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Dispatching_Task.inl new file mode 100644 index 00000000000..1432528492a --- /dev/null +++ b/TAO/orbsvcs/orbsvcs/CosEvent/CEC_Dispatching_Task.inl @@ -0,0 +1,85 @@ +// -*- C++ -*- +// +// $Id$ + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +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 */ + +TAO_END_VERSIONED_NAMESPACE_DECL |