#include "hello.h" #include #ifdef HAVE_UNISTD_H #include #endif #ifdef _WIN32 #include #endif using namespace std; class MyClientInterceptor : virtual public PortableInterceptor::ClientRequestInterceptor, virtual public CORBA::LocalObject { string nm; int count_; public: MyClientInterceptor() : count_(0) { nm = ""; } MyClientInterceptor(const char * name) : count_(0) { nm = name; } char* name() { return CORBA::string_dup(nm.c_str()); } void destroy() { cerr << this->name() << " destroy" << endl; } void send_request(PortableInterceptor::ClientRequestInfo_ptr ri) { cout << "client: send_request" << endl; /* if (!count_) { CORBA::Object_ptr target = ri->target(); count_++; throw PortableInterceptor::ForwardRequest(target, false); } */ } void send_poll(PortableInterceptor::ClientRequestInfo_ptr ri) { cout << "client: send_poll" << endl; } void receive_reply(PortableInterceptor::ClientRequestInfo_ptr ri) { cout << "client: receive_reply" << endl; } void receive_exception(PortableInterceptor::ClientRequestInfo_ptr ri) { cout << "client: receive_exception" << endl; } void receive_other(PortableInterceptor::ClientRequestInfo_ptr ri) { cout << "client: receive_other" << endl; } }; class MyInitializer : virtual public PortableInterceptor::ORBInitializer, virtual public CORBA::LocalObject { public: MyInitializer() {} ~MyInitializer() {} virtual void pre_init(PortableInterceptor::ORBInitInfo_ptr info) { // register interceptor MyClientInterceptor * interceptor = new MyClientInterceptor("MyInterceptor"); info->add_client_request_interceptor(interceptor); } virtual void post_init(PortableInterceptor::ORBInitInfo_ptr info) { // nothing } }; int main (int argc, char *argv[]) { MyInitializer* ini = new MyInitializer; PortableInterceptor::register_orb_initializer(ini); CORBA::ORB_var orb = CORBA::ORB_init (argc, argv); char pwd[256], uri[300]; sprintf (uri, "file://%s/hello.ref", getcwd(pwd, 256)); // for mem-leak checking, please uncomment following loop //for (unsigned long i = 0; i < 100000; i++) { CORBA::Object_var obj = orb->string_to_object (uri); assert(!CORBA::is_nil(obj)); try { CORBA::Request_var req = obj->_request("hello"); req->result()->value()->set_type(CORBA::_tc_void); req->send_deferred(); //req->poll_response(); req->get_response(); } catch (CORBA::Exception& ex) { cout << "client: caught: " << ex._repoid() << endl; } //} return 0; }