|
|
|
|
|
|
上記の手順は通常、繰り返し行います。たとえば、最初にインターセプタをビルドしてテストするときは、そのインターセプタが実行中であることを確認するだけの最も基本的なコードのみとします。その後のビルドとテストで、インターセプタの全機能を徐々に実装していきます。
PQ parser;
PQ::op_key key = parser.MapOperation(request_context.operation.in());
switch (key)
{
default:
m_outfile << ��� ERROR: operation is not member of ���
<< request_context.interface_id.in() << endl;
excep_val = new CORBA::BAD_OPERATION();
return Interceptors::REPLY_EXCEPTION;
case PQ::Exit:
m_outfile << endl;
return ret_status;
case PQ::ByPerson:
{
PersonQuery::Person per;
parser.GetByPerson(request_arg_stream, &per);
m_outfile << ��� Parameters:��� << endl;
m_outfile << per << endl;
}
break;クライアント・リクエストからインタフェースIDを抽出するのは、かなり単純な作業です。しかし、ターゲット・レスポンスで同じ処理を行う場合はそれほど単純ではありません。ORBから受信するレスポンスに関連付けられたインタフェースおよびオペレーションを知る必要がある場合、インターセプタはリクエストを追跡するための特別なロジックを必要とします。クライアントから受信したリクエストの追跡は、インターセプタの役割です。InterceptorDataサンプルは、Trackerと呼ばれる言語オブジェクトを実装します。これはターゲットに送られるリクエストの記録を取り、インターセプタにターゲット・レスポンスが返ると、それらのリクエストにレスポンスを適合させるオブジェクトです。InterceptorDataサンプルのclient_responseおよびtarget_responseオペレーションは、ターゲットからレスポンスが返ると、Trackerオブジェクトからインタフェースおよびオペレーションの情報を抽出します。RequestInfo * req_info = m_tracker->CompleteRequest(reply_context);
if (!req_info)
{
m_outfile << ��� unable to find request for this reply (must not be one
we care about)��� << endl << endl;
return Interceptors::RESPONSE_NO_EXCEPTION;
}
//
// This is the interface we are expecting. Now identify the operation
// being invoked, so we can parse the request parameters.
//
m_outfile << ��� ReplyStatus: ���;
OutputReplyStatus(m_outfile, reply_context.reply_status);
m_outfile << endl;
m_outfile << ��� Interface: ��� << req_info->intf() << endl;
m_outfile << ��� Operation: ��� << req_info->op() << endl;
PQ parser;
PQ::op_key key = parser.MapOperation(req_info->op());次のコードの抜粋部分は、InterceptorDataのサンプルがどのようにして、データ・ストリームからのリクエスト・パラメータを構造体に入れるのかの例を示しています。次のコード抜粋部分のパラメータSは、インターセプタの実装によりPersonQueryオペレーションの応答パラメータ値を取得するのに使用可能なDataInputStream構造体へのポインタを表します。このコード抜粋部分において、中カッコで囲まれたコードは、DataInputStream構造体からのレスポンスのパラメータを抽出するものです。DataInputStream構造体の詳細は、第7章「リクエスト・レベルのインターセプタのAPI」を参照してください。excep_valパラメータ経由で返されたインターセプタからの例外は、CORBA::SystemException基本クラスから派生したタイプのみです。(これ以外で、インターセプタの実装がORBに返す例外のタイプはすべて、ORBによってCORBA::UNKNOWN例外に変換され、excep_valパラメータを介して渡されます。)例外はCORBA::SystemExceptionクラスまたはその派生クラスの1つにマップする必要があります。#include <CORBA.h>
#include <RequestLevelInterceptor.h>
#include <security_c.h> //for security
class YourInterceptorClient : public virtual RequestLevelInterceptor::ClientRequestInterceptor
{
private:
YourInterceptorClient() {}
CORBA::ORB_ptr m_orb;
public:
YourInterceptorClient(CORBA::ORB_ptr TheOrb);
~YourInterceptorClient() {}
Interceptors::ShutdownReturnStatus shutdown(
Interceptors::ShutdownReason reason,
CORBA::Exception_ptr & excep_val);
CORBA::String id();
void exception_occurred (
const RequestLevelInterceptor::ReplyContext & reply_context,
CORBA::Exception_ptr excep_val);
Interceptors::InvokeReturnStatus client_invoke (
const RequestLevelInterceptor::RequestContext & request_context,
RequestLevelInterceptor::ServiceContextList_ptr service_context,
CORBA::DataInputStream_ptr request_arg_stream,
CORBA::DataOutputStream_ptr reply_arg_stream,
CORBA::Exception_ptr & excep_val);
Interceptors::ResponseReturnStatus client_response (
const RequestLevelInterceptor::ReplyContext & reply_context,
RequestLevelInterceptor::ServiceContextList_ptr service_context,
CORBA::DataInputStream_ptr arg_stream,
CORBA::Exception_ptr & excep_val);
};
class YourInterceptorTarget : public virtual RequestLevelInterceptor::TargetRequestInterceptor
{
private:
YourInterceptorTarget() {}
CORBA::ORB_ptr m_orb;
SecurityLevel1::Current_ptr m_security_current; //for security
Security::AttributeTypeList * m_attributes_to_get; //for security
public:
YourInterceptorTarget(CORBA::ORB_ptr TheOrb);
~YourInterceptorTarget();
Interceptors::ShutdownReturnStatus shutdown(
Interceptors::ShutdownReason reason,
CORBA::Exception_ptr & excep_val);
CORBA::String id();
void exception_occurred (
const RequestLevelInterceptor::ReplyContext & reply_context,
CORBA::Exception_ptr excep_val);
Interceptors::InvokeReturnStatus target_invoke (
const RequestLevelInterceptor::RequestContext & request_context,
RequestLevelInterceptor::ServiceContextList_ptr service_context,
CORBA::DataInputStream_ptr request_arg_stream,
CORBA::DataOutputStream_ptr reply_arg_stream,
CORBA::Exception_ptr & excep_val);
Interceptors::ResponseReturnStatus target_response (
const RequestLevelInterceptor::ReplyContext & reply_context,
RequestLevelInterceptor::ServiceContextList_ptr service_context,
CORBA::DataInputStream_ptr arg_stream,
CORBA::Exception_ptr & excep_val);
};インターセプタは、共有可能ライブラリに組み込まれます。したがって、インターセプタをビルドする手順は、プラットフォーム固有です。任意の特定プラットフォーム上でインターセプタをビルドするのに使用される特定のコマンドおよびオプションの詳細を知るには、Oracle Tuxedoソフトウェア付属のインターセプタのサンプル・アプリケーションをビルドするmakefileを実行し、ビルドによって生じるログ・ファイルで、ビルド結果を参照します。Oracle Tuxedoソフトウェアに付属するサンプルのインターセプタのビルドおよび実行の詳細は、第4章「PersonQueryサンプル・アプリケーション」を参照してください。インターセプタの登録の詳細は、第3章「CORBAリクエスト・レベルのインターセプタのデプロイ」を参照してください。