比較監視システム及び比較監視方法
【課題】相関性があるデータ列間で、データの出現順番や送信回数が変化する場合でも、一定の相関性を比較監視する。
【解決手段】監視プローブ装置２０，３０それぞれが取得したデータの内容からチェックコードを算出し、チェックコードの値が直前に生成したチェックコードと異なる場合に、そのチェックコードとデータのタイムスタンプを含む比較情報を比較装置４０へ送信し、比較装置４０は監視プローブ装置２０，３０それぞれから受信した比較情報を比較し、比較情報に相違が検出された場合にアラートを出力する。これにより、同じチェックコードが連続した場合、つまり同じデータを連続して受信した場合には、比較処理を行わないので、データの送信回数の違いを無視してデータストリーム間の相関性を比較監視することができる。
【解決手段】監視プローブ装置２０，３０それぞれが取得したデータの内容からチェックコードを算出し、チェックコードの値が直前に生成したチェックコードと異なる場合に、そのチェックコードとデータのタイムスタンプを含む比較情報を比較装置４０へ送信し、比較装置４０は監視プローブ装置２０，３０それぞれから受信した比較情報を比較し、比較情報に相違が検出された場合にアラートを出力する。これにより、同じチェックコードが連続した場合、つまり同じデータを連続して受信した場合には、比較処理を行わないので、データの送信回数の違いを無視してデータストリーム間の相関性を比較監視することができる。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、データ列間の相関性を比較監視する技術に関する。
【背景技術】
【０００２】
ネットワークを用いた映像配信サービスの提供が広まり、近年では、地上デジタル放送あるいはＢＳデジタル放送を、リアルタイムでネットワークを用いて送信するＩＰ再送信も行われている。ＩＰ再送信を行う際、映像データをより符号化効率の高い映像データに変換したり、同じデータを繰り返し送信されているデータ放送や番組情報などは、その繰り返す回数を減らしたりして、使用する帯域を抑制している。
【０００３】
ＩＰ再送信時には、ＩＰ再送信放送に障害が発生していないか地上デジタル放送、ＢＳデジタル放送と比較して監視する必要がある。例えば、特許文献１には、ＩＰ再送信されるテレビジョン放送を監視する技術が開示されている。
【０００４】
ＩＰ再送信放送を監視する方法として人間が視聴して監視する方法が考えられるが、映像、音声、字幕、データ放送、番組情報などを常に視聴し続け、地上デジタル放送、ＢＳデジタルと比較して、ＩＰ再送信放送に障害が発生しているかどうかをリアルタイムに確認する作業はきわめて困難である。地上デジタル放送、ＢＳデジタル放送をＣＡＴＶで再送信する場合も同様である。
【先行技術文献】
【特許文献】
【０００５】
【特許文献１】特開２００９−２８４１８４号公報
【発明の概要】
【発明が解決しようとする課題】
【０００６】
したがって、地上デジタル放送、ＢＳデジタル放送とＩＰ再送信放送のそれぞれのデータをリアルタイムに比較し、異常があった際には通知を行う比較監視システムが必要とされた。
【０００７】
ところが、ＩＰ再送信データは、地上デジタル放送データ、ＢＳデジタル放送データと比較して、出現するデータの順番が違っている場合や、同じデータの繰り返し回数が異なる場合があるが、このような違いは実際の視聴に影響がないので、比較監視するときにはこれを無視する必要がある。このように、出現頻度や送信回数が変化する場合には、単純にデータを１対１で比較できないという問題があった。
【０００８】
本発明は、上記に鑑みてなされたものであり、相関性があるデータ列間で、データの出現順番や送信回数が変化する場合でも、一定の相関性を比較監視することを目的とする。
【課題を解決するための手段】
【０００９】
第１の本発明に係る比較監視システムは、第１の伝送路からデータを取得する第１の監視プローブ装置、第２の伝送路からデータを取得する第２の監視プローブ装置、前記第１及び第２の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置を備えた比較監視システムであって、前記第１及び第２の監視プローブ装置それぞれは、伝送路からデータを取得する取得手段と、取得した前記データの内容からチェックコードを生成するチェックコード生成手段と、前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信する送信手段と、を有し、前記比較装置は、前記第１及び第２の監視プローブ装置それぞれから受信した前記比較情報をそれぞれ蓄積する第１及び第２の比較情報バッファと、前記第１及び第２の比較情報バッファそれぞれから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力する比較手段と、を有することを特徴とする。
【００１０】
上記比較監視システムにおいて、前記比較手段は、前記比較情報を受信した時刻から所定の時間以内に、当該比較情報のチェックコードの値と一致する前記比較情報を検索できない場合にアラートを出力することを特徴とする。
【００１１】
上記比較監視システムにおいて、前記第１及び第２の伝送路には複数の種別のデータが伝送されるものであって、前記第１及び第２の監視プローブ装置それぞれは、取得した前記データを種別毎に分類する分類手段と、種別毎に前記チェックコード生成手段及び前記送信手段を有し、前記比較装置は、種別毎に前記比較手段を有することを特徴とする。
【００１２】
上記比較監視システムにおいて、前記第１及び第２の監視プローブ装置は、一番最後に取得した前記データのタイムスタンプを最終タイムスタンプとして取得し、前記比較装置に送信する最終タイムスタンプ取得手段を有し、前記比較装置は、前記第１及び第２の監視プローブ装置それぞれから受信した前記最終タイムスタンプの時間差が所定の時間を超える場合にアラートを出力する最終タイムスタンプ比較手段を有することを特徴とする。
【００１３】
上記比較監視システムにおいて、前記チェックコード生成手段は、前記第１及び第２の伝送路それぞれから取得する前記データ間の一部に存在する既知の相違箇所については、当該相違箇所を同一に変更した後で前記チェックコードを生成することを特徴とする。
【００１４】
上記比較監視システムにおいて、前記送信手段は、前記比較情報とともに当該比較情報に対応する前記データを前記比較装置に送信し、前記比較装置は、前記比較手段がアラートを出力する場合に前記第１及び第２の監視プローブ装置から受信した前記データ間の相違部分を表示する表示手段を有することを特徴とする。
【００１５】
第２の本発明に係る比較監視方法は、第１の伝送路からデータを取得する第１の監視プローブ装置、第２の伝送路からデータを取得する第２の監視プローブ装置、前記第１及び第２の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置による比較監視方法であって、前記第１及び第２の監視プローブ装置それぞれによる、伝送路からデータを取得するステップと、取得した前記データの内容からチェックコードを生成するステップと、前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信するステップと、を有し、前記比較装置による、前記第１及び第２の監視プローブ装置それぞれから受信した前記比較情報を第１及び第２の比較情報バッファそれぞれに蓄積するステップと、前記第１及び第２の比較情報バッファから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力するステップと、を有することを特徴とする。
【発明の効果】
【００１６】
本発明によれば、相関性があるデータ列間で、データの出現順番や送信回数が変化する場合でも、一定の相関性を比較監視することができる。
【図面の簡単な説明】
【００１７】
【図１】本実施の形態における比較監視システムの構成を示す機能ブロック図である。
【図２】データストリームのイメージを示す模式図である。
【図３】上記比較監視システムの比較情報生成部の処理を説明する模式図である。
【図４】上記比較監視システムの比較装置の処理を説明する模式図である。
【図５】比較装置が有する変化データ取り出し部の構成を示す機能ブロック図である。
【図６】上記変化データ取り出し部の表示例を示す図である。
【発明を実施するための形態】
【００１８】
以下、本発明の実施の形態について図面を用いて説明する。
【００１９】
図１は、本実施の形態における比較監視システムの構成を示す機能ブロック図である。同図に示す比較監視システムは、監視プローブ装置２０，３０及び比較装置４０を備え、データストリーム（１）とデータストリーム（２）とを比較し、相違する場合に警告を出力するシステムである。データストリーム（２）は、データストリーム変換部１０によりデータストリーム（１）を変換したものである。
【００２０】
データストリーム変換部１０は、データストリーム（１）（例えば、地デジ放送データ）を入力し、変換処理してデータストリーム（２）（例えば、地デジＩＰ再送信データ）を出力する。具体的には、データストリーム変換部１０は、地デジ放送データの映像データをより符号化効率の高い映像データに変換し、地デジ放送データの音声データ、字幕、データ放送、番組情報等の他のデータを別の形式に変換することなく出力する。データ放送や番組情報など同じ内容のデータが周期的に送られるものに関しては、回数を減らして出力する。例えば、データ放送において同じデータが２回入力された場合に、データストリーム変換部１０は、２回目のデータを出力しない。あるいは、１分間に３回送信されるデータを１分間に２回に減らして送信する。なお、本実施の形態における比較監視システムは、データストリーム変換部１０が、例えば、音声データや番組情報の符号化方式は変換されずに映像データの符号化方式については変換されるような場合、データの内容が変化しない音声データや番組情報等を比較監視の対象とする。つまり、変換の前後で符号化の形式が異なる映像データは比較監視の対象としない。変換前後の形式が異なる場合として、例えば、元の映像がＭＰＥＧ２で変換後がＨ．２６４の場合、あるいは変換後がＭＰＥＧ２のままビットレートを下げた場合、あるいは変換後の形式としてＭＰＥＧ４を用いる場合などがある。本実施の形態では、変換前後の形式が異なる映像データは比較監視の対象としないので、映像データに関していかなる変換が行われてもよい。
【００２１】
図２は、データストリームのイメージを示す模式図である。図２（ａ）に、変換前のデータストリーム（１）のイメージを示し、図２（ｂ）に、変換後のデータストリーム（２）のイメージを示す。図２中の四角はＴｒａｎｓｐｏｒｔ Ｓｔｒｅａｍ（ＴＳ）パケットを表す。
【００２２】
データストリームでは、複数のデータ種別が混在して流れている。データのサイズが大きいものは、パケットに分割されている。図２中のパケット内のＡ，Ｂ，・・・Ｘなどの英字がデータ種別を示し、英字の横の数字がそのデータ種別のパケットの番号を示している。パケットの右側のボックス内の模様は、データの内容を模式している。データ種別が同じで連続する番号を有し、ボックス内の模様が同じものは、同じ１つのデータから分割されたパケットを示している。例えば、図２（ａ）のＡ−５，Ａ−４，Ａ−３のパケットは、１つのデータを分割したパケットである。パケットの下の数字は、各プローブ装置がパケットを受信した時刻を表すタイムスタンプを示している。
【００２３】
なお、データストリーム変換部１０によるデータストリームの変換前後において、パケットの並び順は保証されていない。つまり、データストリーム間でパケットの並び順は一致しないこともある。例えば、図２（ａ）ではパケット「Ｘ−１」は、パケット「Ａ−３」の次に出現しているが、図２（ｂ）ではパケット「Ｘ−１」は、パケット「Ａ−１」の次に出現している。
【００２４】
また、データストリームの変換前後において相関のあるデータのパケットが出現する時刻に差が存在している。図２に示す例では、データストリーム（１）においてパケット「Ｘ−１」に付されたタイムスタンプは「１０：１２：２０．０１０」であるのに対し、データストリーム（２）においてパケット「Ｘ−１」に付されたタイムスタンプは「１０：１２：２０．８４５」となっている。本実施の形態における比較監視システムは、データが欠落していないか、データストリーム（１），（２）間で対応するデータのタイムスタンプの差が所定の範囲内であるか否かを判定する。
【００２５】
図１に戻り、比較監視システムの説明を続ける。監視プローブ装置２０は、データストリーム変換部１０の入力側の伝送路からデータストリーム（１）を入力して比較情報を生成し、パケットから再構成したデータと比較情報を比較装置４０に送信する。監視プローブ装置３０は、データストリーム変換部１０の出力側の伝送路からデータストリーム（２）を入力して比較情報を生成し、パケットから再構成したデータと比較情報を比較装置４０に送信する。比較装置４０は、監視プローブ装置２０，３０から受信した比較情報を比較し、相違を発見したときに警告を出力する。なお、監視プローブ装置２０，３０は、データ及び比較情報をすべて比較装置４０へ送信するのではなく、所定の条件を満たすデータについてのみ、そのデータとそのデータから生成した比較情報を比較装置４０に送信する。監視プローブ装置２０，３０及び比較装置４０の詳細については後述する。
【００２６】
監視プローブ装置２０，３０及び比較装置４０が備える各部は、演算処理装置、記憶装置、メモリ等を備えたコンピュータにより構成して、各部の処理がプログラムによって実行されるものとしてもよい。このプログラムは各装置が備える記憶装置に記憶されており、磁気ディスク、光ディスク、半導体メモリ等の記録媒体に記録することも、ネットワークを通して提供することも可能である。なお、本実施の形態では、監視プローブ装置２０，３０及び比較装置４０を別々の装置として構成したが、もちろん各部を１つの装置で構成するものでもよい。以下、各装置の詳細について説明する。
【００２７】
監視プローブ装置２０と監視プローブ装置３０は、取得するデータストリームが異なる以外は同じであるので、ここでは監視プローブ装置２０について説明する。監視プローブ装置２０は、パケット解析部２１と複数の比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘを有する。
【００２８】
パケット解析部２１は、複数のデータ種別のパケットが混在して伝送されるデータストリームを入力し、入力したパケットをデータ種別毎に分類する。データ種別は、例えば、音声、字幕、データ放送、番組情報などである。データ種別毎に分類されたパケットは、データ種別毎に用意された比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘへ送信される。
【００２９】
比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘは、パケット解析部２１からパケットを受信してデータを再構成し、比較情報を生成して比較装置４０へ送信する。比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘそれぞれは、受信するデータ種別が異なる以外は同じである。監視プローブ装置３０は、監視プローブ装置２０と同様に、データ種別毎の比較情報生成部３２Ａ，３２Ｂ，・・・，３２Ｘを有する。つまり、監視プローブ装置２０，３０は、それぞれ同数の比較情報生成部を有する。
【００３０】
比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘのそれぞれは、パケットを結合してデータを再構築する結合部２２１Ａ，２２１Ｂ，・・・，２２１Ｘ、再構築したデータの内容からチェックコードを生成するチェックコード生成部２２２Ａ，２２２Ｂ，・・・，２２２Ｘ、および再構築したデータと比較情報を比較装置４０へ送信するか否か判定する変化検出部２２３Ａ，２２３Ｂ，・・・，２２３Ｘを有する。比較情報は、チェックコード生成部２２２Ａ，２２２Ｂ，・・・，２２２Ｘが生成したチェックコードと再構築したデータのタイムスタンプを含む情報である。チェックコードは、例えばＣｙｃｌｉｃ Ｒｅｄｕｎｄａｎｃｙ Ｃｈｅｃｋ（ＣＲＣ：巡回冗長検査）を用いてデータから生成した数バイト程度の値である。
【００３１】
図３は、比較情報生成部の処理を説明する模式図である。図３（ａ）〜（ｃ）は、監視プローブ装置２０が有する比較情報生成部２２Ａ，２２Ｂ，２２Ｘの処理の様子を示し、図３（ｄ）〜（ｆ）は、監視プローブ装置３０が有する比較情報生成部３２Ａ，３２Ｂ，３２Ｘの処理の様子を示す。同図では、パケットを受信した順に下から上に並べている。いずれも同様の処理を行うので、ここでは比較情報生成部２２Ａの処理を示す図３（ａ）に着目して説明する。
【００３２】
監視プローブ装置２０において、データ種別が「Ａ」のパケットは、比較情報生成部２２Ａに送信される。図３（ａ）では、Ａ−５，Ａ−４，Ａ−３，・・・，Ａ６のデータ種別「Ａ」のパケットを受信している。結合部２２１Ａは、同じ１つのデータを分割したパケットを結合してデータを再構築する。図３（ａ）では、例えばＡ−５，Ａ−４，Ａ−３のパケットを結合してデータを再構築している。このとき再構築したデータのタイムスタンプを、一番最後のパケットであるＡ−３に付されたタイムスタンプ「１０：１２：１９．０９９」とする。なお、図３（ｂ），（ｅ）の最上段の点線は、データを再構築するためのパケットがまだ揃っていないことを示している。また、図３（ｃ），（ｆ）のように、データが分割されておらず１つのパケットが１つのデータに対応しているものもある。
【００３３】
チェックコード生成部２２２Ａは、再構築したデータのＣＲＣを計算してチェックコードを生成する。例えば、図３（ａ）において、Ａ−５，Ａ−４，Ａ−３から再構築したデータのチェックコードは、０ｘ９９５Ｃであり、Ａ−２，Ａ−１，Ａ０から再構築したデータのチェックコードは、０ｘＤ２３８である。
【００３４】
なお、データストリーム変換部１０が特定のデータ種別の所定の箇所のビットを書き換えるものである場合、チェックコード生成部２２２Ａは、書き換えられる箇所をビットマスクしてチェックコードを生成する。例えば、データストリーム変換部１０がデータ種別「Ｂ」のデータの先頭から１０〜１５ビット目を書き換えて出力するものである場合、チェックコード生成部２２２Ｂ，３２２Ｂは、データの１０〜１５ビット目を固定値で上書きしてチェックコードを生成する。これにより、書き換えられた箇所以外が同じならば同じ値のチェックコードが生成される。あるいは、データストリーム変換部１０が所定の規則に従ってデータの一部を変更する場合、変更前のデータを扱うチェックコード生成部２２２Ｂは、変更されるデータの一部が変更後と同一となるように、そのデータの一部を変更した後でチェックコードを生成する。
【００３５】
変化検出部２２３Ａは、チェックコード生成部２２２Ａが生成したチェックコードが変化する変化点を検出し、変化点を検出した場合、再構築したデータと比較情報を比較装置４０へ送信する。図３（ａ）では、下から２番目と３番目のチェックコードは共に０ｘＤ２３８で変化せず、下から２番目、４番目においてチェックコードが変化している（図３では「変化点」として示している）。したがって、下から２番目、４番目においてデータと比較情報を比較装置４０へ送信する。比較装置４０へ送信する比較情報はチェックコードとタイムスタンプを含む。例えば、図３（ａ）の下から２番目のデータの比較情報は、チェックコード「０ｘＤ２３８」とタイムスタンプ「１０：１２：２０．１２４」を含む。なお、生成したチェックコードの値を直前に生成したチェックコードの値と比較するため、生成したチェックコードは変化検出部２２３Ａの有する記憶手段に一時的に蓄積される。
【００３６】
続いて比較装置４０について説明する。比較装置４０は、監視プローブ装置２０，３０それぞれから受信した対応する比較情報同士を比較し、比較した比較情報が相違していればアラートを出力する。比較装置４０は、監視プローブ装置２０，３０それぞれが送信するデータと比較情報を受信して蓄積する比較情報受信部４２，４３、データ種別毎に比較情報を比較する比較部４４Ａ，４４Ｂ，・・・，４４Ｘを有する。
【００３７】
比較情報受信部４２は、データ種別毎に比較情報バッファ４２１Ａ，４２１Ｂ，・・・，４２１Ｘ、および蓄積部４２２Ａ，４２２Ｂ，・・・，４２２Ｘを有する。比較情報バッファ４２１Ａ，４２１Ｂ，・・・，４２１Ｘは、監視プローブ装置２０が送信した比較情報をデータ種別毎に一時的に蓄積する。蓄積部４２２Ａ，４２２Ｂ，・・・，４２２Ｘは、監視プローブ装置２０が送信したデータをデータ種別毎に蓄積する。例えば、比較情報バッファ４２１Ａには、監視プローブ装置２０の比較情報生成部２２Ａが送信した比較情報、つまり、データストリーム（１）のデータ種別「Ａ」のデータに関する比較情報が一時的に蓄積される。蓄積部４２２Ａには、データストリーム（１）のデータ種別「Ａ」のデータが蓄積される。なお、比較情報受信部４３も同様に、データ種別毎に比較情報バッファ４３１Ａ，４３１Ｂ，・・・，４３１Ｘ、および蓄積部４３２Ａ，４３２Ｂ，・・・，４３２Ｘを有し、監視プローブ装置３０が送信した比較情報とデータを蓄積する。
【００３８】
比較部４４Ａ，４４Ｂ，・・・，４４Ｘはデータ種別毎に用意され、比較情報受信部４２，４３それぞれから対応するデータ種別の比較情報を読み出して比較し、比較情報が相違している場合にアラートを出力する。比較部４４Ａ，４４Ｂ，・・・，４４Ｘは、比較情報バッファ４２１Ａ，４２１Ｂ，・・・，４２１Ｘと比較情報バッファ４３１Ａ，４３１Ｂ，・・・，４３１Ｘそれぞれから対応する比較情報を取得し、その比較情報の組のタイムスタンプの時間差が所定の時間以内であるか否かを判定する。そして、対応する比較情報が取得できない場合、あるいは、タイムスタンプの時間差が所定の時間を超えている場合にアラートを出力する。また、対応する比較情報が取得できない場合もアラートを出力する。
【００３９】
比較部４４Ａを例にとり、アラートを出力する処理をより具体的に説明する。
【００４０】
まず、比較部４４Ａは、比較情報バッファ４２１Ａ，４３１Ａそれぞれから比較情報を古い順に取り出し、比較情報のチェックコードを比較する。
【００４１】
同一のチェックコードを有する比較情報が見つからない場合、その比較情報を受信した時刻から所定の時間以上経過したか否か判定し、所定の時間以上経過していた場合は、タイムアウトのアラートを出力する。なお、比較情報に含まれるタイムスタンプを比較情報を受信した時刻として用いてもよい。
【００４２】
同一のチェックコードを有する比較情報が比較情報バッファ４２１Ａ，４３１Ａそれぞれから見つかった場合、比較情報それぞれのタイムスタンプの差が所定の時間以内であるか否か判定し、タイムスタンプの差が所定の時間を超えていた場合は、時間差エラーのアラートを出力する。
【００４３】
チェックコードが同一で、タイムスタンプの差が所定の時間以内の比較情報はマッチング成立と判断し、比較情報バッファ４２１Ａ，４３１Ａそれぞれからその比較情報を取り除く。そして、マッチングが成立した比較情報より前に受信した比較情報が比較情報バッファ４２１Ａ，４３１Ａに残っている場合、その比較情報に対応する比較情報は欠落したものと判断し、欠落エラーを出力する。
【００４４】
マッチングが成立した比較情報より後に受信した比較情報が比較情報バッファ４２１Ａ，４３１Ａに存在する場合は、上記の処理を繰り返す。
【００４５】
図４は、比較装置４０の処理を説明する模式図である。図４（ａ）は図３（ａ），（ｄ）、図４（ｂ）は図３（ｂ），（ｅ）、図４（ｃ）は図３（ｃ），（ｆ）の比較情報を比較する様子を示す。図４（ａ）〜（ｃ）では、左側にデータストリーム（１）側（比較情報受信部４２）の比較情報バッファ、右側にデータストリーム（２）側（比較情報受信部４３）の比較情報バッファの内容を示している。
【００４６】
図４（ａ）では、チェックコードが同一の対応する比較情報が取得でき、各比較情報のタイムスタンプの時間差も１０００ミリ秒以内である。この場合、正常と判断してアラートは出力されない。
【００４７】
図４（ｂ）では、チェックコードが同一の対応する比較情報が取得できているが、下から３番目の比較情報［ｎ＋２］のタイムスタンプの時間差が１０００ミリ秒を超えているので、時間差エラーのアラートが出力される。
【００４８】
図４（ｃ）では、データストリーム（１）側の下から２番目の比較情報［ｎ＋１］に対応するデータストリーム（２）側の比較情報が取得できないので、欠落エラーのアラートが出力される。図４（ｃ）に示す例では、データストリーム（１）の下から３番目の比較情報［ｎ＋２］に対応するデータストリーム（２）側の比較情報が取得できたときに、データストリーム（２）側の、データストリーム（１）側の比較情報［ｎ＋１］に対応する比較情報が欠落したと判断する。
【００４９】
また、図示していないが、どちらかのデータストリームの比較情報が比較情報バッファに蓄積されてから、所定の時間以上経過しても、対応する比較情報が別のデータストリーム側から取得できない場合、タイムアウトのアラートが出力される。
【００５０】
図５は、比較装置４０がデータの相違部分を表示するための変化データ取り出し部４５を示す図である。変化データ取り出し部４５は、比較部４４Ａ，４４Ｂ，・・・，４４Ｘが相違していると判定した比較情報に対応するデータを各蓄積部４２２Ａ，４３２Ａから読み出し、読み出したデータ間の相違部分を表示する。蓄積部４２２Ａ，４２２Ｂ，・・・，４２２Ｘがデータにタイムスタンプを関連付けて蓄積することで、比較情報に対応するデータを容易に検索することができる。図６に相違部分を表示した例を示す。
【００５１】
次に、比較監視システムの処理の流れについて説明する。
【００５２】
まず、監視プローブ装置２０，３０それぞれが変換前後のデータストリームを取得する。監視プローブ装置２０が変換前のデータストリーム（１）を取得し、監視プローブ装置３０が変換後のデータストリーム（２）を取得する。
【００５３】
続いて、監視プローブ装置２０のパケット解析部２１がパケットをデータ種別毎に分類し、対応する比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘに送信する。監視プローブ装置３０のパケット解析部３１も同様の処理を行う。以下、監視プローブ装置３０において行われる同様の処理については説明を省略する。
【００５４】
続いて、結合部２２１Ａ，２２１Ｂ，・・・，２２１Ｘがパケットを結合してデータを再構成し、チェックコード生成部２２２Ａ，２２２Ｂ，・・・，２２２Ｘがデータのチェックコードを生成する。
【００５５】
そして、変化検出部２２３Ａ，２２３Ｂ，・・・，２２３Ｘがチェックコードが変化したか否かを調べることにより、比較対象のデータであるか否か判定する。比較対象のデータでない場合は、そのデータについての処理を終了する。本実施の形態では、繰り返して送信されるデータの送信回数の違いを無視して相関性を比較監視するために、データ種別毎にチェックコードが変化した場合、つまりデータが変化した場合を比較対象のデータとする。例えば、データストリーム（１）では１分間に３回送信されたデータがデータストリーム（２）では１分間に２回しか送信されない場合でも、どちらも比較対象となるデータは最初の１つである。
【００５６】
比較対象のデータの場合、比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘは、再構成したデータおよびチェックコードとタイムスタンプを含む比較情報を比較装置４０へ送信し、比較装置４０は、受信した比較情報を比較情報バッファ４２１Ａ，・・・，４２１Ｘに、受信したデータを蓄積部４２２Ａ，４２２Ｂ，・・・，４２２Ｘに蓄積する。
【００５７】
そして、比較部４４Ａ，４４Ｂ，・・・，４４Ｘは、比較情報バッファ４２１Ａ，・・・，４２１Ｘ、比較情報バッファ４３１Ａ，・・・，４３１Ｘそれぞれから比較情報を読み出して比較し、比較情報に相違を検出した場合は、アラートを出力するとともに、本実施の形態では、相違を検出した比較情報に対応するデータを比較情報受信部４２，４３それぞれから読み出して相違部分を比較表示する。
【００５８】
また、本実施の形態における比較監視システムは、監視プローブ装置２０，３０が入力したパケットのタイムスタンプを比較して、一方のデータストリームが停止しているか否か判定する。具体的には、監視プローブ装置２０，３０は、データ種別毎に、最後に入力したパケットのタイムスタンプを最終タイムスタンプとして取得して比較装置４０に送信する。最終タイムスタンプはパケットを取得すると更新される。比較装置４０は、監視プローブ装置２０，３０それぞれから受信した最終タイムスタンプを比較し、その差が所定の時間を超えていた場合にアラームを出力する。なお、データストリームの帯域を比較してデータストリームの停止を判定してもよい。
【００５９】
以上説明したように、本実施の形態によれば、監視プローブ装置２０，３０それぞれが取得したデータの内容からチェックコードを算出し、チェックコードの値が直前に生成したチェックコードと異なる場合に、そのチェックコードとデータのタイムスタンプを含む比較情報を比較装置４０へ送信し、比較装置４０は監視プローブ装置２０，３０それぞれから受信した比較情報を比較し、比較情報に相違が検出された場合にアラートを出力することにより、同じチェックコードが連続した場合、つまり同じデータを連続して受信した場合には、比較処理を行わないので、データの送信回数の違いを無視してデータストリーム間の相関性を比較監視することができる。
【００６０】
本実施の形態によれば、比較装置４０がデータを直接比較せず、データの内容から算出したチェックコードを比較するので、データ量にばらつきがある場合でも、比較装置４０の比較処理の処理量のバラツキを抑制することができる。
【００６１】
本実施の形態によれば、パケット解析部２１が入力したパケットをデータ種別毎に分類し、データ種別毎に比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘを有することにより、データストリーム間で出現するデータの順番が異なる場合でも、データの相関性を比較監視することができる。
【００６２】
なお、本実施の形態では、データストリーム変換部１０が入力したデータの送信回数を減らす処理を行う場合について説明したが、データストリーム変換部１０が入力したデータの送信回数を増やす場合でも、データストリーム間の相関性を比較監視することができる。
【００６３】
本実施の形態では、変化検出部がチェックコードの変化点を検出することで比較対象のデータを検出したが、変化検出部の判定条件は、データストリーム変換部１０の仕様に合わせて変更できる。例えば、データストリーム変換部１０が音声データの無音部分を削除する処理を行う場合、変化検出部が無音部分を検出し、無音部分以外のデータを比較対象のデータとして、そのデータの内容から生成したチェックコードを比較装置４０に送信することで比較監視することが可能である。
【符号の説明】
【００６４】
１０…データストリーム変換部
２０，３０…監視プローブ装置
２１，３１…パケット解析部
２２Ａ，２２Ｂ，２２Ｘ，３２Ａ，３２Ｂ，３２Ｘ…比較情報生成部
２２１Ａ，２２１Ｂ，…結合部
２２２Ａ，２２２Ｂ，２２２Ｘ，３２２Ａ，３２２Ｂ，３２２Ｘ…チェックコード生成部
２２３Ａ，２２３Ｂ，２２３Ｘ，３２３Ａ，３２３Ｂ，３２３Ｘ…変化検出部
４０…比較装置
４２，４３…比較情報受信部
４２１Ａ，４２１Ｂ，４２１Ｘ，４３１Ａ，４３１Ｂ，４３１Ｘ…比較情報バッファ
４２２Ａ，４２２Ｂ，４２２Ｘ，４３２Ａ，４３２Ｂ，４３２Ｘ…蓄積部
４４Ａ，４４Ｂ，４４Ｘ…比較部
４５…変化データ取りだし部
【技術分野】
【０００１】
本発明は、データ列間の相関性を比較監視する技術に関する。
【背景技術】
【０００２】
ネットワークを用いた映像配信サービスの提供が広まり、近年では、地上デジタル放送あるいはＢＳデジタル放送を、リアルタイムでネットワークを用いて送信するＩＰ再送信も行われている。ＩＰ再送信を行う際、映像データをより符号化効率の高い映像データに変換したり、同じデータを繰り返し送信されているデータ放送や番組情報などは、その繰り返す回数を減らしたりして、使用する帯域を抑制している。
【０００３】
ＩＰ再送信時には、ＩＰ再送信放送に障害が発生していないか地上デジタル放送、ＢＳデジタル放送と比較して監視する必要がある。例えば、特許文献１には、ＩＰ再送信されるテレビジョン放送を監視する技術が開示されている。
【０００４】
ＩＰ再送信放送を監視する方法として人間が視聴して監視する方法が考えられるが、映像、音声、字幕、データ放送、番組情報などを常に視聴し続け、地上デジタル放送、ＢＳデジタルと比較して、ＩＰ再送信放送に障害が発生しているかどうかをリアルタイムに確認する作業はきわめて困難である。地上デジタル放送、ＢＳデジタル放送をＣＡＴＶで再送信する場合も同様である。
【先行技術文献】
【特許文献】
【０００５】
【特許文献１】特開２００９−２８４１８４号公報
【発明の概要】
【発明が解決しようとする課題】
【０００６】
したがって、地上デジタル放送、ＢＳデジタル放送とＩＰ再送信放送のそれぞれのデータをリアルタイムに比較し、異常があった際には通知を行う比較監視システムが必要とされた。
【０００７】
ところが、ＩＰ再送信データは、地上デジタル放送データ、ＢＳデジタル放送データと比較して、出現するデータの順番が違っている場合や、同じデータの繰り返し回数が異なる場合があるが、このような違いは実際の視聴に影響がないので、比較監視するときにはこれを無視する必要がある。このように、出現頻度や送信回数が変化する場合には、単純にデータを１対１で比較できないという問題があった。
【０００８】
本発明は、上記に鑑みてなされたものであり、相関性があるデータ列間で、データの出現順番や送信回数が変化する場合でも、一定の相関性を比較監視することを目的とする。
【課題を解決するための手段】
【０００９】
第１の本発明に係る比較監視システムは、第１の伝送路からデータを取得する第１の監視プローブ装置、第２の伝送路からデータを取得する第２の監視プローブ装置、前記第１及び第２の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置を備えた比較監視システムであって、前記第１及び第２の監視プローブ装置それぞれは、伝送路からデータを取得する取得手段と、取得した前記データの内容からチェックコードを生成するチェックコード生成手段と、前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信する送信手段と、を有し、前記比較装置は、前記第１及び第２の監視プローブ装置それぞれから受信した前記比較情報をそれぞれ蓄積する第１及び第２の比較情報バッファと、前記第１及び第２の比較情報バッファそれぞれから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力する比較手段と、を有することを特徴とする。
【００１０】
上記比較監視システムにおいて、前記比較手段は、前記比較情報を受信した時刻から所定の時間以内に、当該比較情報のチェックコードの値と一致する前記比較情報を検索できない場合にアラートを出力することを特徴とする。
【００１１】
上記比較監視システムにおいて、前記第１及び第２の伝送路には複数の種別のデータが伝送されるものであって、前記第１及び第２の監視プローブ装置それぞれは、取得した前記データを種別毎に分類する分類手段と、種別毎に前記チェックコード生成手段及び前記送信手段を有し、前記比較装置は、種別毎に前記比較手段を有することを特徴とする。
【００１２】
上記比較監視システムにおいて、前記第１及び第２の監視プローブ装置は、一番最後に取得した前記データのタイムスタンプを最終タイムスタンプとして取得し、前記比較装置に送信する最終タイムスタンプ取得手段を有し、前記比較装置は、前記第１及び第２の監視プローブ装置それぞれから受信した前記最終タイムスタンプの時間差が所定の時間を超える場合にアラートを出力する最終タイムスタンプ比較手段を有することを特徴とする。
【００１３】
上記比較監視システムにおいて、前記チェックコード生成手段は、前記第１及び第２の伝送路それぞれから取得する前記データ間の一部に存在する既知の相違箇所については、当該相違箇所を同一に変更した後で前記チェックコードを生成することを特徴とする。
【００１４】
上記比較監視システムにおいて、前記送信手段は、前記比較情報とともに当該比較情報に対応する前記データを前記比較装置に送信し、前記比較装置は、前記比較手段がアラートを出力する場合に前記第１及び第２の監視プローブ装置から受信した前記データ間の相違部分を表示する表示手段を有することを特徴とする。
【００１５】
第２の本発明に係る比較監視方法は、第１の伝送路からデータを取得する第１の監視プローブ装置、第２の伝送路からデータを取得する第２の監視プローブ装置、前記第１及び第２の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置による比較監視方法であって、前記第１及び第２の監視プローブ装置それぞれによる、伝送路からデータを取得するステップと、取得した前記データの内容からチェックコードを生成するステップと、前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信するステップと、を有し、前記比較装置による、前記第１及び第２の監視プローブ装置それぞれから受信した前記比較情報を第１及び第２の比較情報バッファそれぞれに蓄積するステップと、前記第１及び第２の比較情報バッファから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力するステップと、を有することを特徴とする。
【発明の効果】
【００１６】
本発明によれば、相関性があるデータ列間で、データの出現順番や送信回数が変化する場合でも、一定の相関性を比較監視することができる。
【図面の簡単な説明】
【００１７】
【図１】本実施の形態における比較監視システムの構成を示す機能ブロック図である。
【図２】データストリームのイメージを示す模式図である。
【図３】上記比較監視システムの比較情報生成部の処理を説明する模式図である。
【図４】上記比較監視システムの比較装置の処理を説明する模式図である。
【図５】比較装置が有する変化データ取り出し部の構成を示す機能ブロック図である。
【図６】上記変化データ取り出し部の表示例を示す図である。
【発明を実施するための形態】
【００１８】
以下、本発明の実施の形態について図面を用いて説明する。
【００１９】
図１は、本実施の形態における比較監視システムの構成を示す機能ブロック図である。同図に示す比較監視システムは、監視プローブ装置２０，３０及び比較装置４０を備え、データストリーム（１）とデータストリーム（２）とを比較し、相違する場合に警告を出力するシステムである。データストリーム（２）は、データストリーム変換部１０によりデータストリーム（１）を変換したものである。
【００２０】
データストリーム変換部１０は、データストリーム（１）（例えば、地デジ放送データ）を入力し、変換処理してデータストリーム（２）（例えば、地デジＩＰ再送信データ）を出力する。具体的には、データストリーム変換部１０は、地デジ放送データの映像データをより符号化効率の高い映像データに変換し、地デジ放送データの音声データ、字幕、データ放送、番組情報等の他のデータを別の形式に変換することなく出力する。データ放送や番組情報など同じ内容のデータが周期的に送られるものに関しては、回数を減らして出力する。例えば、データ放送において同じデータが２回入力された場合に、データストリーム変換部１０は、２回目のデータを出力しない。あるいは、１分間に３回送信されるデータを１分間に２回に減らして送信する。なお、本実施の形態における比較監視システムは、データストリーム変換部１０が、例えば、音声データや番組情報の符号化方式は変換されずに映像データの符号化方式については変換されるような場合、データの内容が変化しない音声データや番組情報等を比較監視の対象とする。つまり、変換の前後で符号化の形式が異なる映像データは比較監視の対象としない。変換前後の形式が異なる場合として、例えば、元の映像がＭＰＥＧ２で変換後がＨ．２６４の場合、あるいは変換後がＭＰＥＧ２のままビットレートを下げた場合、あるいは変換後の形式としてＭＰＥＧ４を用いる場合などがある。本実施の形態では、変換前後の形式が異なる映像データは比較監視の対象としないので、映像データに関していかなる変換が行われてもよい。
【００２１】
図２は、データストリームのイメージを示す模式図である。図２（ａ）に、変換前のデータストリーム（１）のイメージを示し、図２（ｂ）に、変換後のデータストリーム（２）のイメージを示す。図２中の四角はＴｒａｎｓｐｏｒｔ Ｓｔｒｅａｍ（ＴＳ）パケットを表す。
【００２２】
データストリームでは、複数のデータ種別が混在して流れている。データのサイズが大きいものは、パケットに分割されている。図２中のパケット内のＡ，Ｂ，・・・Ｘなどの英字がデータ種別を示し、英字の横の数字がそのデータ種別のパケットの番号を示している。パケットの右側のボックス内の模様は、データの内容を模式している。データ種別が同じで連続する番号を有し、ボックス内の模様が同じものは、同じ１つのデータから分割されたパケットを示している。例えば、図２（ａ）のＡ−５，Ａ−４，Ａ−３のパケットは、１つのデータを分割したパケットである。パケットの下の数字は、各プローブ装置がパケットを受信した時刻を表すタイムスタンプを示している。
【００２３】
なお、データストリーム変換部１０によるデータストリームの変換前後において、パケットの並び順は保証されていない。つまり、データストリーム間でパケットの並び順は一致しないこともある。例えば、図２（ａ）ではパケット「Ｘ−１」は、パケット「Ａ−３」の次に出現しているが、図２（ｂ）ではパケット「Ｘ−１」は、パケット「Ａ−１」の次に出現している。
【００２４】
また、データストリームの変換前後において相関のあるデータのパケットが出現する時刻に差が存在している。図２に示す例では、データストリーム（１）においてパケット「Ｘ−１」に付されたタイムスタンプは「１０：１２：２０．０１０」であるのに対し、データストリーム（２）においてパケット「Ｘ−１」に付されたタイムスタンプは「１０：１２：２０．８４５」となっている。本実施の形態における比較監視システムは、データが欠落していないか、データストリーム（１），（２）間で対応するデータのタイムスタンプの差が所定の範囲内であるか否かを判定する。
【００２５】
図１に戻り、比較監視システムの説明を続ける。監視プローブ装置２０は、データストリーム変換部１０の入力側の伝送路からデータストリーム（１）を入力して比較情報を生成し、パケットから再構成したデータと比較情報を比較装置４０に送信する。監視プローブ装置３０は、データストリーム変換部１０の出力側の伝送路からデータストリーム（２）を入力して比較情報を生成し、パケットから再構成したデータと比較情報を比較装置４０に送信する。比較装置４０は、監視プローブ装置２０，３０から受信した比較情報を比較し、相違を発見したときに警告を出力する。なお、監視プローブ装置２０，３０は、データ及び比較情報をすべて比較装置４０へ送信するのではなく、所定の条件を満たすデータについてのみ、そのデータとそのデータから生成した比較情報を比較装置４０に送信する。監視プローブ装置２０，３０及び比較装置４０の詳細については後述する。
【００２６】
監視プローブ装置２０，３０及び比較装置４０が備える各部は、演算処理装置、記憶装置、メモリ等を備えたコンピュータにより構成して、各部の処理がプログラムによって実行されるものとしてもよい。このプログラムは各装置が備える記憶装置に記憶されており、磁気ディスク、光ディスク、半導体メモリ等の記録媒体に記録することも、ネットワークを通して提供することも可能である。なお、本実施の形態では、監視プローブ装置２０，３０及び比較装置４０を別々の装置として構成したが、もちろん各部を１つの装置で構成するものでもよい。以下、各装置の詳細について説明する。
【００２７】
監視プローブ装置２０と監視プローブ装置３０は、取得するデータストリームが異なる以外は同じであるので、ここでは監視プローブ装置２０について説明する。監視プローブ装置２０は、パケット解析部２１と複数の比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘを有する。
【００２８】
パケット解析部２１は、複数のデータ種別のパケットが混在して伝送されるデータストリームを入力し、入力したパケットをデータ種別毎に分類する。データ種別は、例えば、音声、字幕、データ放送、番組情報などである。データ種別毎に分類されたパケットは、データ種別毎に用意された比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘへ送信される。
【００２９】
比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘは、パケット解析部２１からパケットを受信してデータを再構成し、比較情報を生成して比較装置４０へ送信する。比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘそれぞれは、受信するデータ種別が異なる以外は同じである。監視プローブ装置３０は、監視プローブ装置２０と同様に、データ種別毎の比較情報生成部３２Ａ，３２Ｂ，・・・，３２Ｘを有する。つまり、監視プローブ装置２０，３０は、それぞれ同数の比較情報生成部を有する。
【００３０】
比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘのそれぞれは、パケットを結合してデータを再構築する結合部２２１Ａ，２２１Ｂ，・・・，２２１Ｘ、再構築したデータの内容からチェックコードを生成するチェックコード生成部２２２Ａ，２２２Ｂ，・・・，２２２Ｘ、および再構築したデータと比較情報を比較装置４０へ送信するか否か判定する変化検出部２２３Ａ，２２３Ｂ，・・・，２２３Ｘを有する。比較情報は、チェックコード生成部２２２Ａ，２２２Ｂ，・・・，２２２Ｘが生成したチェックコードと再構築したデータのタイムスタンプを含む情報である。チェックコードは、例えばＣｙｃｌｉｃ Ｒｅｄｕｎｄａｎｃｙ Ｃｈｅｃｋ（ＣＲＣ：巡回冗長検査）を用いてデータから生成した数バイト程度の値である。
【００３１】
図３は、比較情報生成部の処理を説明する模式図である。図３（ａ）〜（ｃ）は、監視プローブ装置２０が有する比較情報生成部２２Ａ，２２Ｂ，２２Ｘの処理の様子を示し、図３（ｄ）〜（ｆ）は、監視プローブ装置３０が有する比較情報生成部３２Ａ，３２Ｂ，３２Ｘの処理の様子を示す。同図では、パケットを受信した順に下から上に並べている。いずれも同様の処理を行うので、ここでは比較情報生成部２２Ａの処理を示す図３（ａ）に着目して説明する。
【００３２】
監視プローブ装置２０において、データ種別が「Ａ」のパケットは、比較情報生成部２２Ａに送信される。図３（ａ）では、Ａ−５，Ａ−４，Ａ−３，・・・，Ａ６のデータ種別「Ａ」のパケットを受信している。結合部２２１Ａは、同じ１つのデータを分割したパケットを結合してデータを再構築する。図３（ａ）では、例えばＡ−５，Ａ−４，Ａ−３のパケットを結合してデータを再構築している。このとき再構築したデータのタイムスタンプを、一番最後のパケットであるＡ−３に付されたタイムスタンプ「１０：１２：１９．０９９」とする。なお、図３（ｂ），（ｅ）の最上段の点線は、データを再構築するためのパケットがまだ揃っていないことを示している。また、図３（ｃ），（ｆ）のように、データが分割されておらず１つのパケットが１つのデータに対応しているものもある。
【００３３】
チェックコード生成部２２２Ａは、再構築したデータのＣＲＣを計算してチェックコードを生成する。例えば、図３（ａ）において、Ａ−５，Ａ−４，Ａ−３から再構築したデータのチェックコードは、０ｘ９９５Ｃであり、Ａ−２，Ａ−１，Ａ０から再構築したデータのチェックコードは、０ｘＤ２３８である。
【００３４】
なお、データストリーム変換部１０が特定のデータ種別の所定の箇所のビットを書き換えるものである場合、チェックコード生成部２２２Ａは、書き換えられる箇所をビットマスクしてチェックコードを生成する。例えば、データストリーム変換部１０がデータ種別「Ｂ」のデータの先頭から１０〜１５ビット目を書き換えて出力するものである場合、チェックコード生成部２２２Ｂ，３２２Ｂは、データの１０〜１５ビット目を固定値で上書きしてチェックコードを生成する。これにより、書き換えられた箇所以外が同じならば同じ値のチェックコードが生成される。あるいは、データストリーム変換部１０が所定の規則に従ってデータの一部を変更する場合、変更前のデータを扱うチェックコード生成部２２２Ｂは、変更されるデータの一部が変更後と同一となるように、そのデータの一部を変更した後でチェックコードを生成する。
【００３５】
変化検出部２２３Ａは、チェックコード生成部２２２Ａが生成したチェックコードが変化する変化点を検出し、変化点を検出した場合、再構築したデータと比較情報を比較装置４０へ送信する。図３（ａ）では、下から２番目と３番目のチェックコードは共に０ｘＤ２３８で変化せず、下から２番目、４番目においてチェックコードが変化している（図３では「変化点」として示している）。したがって、下から２番目、４番目においてデータと比較情報を比較装置４０へ送信する。比較装置４０へ送信する比較情報はチェックコードとタイムスタンプを含む。例えば、図３（ａ）の下から２番目のデータの比較情報は、チェックコード「０ｘＤ２３８」とタイムスタンプ「１０：１２：２０．１２４」を含む。なお、生成したチェックコードの値を直前に生成したチェックコードの値と比較するため、生成したチェックコードは変化検出部２２３Ａの有する記憶手段に一時的に蓄積される。
【００３６】
続いて比較装置４０について説明する。比較装置４０は、監視プローブ装置２０，３０それぞれから受信した対応する比較情報同士を比較し、比較した比較情報が相違していればアラートを出力する。比較装置４０は、監視プローブ装置２０，３０それぞれが送信するデータと比較情報を受信して蓄積する比較情報受信部４２，４３、データ種別毎に比較情報を比較する比較部４４Ａ，４４Ｂ，・・・，４４Ｘを有する。
【００３７】
比較情報受信部４２は、データ種別毎に比較情報バッファ４２１Ａ，４２１Ｂ，・・・，４２１Ｘ、および蓄積部４２２Ａ，４２２Ｂ，・・・，４２２Ｘを有する。比較情報バッファ４２１Ａ，４２１Ｂ，・・・，４２１Ｘは、監視プローブ装置２０が送信した比較情報をデータ種別毎に一時的に蓄積する。蓄積部４２２Ａ，４２２Ｂ，・・・，４２２Ｘは、監視プローブ装置２０が送信したデータをデータ種別毎に蓄積する。例えば、比較情報バッファ４２１Ａには、監視プローブ装置２０の比較情報生成部２２Ａが送信した比較情報、つまり、データストリーム（１）のデータ種別「Ａ」のデータに関する比較情報が一時的に蓄積される。蓄積部４２２Ａには、データストリーム（１）のデータ種別「Ａ」のデータが蓄積される。なお、比較情報受信部４３も同様に、データ種別毎に比較情報バッファ４３１Ａ，４３１Ｂ，・・・，４３１Ｘ、および蓄積部４３２Ａ，４３２Ｂ，・・・，４３２Ｘを有し、監視プローブ装置３０が送信した比較情報とデータを蓄積する。
【００３８】
比較部４４Ａ，４４Ｂ，・・・，４４Ｘはデータ種別毎に用意され、比較情報受信部４２，４３それぞれから対応するデータ種別の比較情報を読み出して比較し、比較情報が相違している場合にアラートを出力する。比較部４４Ａ，４４Ｂ，・・・，４４Ｘは、比較情報バッファ４２１Ａ，４２１Ｂ，・・・，４２１Ｘと比較情報バッファ４３１Ａ，４３１Ｂ，・・・，４３１Ｘそれぞれから対応する比較情報を取得し、その比較情報の組のタイムスタンプの時間差が所定の時間以内であるか否かを判定する。そして、対応する比較情報が取得できない場合、あるいは、タイムスタンプの時間差が所定の時間を超えている場合にアラートを出力する。また、対応する比較情報が取得できない場合もアラートを出力する。
【００３９】
比較部４４Ａを例にとり、アラートを出力する処理をより具体的に説明する。
【００４０】
まず、比較部４４Ａは、比較情報バッファ４２１Ａ，４３１Ａそれぞれから比較情報を古い順に取り出し、比較情報のチェックコードを比較する。
【００４１】
同一のチェックコードを有する比較情報が見つからない場合、その比較情報を受信した時刻から所定の時間以上経過したか否か判定し、所定の時間以上経過していた場合は、タイムアウトのアラートを出力する。なお、比較情報に含まれるタイムスタンプを比較情報を受信した時刻として用いてもよい。
【００４２】
同一のチェックコードを有する比較情報が比較情報バッファ４２１Ａ，４３１Ａそれぞれから見つかった場合、比較情報それぞれのタイムスタンプの差が所定の時間以内であるか否か判定し、タイムスタンプの差が所定の時間を超えていた場合は、時間差エラーのアラートを出力する。
【００４３】
チェックコードが同一で、タイムスタンプの差が所定の時間以内の比較情報はマッチング成立と判断し、比較情報バッファ４２１Ａ，４３１Ａそれぞれからその比較情報を取り除く。そして、マッチングが成立した比較情報より前に受信した比較情報が比較情報バッファ４２１Ａ，４３１Ａに残っている場合、その比較情報に対応する比較情報は欠落したものと判断し、欠落エラーを出力する。
【００４４】
マッチングが成立した比較情報より後に受信した比較情報が比較情報バッファ４２１Ａ，４３１Ａに存在する場合は、上記の処理を繰り返す。
【００４５】
図４は、比較装置４０の処理を説明する模式図である。図４（ａ）は図３（ａ），（ｄ）、図４（ｂ）は図３（ｂ），（ｅ）、図４（ｃ）は図３（ｃ），（ｆ）の比較情報を比較する様子を示す。図４（ａ）〜（ｃ）では、左側にデータストリーム（１）側（比較情報受信部４２）の比較情報バッファ、右側にデータストリーム（２）側（比較情報受信部４３）の比較情報バッファの内容を示している。
【００４６】
図４（ａ）では、チェックコードが同一の対応する比較情報が取得でき、各比較情報のタイムスタンプの時間差も１０００ミリ秒以内である。この場合、正常と判断してアラートは出力されない。
【００４７】
図４（ｂ）では、チェックコードが同一の対応する比較情報が取得できているが、下から３番目の比較情報［ｎ＋２］のタイムスタンプの時間差が１０００ミリ秒を超えているので、時間差エラーのアラートが出力される。
【００４８】
図４（ｃ）では、データストリーム（１）側の下から２番目の比較情報［ｎ＋１］に対応するデータストリーム（２）側の比較情報が取得できないので、欠落エラーのアラートが出力される。図４（ｃ）に示す例では、データストリーム（１）の下から３番目の比較情報［ｎ＋２］に対応するデータストリーム（２）側の比較情報が取得できたときに、データストリーム（２）側の、データストリーム（１）側の比較情報［ｎ＋１］に対応する比較情報が欠落したと判断する。
【００４９】
また、図示していないが、どちらかのデータストリームの比較情報が比較情報バッファに蓄積されてから、所定の時間以上経過しても、対応する比較情報が別のデータストリーム側から取得できない場合、タイムアウトのアラートが出力される。
【００５０】
図５は、比較装置４０がデータの相違部分を表示するための変化データ取り出し部４５を示す図である。変化データ取り出し部４５は、比較部４４Ａ，４４Ｂ，・・・，４４Ｘが相違していると判定した比較情報に対応するデータを各蓄積部４２２Ａ，４３２Ａから読み出し、読み出したデータ間の相違部分を表示する。蓄積部４２２Ａ，４２２Ｂ，・・・，４２２Ｘがデータにタイムスタンプを関連付けて蓄積することで、比較情報に対応するデータを容易に検索することができる。図６に相違部分を表示した例を示す。
【００５１】
次に、比較監視システムの処理の流れについて説明する。
【００５２】
まず、監視プローブ装置２０，３０それぞれが変換前後のデータストリームを取得する。監視プローブ装置２０が変換前のデータストリーム（１）を取得し、監視プローブ装置３０が変換後のデータストリーム（２）を取得する。
【００５３】
続いて、監視プローブ装置２０のパケット解析部２１がパケットをデータ種別毎に分類し、対応する比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘに送信する。監視プローブ装置３０のパケット解析部３１も同様の処理を行う。以下、監視プローブ装置３０において行われる同様の処理については説明を省略する。
【００５４】
続いて、結合部２２１Ａ，２２１Ｂ，・・・，２２１Ｘがパケットを結合してデータを再構成し、チェックコード生成部２２２Ａ，２２２Ｂ，・・・，２２２Ｘがデータのチェックコードを生成する。
【００５５】
そして、変化検出部２２３Ａ，２２３Ｂ，・・・，２２３Ｘがチェックコードが変化したか否かを調べることにより、比較対象のデータであるか否か判定する。比較対象のデータでない場合は、そのデータについての処理を終了する。本実施の形態では、繰り返して送信されるデータの送信回数の違いを無視して相関性を比較監視するために、データ種別毎にチェックコードが変化した場合、つまりデータが変化した場合を比較対象のデータとする。例えば、データストリーム（１）では１分間に３回送信されたデータがデータストリーム（２）では１分間に２回しか送信されない場合でも、どちらも比較対象となるデータは最初の１つである。
【００５６】
比較対象のデータの場合、比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘは、再構成したデータおよびチェックコードとタイムスタンプを含む比較情報を比較装置４０へ送信し、比較装置４０は、受信した比較情報を比較情報バッファ４２１Ａ，・・・，４２１Ｘに、受信したデータを蓄積部４２２Ａ，４２２Ｂ，・・・，４２２Ｘに蓄積する。
【００５７】
そして、比較部４４Ａ，４４Ｂ，・・・，４４Ｘは、比較情報バッファ４２１Ａ，・・・，４２１Ｘ、比較情報バッファ４３１Ａ，・・・，４３１Ｘそれぞれから比較情報を読み出して比較し、比較情報に相違を検出した場合は、アラートを出力するとともに、本実施の形態では、相違を検出した比較情報に対応するデータを比較情報受信部４２，４３それぞれから読み出して相違部分を比較表示する。
【００５８】
また、本実施の形態における比較監視システムは、監視プローブ装置２０，３０が入力したパケットのタイムスタンプを比較して、一方のデータストリームが停止しているか否か判定する。具体的には、監視プローブ装置２０，３０は、データ種別毎に、最後に入力したパケットのタイムスタンプを最終タイムスタンプとして取得して比較装置４０に送信する。最終タイムスタンプはパケットを取得すると更新される。比較装置４０は、監視プローブ装置２０，３０それぞれから受信した最終タイムスタンプを比較し、その差が所定の時間を超えていた場合にアラームを出力する。なお、データストリームの帯域を比較してデータストリームの停止を判定してもよい。
【００５９】
以上説明したように、本実施の形態によれば、監視プローブ装置２０，３０それぞれが取得したデータの内容からチェックコードを算出し、チェックコードの値が直前に生成したチェックコードと異なる場合に、そのチェックコードとデータのタイムスタンプを含む比較情報を比較装置４０へ送信し、比較装置４０は監視プローブ装置２０，３０それぞれから受信した比較情報を比較し、比較情報に相違が検出された場合にアラートを出力することにより、同じチェックコードが連続した場合、つまり同じデータを連続して受信した場合には、比較処理を行わないので、データの送信回数の違いを無視してデータストリーム間の相関性を比較監視することができる。
【００６０】
本実施の形態によれば、比較装置４０がデータを直接比較せず、データの内容から算出したチェックコードを比較するので、データ量にばらつきがある場合でも、比較装置４０の比較処理の処理量のバラツキを抑制することができる。
【００６１】
本実施の形態によれば、パケット解析部２１が入力したパケットをデータ種別毎に分類し、データ種別毎に比較情報生成部２２Ａ，２２Ｂ，・・・，２２Ｘを有することにより、データストリーム間で出現するデータの順番が異なる場合でも、データの相関性を比較監視することができる。
【００６２】
なお、本実施の形態では、データストリーム変換部１０が入力したデータの送信回数を減らす処理を行う場合について説明したが、データストリーム変換部１０が入力したデータの送信回数を増やす場合でも、データストリーム間の相関性を比較監視することができる。
【００６３】
本実施の形態では、変化検出部がチェックコードの変化点を検出することで比較対象のデータを検出したが、変化検出部の判定条件は、データストリーム変換部１０の仕様に合わせて変更できる。例えば、データストリーム変換部１０が音声データの無音部分を削除する処理を行う場合、変化検出部が無音部分を検出し、無音部分以外のデータを比較対象のデータとして、そのデータの内容から生成したチェックコードを比較装置４０に送信することで比較監視することが可能である。
【符号の説明】
【００６４】
１０…データストリーム変換部
２０，３０…監視プローブ装置
２１，３１…パケット解析部
２２Ａ，２２Ｂ，２２Ｘ，３２Ａ，３２Ｂ，３２Ｘ…比較情報生成部
２２１Ａ，２２１Ｂ，…結合部
２２２Ａ，２２２Ｂ，２２２Ｘ，３２２Ａ，３２２Ｂ，３２２Ｘ…チェックコード生成部
２２３Ａ，２２３Ｂ，２２３Ｘ，３２３Ａ，３２３Ｂ，３２３Ｘ…変化検出部
４０…比較装置
４２，４３…比較情報受信部
４２１Ａ，４２１Ｂ，４２１Ｘ，４３１Ａ，４３１Ｂ，４３１Ｘ…比較情報バッファ
４２２Ａ，４２２Ｂ，４２２Ｘ，４３２Ａ，４３２Ｂ，４３２Ｘ…蓄積部
４４Ａ，４４Ｂ，４４Ｘ…比較部
４５…変化データ取りだし部
【特許請求の範囲】
【請求項１】
第１の伝送路からデータを取得する第１の監視プローブ装置、第２の伝送路からデータを取得する第２の監視プローブ装置、前記第１及び第２の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置を備えた比較監視システムであって、
前記第１及び第２の監視プローブ装置それぞれは、
伝送路からデータを取得する取得手段と、
取得した前記データの内容からチェックコードを生成するチェックコード生成手段と、
前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信する送信手段と、を有し、
前記比較装置は、
前記第１及び第２の監視プローブ装置それぞれから受信した前記比較情報をそれぞれ蓄積する第１及び第２の比較情報バッファと、
前記第１及び第２の比較情報バッファそれぞれから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力する比較手段と、を有すること
を特徴とする比較監視システム。
【請求項２】
前記比較手段は、前記比較情報を受信した時刻から所定の時間以内に、当該比較情報のチェックコードの値と一致する前記比較情報を検索できない場合にアラートを出力することを特徴とする請求項１記載の比較監視システム。
【請求項３】
前記第１及び第２の伝送路には複数の種別のデータが伝送されるものであって、
前記第１及び第２の監視プローブ装置それぞれは、
取得した前記データを種別毎に分類する分類手段と、
種別毎に前記チェックコード生成手段及び前記送信手段を有し、
前記比較装置は、
種別毎に前記比較手段を有すること
を特徴とする請求項１又は２記載の比較監視システム。
【請求項４】
前記第１及び第２の監視プローブ装置は、
一番最後に取得した前記データのタイムスタンプを最終タイムスタンプとして取得し、前記比較装置に送信する最終タイムスタンプ取得手段を有し、
前記比較装置は、
前記第１及び第２の監視プローブ装置それぞれから受信した前記最終タイムスタンプの時間差が所定の時間を超える場合にアラートを出力する最終タイムスタンプ比較手段を有すること
を特徴とする請求項１乃至３のいずれかに記載の比較監視システム。
【請求項５】
前記チェックコード生成手段は、前記第１及び第２の伝送路それぞれから取得する前記データ間の一部に存在する既知の相違箇所については、当該相違箇所を同一に変更した後で前記チェックコードを生成することを特徴とする請求項１乃至４のいずれかに記載の比較監視システム。
【請求項６】
前記送信手段は、前記比較情報とともに当該比較情報に対応する前記データを前記比較装置に送信し、
前記比較装置は、
前記比較手段がアラートを出力する場合に前記第１及び第２の監視プローブ装置から受信した前記データ間の相違部分を表示する表示手段を有すること
を特徴とする請求項１乃至５のいずれかに記載の比較監視システム。
【請求項７】
第１の伝送路からデータを取得する第１の監視プローブ装置、第２の伝送路からデータを取得する第２の監視プローブ装置、前記第１及び第２の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置による比較監視方法であって、
前記第１及び第２の監視プローブ装置それぞれによる、
伝送路からデータを取得するステップと、
取得した前記データの内容からチェックコードを生成するステップと、
前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信するステップと、を有し、
前記比較装置による、
前記第１及び第２の監視プローブ装置それぞれから受信した前記比較情報を第１及び第２の比較情報バッファそれぞれに蓄積するステップと、
前記第１及び第２の比較情報バッファから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力するステップと、を有すること
を特徴とする比較監視方法。
【請求項１】
第１の伝送路からデータを取得する第１の監視プローブ装置、第２の伝送路からデータを取得する第２の監視プローブ装置、前記第１及び第２の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置を備えた比較監視システムであって、
前記第１及び第２の監視プローブ装置それぞれは、
伝送路からデータを取得する取得手段と、
取得した前記データの内容からチェックコードを生成するチェックコード生成手段と、
前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信する送信手段と、を有し、
前記比較装置は、
前記第１及び第２の監視プローブ装置それぞれから受信した前記比較情報をそれぞれ蓄積する第１及び第２の比較情報バッファと、
前記第１及び第２の比較情報バッファそれぞれから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力する比較手段と、を有すること
を特徴とする比較監視システム。
【請求項２】
前記比較手段は、前記比較情報を受信した時刻から所定の時間以内に、当該比較情報のチェックコードの値と一致する前記比較情報を検索できない場合にアラートを出力することを特徴とする請求項１記載の比較監視システム。
【請求項３】
前記第１及び第２の伝送路には複数の種別のデータが伝送されるものであって、
前記第１及び第２の監視プローブ装置それぞれは、
取得した前記データを種別毎に分類する分類手段と、
種別毎に前記チェックコード生成手段及び前記送信手段を有し、
前記比較装置は、
種別毎に前記比較手段を有すること
を特徴とする請求項１又は２記載の比較監視システム。
【請求項４】
前記第１及び第２の監視プローブ装置は、
一番最後に取得した前記データのタイムスタンプを最終タイムスタンプとして取得し、前記比較装置に送信する最終タイムスタンプ取得手段を有し、
前記比較装置は、
前記第１及び第２の監視プローブ装置それぞれから受信した前記最終タイムスタンプの時間差が所定の時間を超える場合にアラートを出力する最終タイムスタンプ比較手段を有すること
を特徴とする請求項１乃至３のいずれかに記載の比較監視システム。
【請求項５】
前記チェックコード生成手段は、前記第１及び第２の伝送路それぞれから取得する前記データ間の一部に存在する既知の相違箇所については、当該相違箇所を同一に変更した後で前記チェックコードを生成することを特徴とする請求項１乃至４のいずれかに記載の比較監視システム。
【請求項６】
前記送信手段は、前記比較情報とともに当該比較情報に対応する前記データを前記比較装置に送信し、
前記比較装置は、
前記比較手段がアラートを出力する場合に前記第１及び第２の監視プローブ装置から受信した前記データ間の相違部分を表示する表示手段を有すること
を特徴とする請求項１乃至５のいずれかに記載の比較監視システム。
【請求項７】
第１の伝送路からデータを取得する第１の監視プローブ装置、第２の伝送路からデータを取得する第２の監視プローブ装置、前記第１及び第２の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置による比較監視方法であって、
前記第１及び第２の監視プローブ装置それぞれによる、
伝送路からデータを取得するステップと、
取得した前記データの内容からチェックコードを生成するステップと、
前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信するステップと、を有し、
前記比較装置による、
前記第１及び第２の監視プローブ装置それぞれから受信した前記比較情報を第１及び第２の比較情報バッファそれぞれに蓄積するステップと、
前記第１及び第２の比較情報バッファから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力するステップと、を有すること
を特徴とする比較監視方法。
【図１】
【図２】
【図３】
【図４】
【図５】
【図６】
【図２】
【図３】
【図４】
【図５】
【図６】
【公開番号】特開２０１１−２４４２７７（Ｐ２０１１−２４４２７７Ａ）
【公開日】平成２３年１２月１日（２０１１．１２．１）
【国際特許分類】
【出願番号】特願２０１０−１１５５８７（Ｐ２０１０−１１５５８７）
【出願日】平成２２年５月１９日（２０１０．５．１９）
【出願人】（５００１９７１４３）株式会社ＮＴＴぷらら (4)
【出願人】（３９８０３５６０４）株式会社トラフィック・シム (8)
【出願人】（３９９０３５７６６）エヌ・ティ・ティ・コミュニケーションズ株式会社 (321)
【Ｆターム（参考）】
【公開日】平成２３年１２月１日（２０１１．１２．１）
【国際特許分類】
【出願日】平成２２年５月１９日（２０１０．５．１９）
【出願人】（５００１９７１４３）株式会社ＮＴＴぷらら (4)
【出願人】（３９８０３５６０４）株式会社トラフィック・シム (8)
【出願人】（３９９０３５７６６）エヌ・ティ・ティ・コミュニケーションズ株式会社 (321)
【Ｆターム（参考）】
[ Back to top ]