TAO/DevGuideExamples/PortableInterceptors/IOR/ClientInterceptor.cpp

   1 #include "ClientInterceptor.h"
   2 #include "tao/OctetSeqC.h"
   3 #include "tao/LocalObject.h"
   4 #include "tao/PI/ClientRequestInfo.h"
   5
   6 #include <iostream>
   7
   8 const CORBA::ULong service_ctx_id = 0xdeed;
   9
  10 ClientInterceptor::
  11 ClientInterceptor (IOP::CodecFactory_var cf)
  12   : myname_ ("Client_Authentication_Interceptor")
  13 {
  14   std::cout << "Calling ClientInterceptor constructor." << std::endl;
  15
  16   // Set up a structure that contains information necessary to
  17   // create a GIOP 1.2 CDR encapsulation Codec.
  18   IOP::Encoding encoding;
  19   encoding.format = IOP::ENCODING_CDR_ENCAPS;
  20   encoding.major_version = 1;
  21   encoding.minor_version = 2;
  22
  23   // Obtain the CDR encapsulation Codec.
  24   this->codec = cf->create_codec (encoding);
  25 }
  26
  27 ClientInterceptor::~ClientInterceptor ()
  28 {
  29 }
  30
  31 char *
  32 ClientInterceptor::name ()
  33 {
  34   std::cout << "Calling ClientInterceptor name() method" << std::endl;
  35   return CORBA::string_dup (this->myname_);
  36 }
  37
  38 void
  39 ClientInterceptor::destroy ()
  40 {
  41 }
  42
  43 void
  44 ClientInterceptor::send_poll (
  45                               PortableInterceptor::ClientRequestInfo_ptr ri)
  46 {
  47   ACE_UNUSED_ARG(ri);
  48   std::cout << "Calling send_poll()." << std::endl;
  49 }
  50
  51
  52 void
  53 ClientInterceptor::send_request (
  54                                  PortableInterceptor::ClientRequestInfo_ptr ri)
  55 {
  56   std::cout << "Calling send_request()." << std::endl;
  57
  58   const CORBA::ULong tagID = 9654;
  59
  60   try
  61     {
  62       IOP::TaggedComponent_var myTag = ri->get_effective_component(tagID);
  63       char *tag =
  64         reinterpret_cast<char*> (myTag->component_data.get_buffer());
  65
  66       std::cout << "IOR Tag is : " << tag << std::endl;
  67     }
  68   catch(...)
  69     {
  70       std::cerr << "Tagged Component not found" << std::endl;
  71     }
  72
  73   IOP::ServiceContext sc;
  74   sc.context_id = service_ctx_id;
  75
  76   const CORBA::Long gid = 9007;
  77
  78   std::cout << "GID: " << gid << std::endl;
  79
  80   CORBA::Any gid_as_any;
  81   gid_as_any <<= gid;
  82
  83   sc.context_data = *codec->encode(gid_as_any);
  84
  85   // Add this context to the service context list.
  86   ri->add_request_service_context (sc, false);
  87 }
  88
  89 void
  90 ClientInterceptor::receive_reply (
  91                                   PortableInterceptor::ClientRequestInfo_ptr ri)
  92 {
  93   ACE_UNUSED_ARG(ri);
  94   std::cout << "Calling receive_reply()." << std::endl;
  95 }
  96
  97 void
  98 ClientInterceptor::receive_other (
  99                                   PortableInterceptor::ClientRequestInfo_ptr ri)
 100 {
 101   ACE_UNUSED_ARG(ri);
 102   std::cout << "Calling receive_other()." << std::endl;
 103 }
 104
 105 void
 106 ClientInterceptor::receive_exception (
 107                                       PortableInterceptor::ClientRequestInfo_ptr ri)
 108 {
 109   ACE_UNUSED_ARG(ri);
 110   std::cout << "Calling receive_exception()." << std::endl;
 111 }