diff options
Diffstat (limited to 'ACE/TAO/tao/CSD_ThreadPool/CSD_TP_Collocated_Asynch_Request.cpp')
-rw-r--r-- | ACE/TAO/tao/CSD_ThreadPool/CSD_TP_Collocated_Asynch_Request.cpp | 55 |
1 files changed, 55 insertions, 0 deletions
diff --git a/ACE/TAO/tao/CSD_ThreadPool/CSD_TP_Collocated_Asynch_Request.cpp b/ACE/TAO/tao/CSD_ThreadPool/CSD_TP_Collocated_Asynch_Request.cpp new file mode 100644 index 00000000000..ff94e678bb3 --- /dev/null +++ b/ACE/TAO/tao/CSD_ThreadPool/CSD_TP_Collocated_Asynch_Request.cpp @@ -0,0 +1,55 @@ +// $Id$ + +#include "tao/CSD_ThreadPool/CSD_TP_Collocated_Asynch_Request.h" + +ACE_RCSID (CSD_ThreadPool, + TP_Collocated_Asynch_Request, + "$Id$") + +#if !defined (__ACE_INLINE__) +# include "tao/CSD_ThreadPool/CSD_TP_Collocated_Asynch_Request.inl" +#endif /* ! __ACE_INLINE__ */ + + +TAO_BEGIN_VERSIONED_NAMESPACE_DECL + +TAO::CSD::TP_Collocated_Asynch_Request::~TP_Collocated_Asynch_Request() +{ +} + + +void +TAO::CSD::TP_Collocated_Asynch_Request::prepare_for_queue_i() +{ + this->do_clone(); +} + + +void +TAO::CSD::TP_Collocated_Asynch_Request::dispatch_i() +{ + try + { + this->do_dispatch(); + } + catch (const ::CORBA::Exception&) + { + // Eat these. We probably should log these, but since we have already + // unblocked the requesting thread there is no point in saving it or + // doing anything with it. + } + catch (...) + { + // Eat these. We probably should log these, but since we have already + // unblocked the requesting thread there is no point in saving it or + // doing anything with it. + } +} + +void +TAO::CSD::TP_Collocated_Asynch_Request::cancel_i() +{ + this->do_cancel(); +} + +TAO_END_VERSIONED_NAMESPACE_DECL |