diff options
| author | bala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-10-28 18:31:01 +0000 |
|---|---|---|
| committer | bala <bala@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2003-10-28 18:31:01 +0000 |
| commit | cdb6fd66611283a0314ab23e08472d11dae4f0e4 (patch) | |
| tree | fd6ae8c3db752254802dfaafd1543974a4741e47 /TAO/tao/RTScheduling/Request_Interceptor.cpp | |
| parent | f984aa2bff444f381570d2f97ac9ba958926fb6b (diff) | |
| download | ATCD-cdb6fd66611283a0314ab23e08472d11dae4f0e4.tar.gz | |
ChangeLogTag:Tue Oct 28 12:02:47 2003 Balachandran Natarajan <bala@dre.vanderbilt.edu>
Diffstat (limited to 'TAO/tao/RTScheduling/Request_Interceptor.cpp')
| -rw-r--r-- | TAO/tao/RTScheduling/Request_Interceptor.cpp | 37 |
1 files changed, 20 insertions, 17 deletions
diff --git a/TAO/tao/RTScheduling/Request_Interceptor.cpp b/TAO/tao/RTScheduling/Request_Interceptor.cpp index 95e90c2ed2a..cd5fb5ed4ad 100644 --- a/TAO/tao/RTScheduling/Request_Interceptor.cpp +++ b/TAO/tao/RTScheduling/Request_Interceptor.cpp @@ -4,7 +4,10 @@ #include "Current.h" #include "Distributable_Thread.h" #include "tao/TSS_Resources.h" - +#include "tao/debug.h" +#include "tao/Any.h" +#include "tao/Typecode.h" +#include "tao/ORB_Constants.h" ACE_RCSID (RTScheduling, Request_Interceptor, @@ -175,11 +178,11 @@ Client_Interceptor::receive_exception (PortableInterceptor::ClientRequestInfo_pt if (current != 0) { if (ri == 0) - { - ACE_ERROR ((LM_ERROR, - "ri = 0\n")); - return; - } + { + ACE_ERROR ((LM_ERROR, + "ri = 0\n")); + return; + } CORBA::Any_var ex = ri->received_exception (ACE_ENV_SINGLE_ARG_PARAMETER); @@ -187,11 +190,11 @@ Client_Interceptor::receive_exception (PortableInterceptor::ClientRequestInfo_pt CORBA::TypeCode_var type = ex->type (); if (CORBA::is_nil (type.in ())) - { - ACE_ERROR ((LM_ERROR, - "type = 0 \n")); - return; - } + { + ACE_ERROR ((LM_ERROR, + "type = 0 \n")); + return; + } const char * id = type->id (); if (TAO_debug_level > 0) @@ -295,8 +298,8 @@ Server_Interceptor::receive_request (PortableInterceptor::ServerRequestInfo_ptr ACE_CATCHANY { if (TAO_debug_level > 0) - ACE_DEBUG ((LM_DEBUG, - "Invalid Service Request\n")); + ACE_DEBUG ((LM_DEBUG, + "Invalid Service Request\n")); return; } ACE_ENDTRY; @@ -405,15 +408,15 @@ Server_Interceptor::send_reply (PortableInterceptor::ServerRequestInfo_ptr ri current->cancel_thread (ACE_ENV_SINGLE_ARG_PARAMETER); ACE_CHECK; - return; + return; } else ACE_DEBUG ((LM_DEBUG, - "Thread Not Cancelled\n")); + "Thread Not Cancelled\n")); // Inform scheduler that upcall is complete. current->scheduler ()->send_reply (ri - ACE_ENV_ARG_PARAMETER); + ACE_ENV_ARG_PARAMETER); ACE_CHECK; current->cleanup_DT (); @@ -431,7 +434,7 @@ Server_Interceptor::send_reply (PortableInterceptor::ServerRequestInfo_ptr ri } else ACE_DEBUG ((LM_DEBUG, - "Send Reply Current is 0\n")); + "Send Reply Current is 0\n")); } void |