JP7675006B2 - トレース管理装置、トレース管理方法、及びトレース管理プログラム - Google Patents

Description

本発明は、プロセスから出力されて送信されるリクエストにトレース情報を付与する技術に関する。

マイクロサービスアーキテクチャのような分散システムでは、障害や性能劣化の原因解析のため、リクエストの流れをトレースする分散トレーシングが用いられる。分散トレーシングは、一連のリクエストの流れに、同一のトレースＩＤを付与することで、リクエストの流れのトレースをすることができる。リクエストにトレースＩＤを付与するためには、リクエストを発行するアプリケーション内にハードコードしておくことが必要である。

アプリケーションにトレースＩＤを付与させるようにするには、コストを要する問題がある。また、アプリケーションが他社製品である等の場合においては、アプリケーションにハードコードすることが不可能であり、トレースＩＤを付与させることができない。

トレースＩＤを付与する技術としては、例えば、Ｐｙｔｈｏｎ・Ｊａｖａ（登録商標）等のスクリプトや中間言語を解析してＨＴＴＰ受信／転送の対応関係を把握し、アプリケーションの起動時に、必要な箇所にトレースＩＤを付与するコードを埋め込む技術が知られている（例えば、非特許文献１参照）。

Jonathan Mace, Ryan Roelke, and Rodrigo Fonseca. 2015. Pivot tracing: dynamic causal monitoring for distributed systems. In Proceedings of the 25th Symposium on Operating Systems Principles (SOSP '15). Association for Computing Machinery, New York, NY, USA, P.378-393.

しかし、特許文献１に開示された技術は、スクリプトや中間言語に対して適用可能な技術であり、Ｃ言語などのバイナリ形式のアプリケーションに対して適用することができない。

したがって、バイナリ形式のアプリケーションに対しては、ハードコードする必要があり、コストを要するか、或いは、ハードコードできないという問題が依然として残っている。

本発明は、上記事情に鑑みなされたものであり、その目的は、アプリケーションのプロセスから出力される送信リクエストに対して容易且つ適切にトレース情報を付与することのできる技術を提供することにある。

上記目的を達成するため、一観点に係るトレース管理装置は、第１装置から受信された受信リクエストを入力し、第２装置へ送信する送信リクエストを出力するプロセスを実行し、前記送信リクエストに対してトレース情報を付与して第２装置へ送信するトレース管理装置であって、プロセッサを有し、前記プロセッサは、前記プロセスにおける前記受信リクエストと前記受信リクエストに対応する前記送信リクエストとの生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定し、前記特定した受信リクエストに付与されているトレース情報の少なくとも一部の情報を、前記特定した送信リクエストに付与するトレース情報に含めて、前記第２装置へ送信する。

本発明によれば、アプリケーションのプロセスから出力される送信リクエストに対して容易且つ適切にトレース情報を付与することができる。

図１は、第１実施形態に係る計算機の機能構成図である。 図２は、第１実施形態に係るトラフィック情報の構成図である。 図３は、第１実施形態に係るＩＤ対応情報の構成図である。 図４は、第１実施形態に係るフィルタ情報の構成図である。 図５は、第１実施形態に係る計算機のハードウェア構成図である。 図６は、第１実施形態に係る情報取得の流れを説明する図である。 図７は、第１実施形態に係るトレース情報制御処理のフローチャートである。 図８は、第２実施形態に係る計算機が対象とするプロセスの例を説明する図である。 図９は、第２実施形態に係る計算機の機能構成図である。 図１０は、第２実施形態に係る付加情報の一例の構成図である。 図１１は、第２実施形態に係るトラフィック情報の一例を示す図である。

実施形態について、図面を参照して説明する。なお、以下に説明する実施形態は特許請求の範囲に係る発明を限定するものではなく、また実施形態の中で説明されている諸要素及びその組み合わせの全てが発明の解決手段に必須であるとは限らない。

以下の説明では、「プログラム」を動作主体として処理を説明する場合があるが、プログラムは、プロセッサによって実行されることで、定められた処理を、適宜に記憶部及びインターフェース部のうちの少なくとも１つを用いながら行うため、処理の動作主体が、プロセッサ（或いは、プロセッサを有する計算機）とされてもよい。プログラムは、プログラムソースから計算機にインストールされてもよい。プログラムソースは、例えば、プログラム配布サーバまたは計算機が読み取り可能な記憶メディアであってもよい。また、以下の説明において、２以上のプログラムが１つのプログラムとして実現されてもよいし、１つのプログラムが２以上のプログラムとして実現されてもよい。

図１は、第１実施形態に係る計算機の機能構成図である。

計算機１００は、例えば、図示しない分散システムの一部を構成する計算機であり、リソース管理装置の一例である。計算機１００は、物理的な計算機（物理計算機）であってもよく、物理的な計算機のリソースに基づいて構成される仮想的な計算機（仮想計算機）であってもよい。計算機１００は、アプリケーションを実行する１以上のプロセス１１０と、ＩＤ付与サーバ１２０とを備える。本実施形態では、プロセス１１０と、ＩＤ付与サーバ１２０とは、例えば、計算機１００で実行されるＯＳ（Ｏｐｅｒａｔｉｎｇ Ｓｙｓｔｅｍ）のカーネルを共有している。プロセス１１０は、１以上のスレッド１１１を有する。スレッド１１１には、例えば、外部の装置（第１装置）から受信された受信リクエストを入力して処理し、受信リクエストに基づいて、外部の装置（第２装置）に送信するための１以上の送信リクエストを生成して出力する処理を実行するものがある。

ＩＤ付与サーバ１２０は、プロセス１１０が出力する送信リクエストに対してトレース情報を付与して送信する処理を行う。ＩＤ付与サーバ１２０は、トラフィック取得プログラム１２１と、ＩＤ操作プログラム１２２と、パターン分析プログラム１２３と、マッピングプログラム１２４と、通信プログラム１２５と、トラフィック情報１２６と、ＩＤ対応情報１２７と、対象情報１２８と、パターンロジック１２９と、フィルタ情報１３２とを格納する。

トラフィック取得プログラム１２１は、後述するプロセッサ２０１（図５参照）により実行されることにより、プロセス１１０に入力された受信リクエストや、プロセス１１０から出力された送信リクエストに関するトラフィック情報を取得し、トラフィック情報１２６に格納する。トラフィック取得プログラム１２１は、例えば、ＯＳがＬｉｎｕｘ（登録商標）である場合には、Ｓｔｒａｃｅコマンドを利用してｓｙｓｔｅｍｃａｌｌを取得することによりトラフィック情報を取得してもよく、又はＢＰＦ（Ｂｅｒｋｅｌｅｙ Ｐａｃｋｅｔ Ｆｉｌｔｅｒ）により通信データを取得することによりトラフィック情報を取得してもよい。本実施形態では、トラフィック取得プログラム１２１は、例えば、フィルタ情報１３２に指定された条件に適合するトラフィック情報を取得する。

ＩＤ操作プログラム１２２は、プロセッサ２０１により実行されることにより、受信リクエストからＩＤ情報（トラフィック情報）を取得してＩＤ対応情報１２７に格納したり、送信リクエストに対してＩＤ情報を付与したりする。本実施形態では、ＩＤ操作プログラム１２２は、送信リクエストのＨＴＴＰヘッダに対してＩＤ情報を格納するためＬ７（ａｐｐｌｉｃａｔｉｏｎ ｌａｙｅｒ）制御が可能である。

本実施形態では、例えば、受信リクエストのＩＤ情報から取得して送信リクエストに含める（伝播）するＩＤ情報としては、Ｗ３Ｃ（Ｗｏｒｌｄ Ｗｉｄｅ Ｗｅｂ Ｃｏｎｓｏｒｔｉｕｍ）のＴｒａｃｅ Ｃｏｎｔｅｘｔ規格に従う場合には、少なくともｔｒａｃｅ－ｉｄ（トレースＩＤの一例）を含み、ｔｒａｃｅ－ｆｌａｇ、ｔｒａｃｅｓｔａｔｅをさらに含んでもよく、Ｂ３ ＰｒｏｐａｇａｔｉｏｎのＴｒａｃｅ Ｃｏｎｔｅｘｔ規格に従う場合には、少なくともｘ－ｂ３－ｔｒａｃｅｉｄ（トレースＩＤの一例）を含み、ｘ－ｂ３－ｐａｒｅｎｔｓｐａｎｉｄ、ｘ－ｂ３－ｓａｍｐｌｅｄ、ｘ－３ｂ―ｆｌａｇｓをさらに含んでもよい。

ｔｒａｃｅ－ｉｄは、一連のトラフィックの流れを表すＩＤである。ｔｒａｃｅ－ｆｌａｇは、例えば、サンプリングレートなどである。ｔｒａｃｅ－ｆｌａｇについては、受信リクエストのデータを伝播せずに、ＩＤ付与サーバ１２０で独自の値を設定してもよい。ｔｒａｃｅｓｔａｔｅは、ベンダ独自のデータである。ｔｒａｃｅｓｔａｔｅについては、ＩＤ付与サーバ１２０の処理に応じたパラメータ（例えば、Ｓｐａｎ－ｉｄ）を追加してもよい。

ｘ－ｂ３－ｔｒａｃｅｉｄは、一連のトラフィックの流れを表すＩＤである。ｘ－ｂ３－ｐａｒｅｎｔｓｐａｎｉｄは、受信リクエストのｘ－ｂ３－ｓｐａｎｉｄである。なお、ｘ－ｂ３－ｐａｒｅｎｔｓｐａｎｉｄは必須ではなく、受信リクエストにパラメータがなければ伝播させなくてよい。ｘ－ｂ３－ｓａｍｐｌｅｄは、サンプルするか否かを示す情報である。受信リクエストにパラメータがなければｘ－ｂ３－ｓａｍｐｌｅｄを伝播させなくてもよい。ｘ－３ｂ―ｆｌａｇｓは、デバックの有無を示す情報である。受信リクエストにパラメータがなければｘ－ｂ３－ｆｌａｇｓを伝播させなくてもよい。

パターン分析プログラム１２３は、トラフィック情報１２６にある受信リクエスト及び送信リクエストの生成関係のパターンがパターンロジック１２９の判定ロジック１３０のパターンに適合するか否かを判定する。マッピングプログラム１２４は、マッピングロジック１３１を用いてトラフィック情報１２６の対応する受信リクエストと送信リクエストとの関連付けを行う。通信プログラム１２５は、スレッド１１１から出力された送信リクエストを宛先の装置（第２装置）に送信する。本実施形態では、通信プログラム１２５は、例えば、後述する通信パターン分析（図７のステップＳ１０）においては、ＩＤ操作プログラム１２２によってＩＤ情報が付与されていない送信リクエストを送信し、後述するＩＤ付与処理（図７のステップＳ１２）においては、ＩＤ操作プログラム１２２によってＩＤ情報が付与された送信リクエストを送信する。

トラフィック情報１２６は、例えば、テーブル形式のデータであり、プロセスにおけるスレッドに入力された受信リクエストと、スレッドから出力された送信リクエストとに関する情報（トラフィック情報）を格納する。ＩＤ対応情報１２７は、受信リクエストに含まれているトレース情報（ＩＤ情報）を格納する。対象情報１２８は、ＩＤ付与の対象とするプロセス（対象プロセス）を指定する情報（例えば、プロセスＩＤ）を格納する。

パターンロジック１２９は、送信リクエストに対してトレース情報を付与する対象となるパターンがあるかを判定し、該当するパターンに従って対象の送信リクエストに対してトレース情報を付与するロジックである。パターンロジック１２９は、対象とするパターンの数だけ用意されている。パターンロジック１２９は、判定ロジック１３０と、マッピングロジック１３１とを含む。判定ロジック１３０と、マッピングロジック１３１とは、例えば、計算機１００の管理者に設定されてもよく、他のシステムにより設定されてもよい。

判定ロジック１３０は、プロセス１１０の受信リクエストと送信リクエストとに対して判定すべきパターン、すなわち、トラフィック情報１２６の受信リクエストと送信リクエストとに対して判定すべきパターンを示すロジックである。判定ロジック１３０のパターンとしては、１つの受信リクエストに対して、１以上のＮ個の送信リクエストが生成されるパターン（生成関係の一例）がある。なお、Ｎの値は、パターン分析プログラム１２３によりトラフィック情報１２６に基づいて動的に決定される。

マッピングロジック１３１は、判定ロジック１３０が判定しているパターンを有する場合において、このパターンに適合する送信リクエスト及び受信リクエストを特定するためのロジックである。本実施形態では、マッピングロジック１３１は、受信リクエストと、受信リクエストの受信後に生成されたＮ個の送信リクエストとを対応するとして特定するためのロジックである。

フィルタ情報１３２は、トラフィック取得プログラム１２１が取得するトラフィック情報を指定する情報（フィルタ情報）を格納する。

次に、トラフィック情報１２６について詳細に説明する。

図２は、第１実施形態に係るトラフィック情報の構成図である。

トラフィック情報１２６は、トレース情報を付与する対象となるプロセス（対象プロセス）に対して入力されるリクエスト（受信リクエスト）及び対象プロセスから出力されるリクエスト（送信リクエスト）に関する情報（トレース情報）の履歴情報を格納する。トラフィック情報１２６は、リクエストごとのエントリを格納する。トラフィック情報１２６のエントリは、種類３０１と、プロセスＩＤ３０２と、スレッドＩＤ３０３と、送信元ＩＰ３０４と、送信元Ｐｏｒｔ３０５と、宛先ＩＰ３０６と、宛先Ｐｏｒｔ３０７とのフィールドを含む。

種類３０１には、エントリに対応するリクエストが受信リクエストか、送信リクエストかを示す種類が格納される。プロセスＩＤ３０２には、エントリに対応するリクエストに関わるプロセスのＩＤ（プロセスＩＤ）が格納される。スレッドＩＤ３０３には、エントリに対応するリクエストに関わるスレッドのＩＤ（スレッドＩＤ）が格納される。送信元ＩＰ３０４には、エントリに対応するリクエストの送信元のＩＰ（Ｉｎｔｅｒｎｅｔ Ｐｒｏｔｏｃｏｌ）アドレスが格納される。送信元Ｐｏｒｔ３０５には、エントリに対応するリクエストの送信元のポートの番号が格納される。宛先ＩＰ３０６には、エントリに対応するリクエストの宛先のＩＰアドレスが格納される。宛先Ｐｏｒｔ３０７には、エントリに対応するリクエストの宛先のポートの番号が格納される。

次に、ＩＤ対応情報１２７について詳細に説明する。

図３は、第１実施形態に係るＩＤ対応情報の構成図である。

ＩＤ対応情報１２７は、対応する送信リクエストにトレース情報を付与する対象となる受信リクエスト（対象受信リクエスト）に含まれるトレース情報を格納する。ＩＤ対応情報１２７は、対象受信リクエストごとのエントリを格納する。

ＩＤ対応情報１２７のエントリは、送信元ＩＰ４０１と、送信元Ｐｏｒｔ４０２と、宛先ＩＰ４０３と、宛先Ｐｏｒｔ４０４と、ＩＤ情報４０５とのフィールドを含む。

送信元ＩＰ４０１には、エントリに対応する受信リクエストの送信元のＩＰアドレスが格納される。送信元Ｐｏｒｔ４０２には、エントリに対応する受信リクエストの送信元のポートの番号が格納される。宛先ＩＰ４０３には、エントリに対応する受信リクエストの宛先のＩＰアドレスが格納される。宛先Ｐｏｒｔ４０４には、エントリに対応する受信リクエストの宛先のポートの番号が格納される。ＩＤ情報４０５には、エントリに対応する受信リクエストのＩＤ情報が格納される。なお、ＩＤ情報４０５には、受信リクエストのトレース情報の中の送信リクエストのトレース情報に含める必要がある情報（少なくともトレースＩＤ）のみ格納するようにしてもよい。

次に、フィルタ情報１３２について詳細に説明する。

図４は、第１実施形態に係るフィルタ情報の構成図である。

フィルタ情報１３２は、トラフィック取得プログラム１２１により取得しないリクエストを指定するエントリを格納する。フィルタ情報１３２のエントリは、送信元ＩＰ８０１と、送信元Ｐｏｒｔ８０２と、宛先ＩＰ８０３と、宛先Ｐｏｒｔ８０４とのフィールドを含む。

送信元ＩＰ８０１には、取得しないリクエストの送信元のＩＰアドレスが格納される。なお、いずれの値でよい場合には、送信元ＩＰ８０１には、いずれの値でもよいことを示す値（例えば、＊）が格納される。送信元Ｐｏｒｔ８０２には、取得しないリクエストの送信元のＰｏｒｔの番号が格納される。いずれの値でよい場合には、送信元Ｐｏｒｔ８０２には、いずれの値でもよいことを示す値（例えば、＊）が格納される。宛先ＩＰ８０３には、取得しないリクエストの宛先のＩＰアドレスが格納される。いずれの値でよい場合には、宛先ＩＰ８０３には、いずれの値でもよいことを示す値（例えば、＊）が格納される。宛先Ｐｏｒｔ８０４には、取得しないリクエストの宛先のポートの番号が格納される。いずれの値でよい場合には、宛先Ｐｏｒｔ８０４には、いずれの値でもよいことを示す値（例えば、＊）が格納される。

例えば、フィルタ情報１３２の１行目のエントリは、宛先ＩＰが１０．０．０．２５４のリクエストの全てが取得しない対象となることを示している。

次に、計算機１００について詳細に説明する。

図５は、第１実施形態に係る計算機のハードウェア構成図である。

計算機１００は、例えば、ＰＣ（Ｐｅｒｓｏｎａｌ Ｃｏｍｐｕｔｅｒ）、サーバ等の物理計算機によって構成されている。計算機１００は、プロセッサ２０１と、通信インターフェース（Ｉ／Ｆ）２０２と、主記憶装置２０３と、補助記憶装置２０４と、内部バス２０５とを備えている。プロセッサ２０１と、通信インターフェース（Ｉ／Ｆ）２０２と、主記憶装置２０３と、補助記憶装置２０４とは、内部バス２０５を介して接続されている。

通信Ｉ／Ｆ２０２は、例えば、有線ＬＡＮカードや無線ＬＡＮカードなどのインターフェースであり、ネットワーク２１０を介して他の装置（例えば、分散システムを構成する他の計算機等）と通信する。

プロセッサ２０１は、主記憶装置２０３及び／又は補助記憶装置２０４に格納されているプログラムに従って各種処理を実行する。

主記憶装置２０３は、記憶部の一例であり、例えば、ＲＡＭ（ＲＡＮＤＯＭ ＡＣＣＥＳＳ ＭＥＭＯＲＹ）であり、プロセッサ２０１で実行されるプログラムや、必要な情報を記憶する。本実施形態では、主記憶装置２０３は、例えば、ＯＳや、トラフィック取得プログラム１２１、ＩＤ操作プログラム１２２、パターン分析プログラム１２３、マッピングプログラム１２４、通信プログラム１２５、トラフィック情報１２６、ＩＤ対応情報１２７、対象情報１２８、パターンロジック１２９、フィルタ情報１３２等を格納する。なお、これらを補助記憶装置２０４に格納してもよい。ここで、トレース管理プログラムは、例えば、トラフィック取得プログラム１２１、ＩＤ操作プログラム１２２、パターン分析プログラム１２３、及びマッピングプログラム１２４で構成される。

補助記憶装置２０４は、記憶部の一例であり、例えば、ハードディスクドライブや、ＳＳＤ（Ｓｏｌｉｄ Ｓｔａｔｅ Ｄｒｉｖｅ）等であり、プロセッサ２０１で実行されるプログラムや、プロセッサ２０１に利用されるデータを記憶する。

次に、計算機１００による処理動作について説明する。

まず、計算機１００による各種情報の取得について説明する。この各種情報の取得は、例えば、対象となっているプロセス１１０のスレッド１１１がリクエストを受信（入力）したり、送信（出力）したりする毎に実行される。

計算機１００のトラフィック取得プログラム１２１は、対象となるプロセス１１０のスレッド１１１における受信リクエスト及び送信リクエストの宛先ＩＰ、宛先Ｐｏｒｔ、送信元ＩＰ、及び送信元Ｐｏｒｔを取得して、トラフィック情報１２６に格納する。例えば、トラフィック取得プログラム１２１は、ＢＰＦツールにおけるｔｃｐｃｏｎｎｅｃｔやｔｃｐａｃｃｅｐｔなどのコマンドによる出力結果から、宛先ＩＰ、宛先Ｐｏｒｔ、送信元ＩＰ、及び送信元Ｐｏｒｔを取得してもよく、Ｓｙｓｔｅｍ ｃａｌｌ情報を取得し、ｃｏｎｎｅｃｔ及びｇｅｔｓｏｃｋｅｔから送信リクエストの宛先ＩＰ、宛先Ｐｏｒｔ、送信元ＩＰ、及び送信元Ｐｏｒｔを取得し、ａｃｃｅｐｔから受信リクエストの宛先ＩＰ、宛先Ｐｏｒｔ、送信元ＩＰ、及び送信元Ｐｏｒｔを取得してもよい。なお、トラフィック取得プログラム１２１は、エラー（例えば、Ｓｙｓｔｅｍ ｃａｌｌ情報の返り値が０以外のｓｙｓｔｅｍ ｃａｌｌ等）となっているリクエストについては、トラフィック情報１２６に格納しないようにしている。

一方、計算機１００のＩＤ操作プログラム１２２は、例えば、受信リクエストをスレッドの前に受信するリバースプロキシや、ＢＰＦツールを用いて、受信リクエストの宛先ＩＰ、宛先Ｐｏｒｔ、送信元ＩＰ、及び送信元Ｐｏｒｔと、受信リクエストのＨＴＴＰヘッダに含まれるＩＤ情報（トレース情報）とを取得し、ＩＤ対応情報１２７に格納する。なお、トラフィック取得プログラム１２１は、エラー（例えば、Ｓｙｓｔｅｍ ｃａｌｌ情報の返り値が０以外のｓｙｓｔｅｍ ｃａｌｌ等）となっているリクエストについては、ＩＤ対応情報１２７に格納しないようにしている。

このように、計算機１００においては、スレッド１１１における受信リクエスト及び送信リクエストの宛先ＩＰ、宛先Ｐｏｒｔ、送信元ＩＰ、及び送信元Ｐｏｒｔや、受信リクエストのＩＤ情報を取得し、管理することができる。

次に、計算機１００によるトレース情報制御処理について説明する。

図７は、第１実施形態に係るトレース情報制御処理のフローチャートである。

ＩＤ付与サーバ１２０のパターン分析プログラム１２３は、パターンロジック１２９の判定ロジック１３０を使用して、トラフィック情報１２６のリクエストが判定ロジック１３０のパターンを満たしているか否かを分析する通信パターン分析を実行する（ステップＳ１０）。パターン分析プログラム１２３は、分析結果をシステムログなどに出力する。なお、パターン分析プログラム１２３は、分析結果とトラフィック情報１２６の分析結果に関係するリクエストとをユーザの端末等に出力してもよい。

パターン分析プログラム１２３は、例えば、一定時間（例えば、５分）及び／又は分析したトラフィック量（リクエスト量）が一定量となるまで、通信パターン分析を実行する。なお、通信パターン分析において、判定ロジック１３０のパターンを満たしていることを検出できない場合には、パターン分析プログラム１２３は、通信パターンなしと判定する。

次いで、マッピングプログラム１２４は、ＩＤ付与処理で対応可能か否か、すなわち、判定ロジック１３０のパターンを満たしているとの分析結果であるか否かを判定する（ステップＳ１１）。この結果、判定ロジック１３０のパターンを満たしているとの分析結果でない場合（ステップＳ１１：Ｎｏ）には、マッピングプログラム１２４は、処理を終了する一方、判定ロジック１３０のパターンを満たしているとの分析結果である場合（ステップＳ１１：Ｙｅｓ）には、マッピングプログラム１２４は、処理をステップＳ１２に進める。

ステップＳ１２においては、マッピングプログラム１２４及びＩＤ操作プログラム１２２は、ＩＤ付与処理を常時実行する。ＩＤ付与処理においては、マッピングプログラム１２４は、マッピングロジック１３１を使用して、トラフィック情報１２６における、対応する受信リクエストと送信リクエストとを特定する。本実施形態では、１つの受信リクエストと、その後に送信されるＮ個の送信リクエストとが対応すると特定される。ここで、マッピングプログラム１２４は、特定した受信リクエストと送信リクエストとについての送信元ＩＰ、送信元Ｐｏｒｔ、宛先ＩＰ、及び宛先Ｐｏｒｔの組をまとめて記憶する。次いで、ＩＤ操作プログラム１２２は、マッピングプログラム１２４により特定された送信リクエストに対して、受信リクエストのＩＤ情報を付与する、具体的には、マッピングプログラム１２４は、ＩＤ対応情報１２７から受信リクエストのＩＤ情報を取得し、取得したＩＤ情報に基づくＩＤ情報を送信リクエストのＨＴＴＰヘッダのパラメータとして設定する。なお、マッピングプログラム１２４は、受信リクエストに対応する全ての送信リクエストを送信した場合、例えば、受信リクエストに対応する正常応答を返す場合には、ＩＤ対応情報１２７からこの受信リクエストのエントリを削除してもよい。

このように、マッピングプログラム１２４によりＩＤ情報が付与された送信リクエストは、通信プログラム１２５により、送信リクエストの宛先の装置に対して送信されることとなる。

上記した実施形態によると、プロセス１１０に変更を加えることなく、プロセス１１０から出力される送信リクエストに対して、対応する受信リクエストのトレース情報中の伝播が必要な情報を適切にトレース情報に付加することができる。これにより、リクエストに付加されているトレース情報（トレースＩＤ等）を用いて、リクエストの流れを適切にトレースし、分析に利用することができる。

次に、第２実施形態について説明する。

図８は、第２実施形態に係る計算機が対象とするプロセスの例を説明する図である。

第２実施形態に係る計算機１００Ａ（図９参照）が対象とするプロセス１１０としては、受信リクエストを受け取ったスレッド１１１（Ｔｈｒｅａｄ１）と、送信リクエストを出力するスレッド１１１（Ｔｈｒｅａｄ１０００，１００１）とが異なっているプロセスを想定している。本実施形態では、送信リクエストを出力するスレッド１１１は、複数存在し、これらのスレッド１１１に対して受信リクエストに基づく処理がラウンドロビンで（順番に）振り分けられるものとする。このプロセス１１０においては、Ｔｈｒｅａｄ１のトラフィック情報は、受信リクエストのみであり、Ｔｈｒｅａｄ１０００とＴｈｒｅａｄ１００１とのトラフィック情報は、送信リクエストのみとなる。

このプロセス１１０において、Ｔｈｒｅａｄ１が、受信リクエスト（受信Ａ）を受信すると、Ｔｈｒｅａｄ１０００が、この受信リクエストに対応する送信リクエスト（送信Ｂ）を出力し、Ｔｈｒｅａｄ１が、受信リクエスト（受信Ｃ）を受信すると、次の順番のＴｈｒｅａｄ１００１が、この受信リクエストに対応する送信リクエスト（送信Ｄ）を出力する。同様に、受信リクエスト（受信Ｅ）を受信すると、次の順番のＴｈｒｅａｄ１０００が、受信リクエストに対応する送信リクエスト（送信Ｆ）を出力する。図８の例では、１つの受信リクエストに対して、スレッド１１１が１つの送信リクエストを送信するようにしているが、１つの受信リクエストに対してスレッド１１１が複数の送信リクエストを送信するようにしてもよい。なお、１つのスレッド１１１における送信リクエストの出力順序は、対応する受信リクエストの順序が維持されているものとする。

次に、第２実施形態に係る計算機１００Ａについて説明する。

図９は、第２実施形態に係る計算機の機能構成図である。なお、第２実施形態に係る計算機１００Ａについて、第１実施形態に係る計算機１００と同様な部分については同一の符号を付すこととする。

計算機１００Ａにおいて、プロセス１１０は、情報検出プログラム９００を有してもよい。情報検出プログラム９００は、プロセス１１０における付加情報（後述する付加情報９０３と同様な情報）を検出し、付加情報をＩＤ付与サーバ１２０Ａに送信する。なお、情報検出プログラム９００を有さない場合には、プロセス１１０のプログラムを変更する必要がなく、情報検出プログラム９００を有する場合には、プロセス１１０のプログラムを大きく変更することなく比較的簡易な変更により対応できる。

ＩＤ付与サーバ１２０Ａは、ＩＤ付与サーバ１２０に対して、付加情報９０３をさらに格納し、パターン分析プログラム１２３に代えてパターン分析プログラム９０１を備え、マッピングプログラム１２４に代えてマッピングプログラム９０２を備え、パターンロジック１２９に、判定ロジック９０４及びマッピングロジック９０５を備える。

付加情報９０３は、プロセス１１０における複数のスレッド１１１の実行順番と、１つの受信リクエストに対して１つのスレッド１１１から出力される送信リクエストの数とを示す情報（生成関係情報の一例）である。本実施形態では、付加情報９０３は、スレッド１１１における実際の受信リクエストと送信リクエストとの実際の送信元ＩＰ、送信元Ｐｏｒｔ、宛先ＩＰ、及び宛先Ｐｏｒｔの組の情報（サンプル）も含まれている。付加情報９０３は、プロセス１１０の情報検出プログラム９００から受信するようにしてもよく、計算機１００Ａの管理者による入力により受け付けてもよい。

パターン分析プログラム９０１は、付加情報９０３を用いて、トラフィック情報１２６にある受信リクエスト及び送信リクエストがパターンロジック１２９の判定ロジック９０４のパターンに適合するか否かを判定する。マッピングプログラム９０２は、付加情報９０３とマッピングロジック９０５を用いて、トラフィック情報１２６から対応する受信リクエストと送信リクエストとを特定し、それらの関連付けを行う。

判定ロジック９０４は、プロセス１１０の受信リクエストと送信リクエストとに対して判定すべき条件、すなわち、トラフィック情報１２６の受信リクエストと送信リクエストとに対して判定すべきパターンを示すロジックである。判定ロジック９０４のパターンとしては、例えば、スレッド１１１が呼び出される順番がラウンドロビンであり、スレッド１１１の読み出し順序が判明しており、対応する受信リクエストと送信リクエストとのサンプルが付加情報９０３として与えられており、そのサンプルが実際にトラフィック情報１２６に格納されていることである。

マッピングロジック９０５は、判定ロジック１３０が判定しているパターンを有する場合において、このパターンに適合する受信リクエストと送信リクエストとを特定するためのロジックである。本実施形態では、マッピングロジック９０５は、付加情報９０３のスレッド１１１における受信リクエストと送信リクエストの対応関係に基づいて、トラフィック情報１２６から次の受信リクエストと、その受信リクエストに対応する次のスレッドの送信リクエストとを特定することを繰り返し実行するロジックである。例えば、図８の例においては、マッピングロジック９０５は、受信Ａと送信Ｂとのサンプルから、次の受信Ｃと次の順番のＴｈｒｅａｄ１００１の送信Ｄとの対応関係を特定し、さらに、以降の受信についても同様に特定するロジックである。

次に、付加情報９０３について説明する。

図１０は、第２実施形態に係る付加情報の一例の構成図である。

付加情報９０３は、例えば、ＪＳＯＮ（ＪａｖａＳｃｒｉｐｔ（登録商標） Ｏｂｌｅｃｔ Ｎｏｔａｔｉｏｎ）形式の情報である。付加情報９０３は、同一のプロセス１１０の各スレッド１１１の呼出し順序を記述する順序記述領域９５１と、トラフィック情報のサンプルを記述するサンプル記述領域９５２とを含む。順序記述領域９５１は、サンプル記述領域９５２において、すべてのスレッド１１１についてのサンプルが呼出し順序に従って記述される場合には不要である。

サンプル記述領域９５２は、一以上のスレッド毎記述領域９５３を有する。なお、順序記述領域９５１に各スレッド１１１の呼出し順序が記述されている場合には、サンプル記述領域９５２は、１つのスレッド１１１についてのスレッド毎記述領域９５３のみを有していてもよい。

スレッド毎記述領域９５３は、スレッドＩＤ領域９５４と、受信リクエスト情報９５５と、１以上の送信リクエスト情報９５６とを含む。１つの受信リクエストに対して複数の送信リクエストを送信する場合には、送信リクエスト情報９５６は、送信される送信リクエストの数だけ含まれる。スレッドＩＤ領域９５４には、スレッド毎記述領域９５３に対応するスレッド１１１のスレッドＩＤが格納される。受信リクエスト情報９５５には、スレッド１１１の呼出しを行うこととなったトラフィック情報１２６に存在する送信リクエストの情報（送信元ＩＰ、送信元Ｐｏｒｔ、宛先ＩＰ、及び宛先Ｐｏｒｔ）が格納される。送信リクエスト情報９５６には、受信リクエストに基づいて送信される、トラフィック情報１２６に存在する送信リクエストの情報（送信元ＩＰ、送信元Ｐｏｒｔ、宛先ＩＰ、及び宛先Ｐｏｒｔ）が格納される。

この付加情報９０３によると、トラフィック情報１２６における受信リクエストと、その受信リクエストに対応する送信リクエストとの関係を適切に把握できる。

次に、付加情報９０３が図１０に示す状態である場合におけるトラフィック情報１２６の一例について説明する。

図１１は、第２実施形態に係るトラフィック情報の一例を示す図である。

図１１に示すトラフィック情報１２６のエントリの構成は、図２に示すトラフィック情報１２６と同様であり、トラフィック情報１２６の各エントリの値は、図８に示すプロセス１１０及び図１０に示す付加情報９０３に対応する値となっている。

トラフィック情報１２６において、１行目に示すように、受信リクエストがＴｈｒｅａｄ１に受信され、この受信リクエストにより２行目に示すように、Ｔｈｒｅａｄ１０００が呼び出されて送信リクエストが送信され、３行目に示すように、次の受信リクエストがＴｈｒｅａｄ１に受信され、この受信リクエストにより４行目に示すように、次の順番のスレッド１１１であるＴｈｒｅａｄ１００１が呼び出されて送信リクエストが送信され、以降も受信リクエストが受信される毎に、次の順番のスレッド１１１が呼び出されて送信リクエストが送信されることとなる。なお、図１１のトラフィック情報１２６においては、受信リクエストと対応する送信リクエストが連続した行に並んでいる例を示しているが、場合によっては、複数の受信リクエストが連続したり、受信リクエストの次に、前の受信リクエストに対応する送信リクエストが発生したりする可能性があるが、付加情報９０３に基づいて、トラフィック情報１２６における受信リクエストと送信リクエストとの対応関係を適切に把握することができる。具体的には、付加情報９０３に実際のサンプルが含まれており、トラフィック情報１２６における対応する特定の受信リクエストと特定の送信リクエストとを特定できる。そのため、次の受信リクエストと、その受信リクエストに対応する次の順番のスレッドの送信リクエストを適切に特定することができる。

第２実施形態に係る計算機１００Ａによるトレース情報制御処理は、図7に示すトレース情報制御処理において、計算機１００のプログラム等の処理を計算機１００Ａのプログラム等の処理に置き換えたものである。

第２実施形態に係る計算機１００Ａによると、受信リクエストを受け取ったスレッド１１１と、送信リクエストを出力するスレッド１１１とが異なり、送信リクエストを送信するスレッド１１１が複数あるプロセス１１０に対しても、受信リクエストに対応する送信リクエストに対して適切にトレース情報を付加することができる。

なお、本発明は、上述の実施形態に限定されるものではなく、本発明の趣旨を逸脱しない範囲で、適宜変形して実施することが可能である。

例えば、上記実施形態では、フィルタ情報１３２を、取得しない対象とするリクエストを指定する、いわゆるブラックリストとしていたが、本発明はこれに限られず、例えば、取得する対象とするリクエストを指定する、いわゆるホワイトリストとしてもよい。

また、上記実施形態において、プロセッサが行っていた処理の一部又は全部を、ハードウェア回路で行うようにしてもよい。また、上記実施形態におけるプログラムは、プログラムソースからインストールされてよい。プログラムソースは、プログラム配布サーバ又は記憶メディア（例えば可搬型の記憶メディア）であってもよい。

１００，１００Ａ…計算機、１１０…プロセス、１１１…スレッド、１２０…ＩＤ付与サーバ、１２１…トラフィック取得プログラム、１２２…ＩＤ操作プログラム、１２３，９０１…パターン分析プログラム、１２４，９０２…マッピングプログラム、１２５…通信プログラム、１２６…トラフィック情報、１２７…ＩＤ対応情報、１２８…対象情報、１２９…パターンロジック、１３０，９０４…判定ロジック、１３１，９０５…マッピングロジック、１３２…フィルタ情報、２０１…プロセッサ、２０２…通信Ｉ／Ｆ、２０３…主記憶装置、２０４…補助記憶装置、２０５…内部バス、２１０…ネットワーク、９００…情報検出プログラム、９０３…付加情報

Claims (11)

1. 第１装置から受信された受信リクエストを入力し、第２装置へ送信する送信リクエストを出力するプロセスを実行し、前記送信リクエストに対してトレース情報を付与して第２装置へ送信するトレース管理装置であって、
   プロセッサを有し、
   前記プロセッサは、
   前記プロセスにおける前記受信リクエストと前記受信リクエストに対応する前記送信リクエストとの生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定し、
   前記特定した受信リクエストに付与されているトレース情報の少なくとも一部の情報を、前記特定した送信リクエストに付与するトレース情報に含めて、前記第２装置へ送信し、
   記憶部をさらに有し、
   前記プロセッサは、
   前記プロセスにおける受信リクエストと送信リクエストとの履歴情報を前記記憶部に格納し、
   前記履歴情報に基づいて、前記受信リクエストと前記送信リクエストとの間に所定の生成関係があるか否かを判定し、
   前記所定の生成関係がある場合に、前記所定の生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定し、
   前記所定の生成関係は、前記プロセスの１つのスレッドにおいて、受信リクエストが入力された後に１以上の送信リクエストが生成される関係である
   トレース管理装置。
2. 第１装置から受信された受信リクエストを入力し、第２装置へ送信する送信リクエストを出力するプロセスを実行し、前記送信リクエストに対してトレース情報を付与して第２装置へ送信するトレース管理装置であって、
   プロセッサを有し、
   前記プロセッサは、
   前記プロセスにおける前記受信リクエストと前記受信リクエストに対応する前記送信リクエストとの生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定し、
   前記特定した受信リクエストに付与されているトレース情報の少なくとも一部の情報を、前記特定した送信リクエストに付与するトレース情報に含めて、前記第２装置へ送信し、
   記憶部をさらに有し、
   前記プロセッサは、
   前記プロセスにおける受信リクエストと送信リクエストとの履歴情報を前記記憶部に格納し、
   前記履歴情報に基づいて、前記受信リクエストと前記送信リクエストとの間に所定の生成関係があるか否かを判定し、
   前記所定の生成関係がある場合に、前記所定の生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定し、
   前記所定の生成関係は、プロセスにおいて、各受信リクエストに対応する送信リクエストが複数のスレッドにより順番に処理される関係である
   トレース管理装置。
3. 前記記憶部は、前記所定の生成関係を示す生成関係情報として、プロセスにおいて受信リクエストに対応する送信リクエストが複数のスレッドにより生成される場合の前記受信リクエストに基づく処理が引き渡されるスレッドの順番の情報と、前記スレッドで１つの受信リクエストに対して生成される送信リクエストの数の情報とを記憶し、
   前記プロセッサは、
   前記生成関係情報に基づく前記所定の生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定する
   請求項２に記載のトレース管理装置。
4. 前記プロセッサは、
   前記プロセスを実行することにより、前記プロセスにおいて受信リクエストに対応する送信リクエストが複数のスレッドで生成される場合における前記受信リクエストに基づく処理が引き渡されるスレッドの順番の情報と、前記スレッドで１つの受信リクエストに対して生成される送信リクエストの数の情報とを含む生成関係情報を生成して前記記憶部に格納する
   請求項３に記載のトレース管理装置。
5. 前記記憶部は、前記履歴情報の対象とする受信リクエスト及び送信リクエストを規定するフィルタ情報を記憶し、
   前記プロセッサは、前記フィルタ情報に基づいて、前記履歴情報に格納する受信リクエスト及び送信リクエストを選択する
   請求項１又は請求項２に記載のトレース管理装置。
6. 前記プロセッサは、
   前記受信リクエストと前記送信リクエストとの間に所定の生成関係があるか否かの判定結果を出力する
   請求項１又は請求項２に記載のトレース管理装置。
7. 前記プロセッサは、
   前記判定結果とともに、前記判定に関係する前記受信リクエストと前記送信リクエストとの履歴情報を出力する
   請求項６に記載のトレース管理装置。
8. 第１装置から受信された受信リクエストを入力し、第２装置へ送信する送信リクエストを出力するプロセスを実行し、前記送信リクエストに対してトレース情報を付与して前記第２装置へ送信するトレース管理装置によるトレース管理方法であって、
   前記トレース管理装置は、
   前記プロセスにおける前記受信リクエストと前記受信リクエストに対応する前記送信リクエストとの生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定し、
   前記特定した受信リクエストに付与されているトレース情報の少なくとも一部の情報を、前記特定した送信リクエストに付与するトレース情報に含めて、前記第２装置へ送信し、
   前記プロセスにおける受信リクエストと送信リクエストとの履歴情報を前記トレース管理装置の記憶部に格納し、
   前記履歴情報に基づいて、前記受信リクエストと前記送信リクエストとの間に所定の生成関係があるか否かを判定し、
   前記所定の生成関係がある場合に、前記所定の生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定し、
   前記所定の生成関係は、前記プロセスの１つのスレッドにおいて、受信リクエストが入力された後に１以上の送信リクエストが生成される関係である
   トレース管理方法。
9. 第１装置から受信された受信リクエストを入力し、第２装置へ送信する送信リクエストを出力するプロセスを実行し、前記送信リクエストに対してトレース情報を付与して前記第２装置へ送信するトレース管理装置によるトレース管理方法であって、
   前記トレース管理装置は、
   前記プロセスにおける前記受信リクエストと前記受信リクエストに対応する前記送信リクエストとの生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定し、
   前記特定した受信リクエストに付与されているトレース情報の少なくとも一部の情報を、前記特定した送信リクエストに付与するトレース情報に含めて、前記第２装置へ送信し、
   前記プロセスにおける受信リクエストと送信リクエストとの履歴情報を前記トレース管理装置の記憶部に格納し、
   前記履歴情報に基づいて、前記受信リクエストと前記送信リクエストとの間に所定の生成関係があるか否かを判定し、
   前記所定の生成関係がある場合に、前記所定の生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定し、
   前記所定の生成関係は、プロセスにおいて、各受信リクエストに対応する送信リクエストが複数のスレッドにより順番に処理される関係である
   トレース管理方法。
10. 第１装置から受信された受信リクエストを入力し、第２装置へ送信する送信リクエストを出力するプロセスを実行し、前記送信リクエストに対してトレース情報を付与して前記第２装置へ送信する計算機に実行させるトレース管理プログラムであって、
    前記計算機に、
    前記プロセスにおける前記受信リクエストと前記受信リクエストに対応する前記送信リクエストとの生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定させ、
    前記特定された受信リクエストに付与されているトレース情報の少なくとも一部の情報を、前記特定された送信リクエストに付与するトレース情報に含めて、前記第２装置へ送信させ、
    前記プロセスにおける受信リクエストと送信リクエストとの履歴情報を前記計算機の記憶部に格納させ、
    前記履歴情報に基づいて、前記受信リクエストと前記送信リクエストとの間に所定の生成関係があるか否かを判定させ、
    前記所定の生成関係がある場合に、前記所定の生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定させ、
    前記所定の生成関係は、前記プロセスの１つのスレッドにおいて、受信リクエストが入力された後に１以上の送信リクエストが生成される関係である
    トレース管理プログラム。
11. 第１装置から受信された受信リクエストを入力し、第２装置へ送信する送信リクエストを出力するプロセスを実行し、前記送信リクエストに対してトレース情報を付与して前記第２装置へ送信する計算機に実行させるトレース管理プログラムであって、
    前記計算機に、
    前記プロセスにおける前記受信リクエストと前記受信リクエストに対応する前記送信リクエストとの生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定させ、
    前記特定された受信リクエストに付与されているトレース情報の少なくとも一部の情報を、前記特定された送信リクエストに付与するトレース情報に含めて、前記第２装置へ送信させ、
    前記プロセスにおける受信リクエストと送信リクエストとの履歴情報を前記計算機の記憶部に格納させ、
    前記履歴情報に基づいて、前記受信リクエストと前記送信リクエストとの間に所定の生成関係があるか否かを判定させ、
    前記所定の生成関係がある場合に、前記所定の生成関係に基づいて、対応する送信リクエストと受信リクエストとを特定させ、
    前記所定の生成関係は、プロセスにおいて、各受信リクエストに対応する送信リクエストが複数のスレッドにより順番に処理される関係である
    トレース管理プログラム。