JP4901977B2 - Comparative monitoring system and comparative monitoring method - Google Patents
Comparative monitoring system and comparative monitoring method Download PDFInfo
- Publication number
- JP4901977B2 JP4901977B2 JP2010115587A JP2010115587A JP4901977B2 JP 4901977 B2 JP4901977 B2 JP 4901977B2 JP 2010115587 A JP2010115587 A JP 2010115587A JP 2010115587 A JP2010115587 A JP 2010115587A JP 4901977 B2 JP4901977 B2 JP 4901977B2
- Authority
- JP
- Japan
- Prior art keywords
- comparison
- data
- comparison information
- check code
- monitoring probe
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Active
Links
Images
Landscapes
- Two-Way Televisions, Distribution Of Moving Picture Or The Like (AREA)
Description
本発明は、データ列間の相関性を比較監視する技術に関する。 The present invention relates to a technique for comparing and monitoring the correlation between data strings.
ネットワークを用いた映像配信サービスの提供が広まり、近年では、地上デジタル放送あるいはBSデジタル放送を、リアルタイムでネットワークを用いて送信するIP再送信も行われている。IP再送信を行う際、映像データをより符号化効率の高い映像データに変換したり、同じデータを繰り返し送信されているデータ放送や番組情報などは、その繰り返す回数を減らしたりして、使用する帯域を抑制している。 The provision of video distribution services using networks has become widespread, and in recent years, IP retransmission has also been performed in which terrestrial digital broadcasting or BS digital broadcasting is transmitted in real time using a network. When performing IP retransmission, convert video data to video data with higher encoding efficiency, or use data broadcasts and program information that are repeatedly transmitted with the same data, reducing the number of repetitions. Bandwidth is suppressed.
IP再送信時には、IP再送信放送に障害が発生していないか地上デジタル放送、BSデジタル放送と比較して監視する必要がある。例えば、特許文献1には、IP再送信されるテレビジョン放送を監視する技術が開示されている。
At the time of IP retransmission, it is necessary to monitor whether there is a failure in the IP retransmission broadcast as compared with the terrestrial digital broadcast or BS digital broadcast. For example,
IP再送信放送を監視する方法として人間が視聴して監視する方法が考えられるが、映像、音声、字幕、データ放送、番組情報などを常に視聴し続け、地上デジタル放送、BSデジタルと比較して、IP再送信放送に障害が発生しているかどうかをリアルタイムに確認する作業はきわめて困難である。地上デジタル放送、BSデジタル放送をCATVで再送信する場合も同様である。 As a method for monitoring IP retransmission broadcasts, a method of watching and monitoring by humans can be considered, but video, audio, subtitles, data broadcasts, program information, etc. are always watched, compared with digital terrestrial broadcasts and BS digitals. It is extremely difficult to confirm in real time whether a failure has occurred in the IP retransmission broadcast. The same applies when terrestrial digital broadcasting and BS digital broadcasting are retransmitted by CATV.
したがって、地上デジタル放送、BSデジタル放送とIP再送信放送のそれぞれのデータをリアルタイムに比較し、異常があった際には通知を行う比較監視システムが必要とされた。 Therefore, there is a need for a comparative monitoring system that compares the data of terrestrial digital broadcasting, BS digital broadcasting, and IP retransmission broadcasting in real time, and notifies when there is an abnormality.
ところが、IP再送信データは、地上デジタル放送データ、BSデジタル放送データと比較して、出現するデータの順番が違っている場合や、同じデータの繰り返し回数が異なる場合があるが、このような違いは実際の視聴に影響がないので、比較監視するときにはこれを無視する必要がある。このように、出現頻度や送信回数が変化する場合には、単純にデータを1対1で比較できないという問題があった。 However, IP retransmitted data may appear in a different order of data or the number of repetitions of the same data compared to terrestrial digital broadcast data and BS digital broadcast data. Does not affect the actual viewing, so it is necessary to ignore this when performing comparative monitoring. As described above, when the appearance frequency or the number of transmissions changes, there is a problem that data cannot be simply compared on a one-to-one basis.
本発明は、上記に鑑みてなされたものであり、相関性があるデータ列間で、データの出現順番や送信回数が変化する場合でも、一定の相関性を比較監視することを目的とする。 The present invention has been made in view of the above, and an object of the present invention is to compare and monitor a certain correlation even when the appearance order of data and the number of transmissions change between correlated data strings.
第1の本発明に係る比較監視システムは、第1の伝送路からデータを取得する第1の監視プローブ装置、第2の伝送路からデータを取得する第2の監視プローブ装置、前記第1及び第2の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置を備えた比較監視システムであって、前記第1及び第2の監視プローブ装置それぞれは、伝送路からデータを取得する取得手段と、取得した前記データの内容からチェックコードを生成するチェックコード生成手段と、前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信する送信手段と、を有し、前記比較装置は、前記第1及び第2の監視プローブ装置それぞれから受信した前記比較情報をそれぞれ蓄積する第1及び第2の比較情報バッファと、前記第1及び第2の比較情報バッファそれぞれから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力する比較手段と、を有することを特徴とする。 A comparative monitoring system according to a first aspect of the present invention includes a first monitoring probe device that acquires data from a first transmission line, a second monitoring probe device that acquires data from a second transmission line, A comparison monitoring system comprising a comparison device for comparing whether or not predetermined data among the data acquired by each of the second monitoring probe devices is the same, wherein each of the first and second monitoring probe devices includes: An acquisition means for acquiring data from a transmission line, a check code generation means for generating a check code from the acquired data contents, and the check code when the value of the check code is different from the value of the check code generated immediately before And transmission means for transmitting comparison information including a time stamp of the data to the comparison device, the comparison device comprising the first and second monitoring devices. The first and second comparison information buffers that store the comparison information received from the probe devices respectively match the check code values included in the comparison information from the first and second comparison information buffers. Comparing means for searching for the set of comparison information and outputting an alert when the time difference of the time stamps included in the set of comparison information exceeds a predetermined time.
上記比較監視システムにおいて、前記比較手段は、前記比較情報を受信した時刻から所定の時間以内に、当該比較情報のチェックコードの値と一致する前記比較情報を検索できない場合にアラートを出力することを特徴とする。 In the comparison monitoring system, the comparison means outputs an alert when the comparison information that matches the check code value of the comparison information cannot be searched within a predetermined time from the time when the comparison information is received. Features.
上記比較監視システムにおいて、前記第1及び第2の伝送路には複数の種別のデータが伝送されるものであって、前記第1及び第2の監視プローブ装置それぞれは、取得した前記データを種別毎に分類する分類手段と、種別毎に前記チェックコード生成手段及び前記送信手段を有し、前記比較装置は、種別毎に前記比較手段を有することを特徴とする。 In the comparative monitoring system, a plurality of types of data are transmitted to the first and second transmission paths, and each of the first and second monitoring probe devices classifies the acquired data. A classifying unit that classifies each type; and a check code generating unit and a transmitting unit for each type; and the comparison device includes the comparing unit for each type.
上記比較監視システムにおいて、前記第1及び第2の監視プローブ装置は、一番最後に取得した前記データのタイムスタンプを最終タイムスタンプとして取得し、前記比較装置に送信する最終タイムスタンプ取得手段を有し、前記比較装置は、前記第1及び第2の監視プローブ装置それぞれから受信した前記最終タイムスタンプの時間差が所定の時間を超える場合にアラートを出力する最終タイムスタンプ比較手段を有することを特徴とする。 In the comparison and monitoring system, the first and second monitoring probe devices have a last time stamp obtaining unit that obtains a time stamp of the data acquired last as a last time stamp and transmits the last time stamp to the comparison device. The comparison device has a final time stamp comparison means for outputting an alert when the time difference between the final time stamps received from the first and second monitoring probe devices exceeds a predetermined time. To do.
上記比較監視システムにおいて、前記チェックコード生成手段は、前記第1及び第2の伝送路それぞれから取得する前記データ間の一部に存在する既知の相違箇所については、当該相違箇所を同一に変更した後で前記チェックコードを生成することを特徴とする。 In the comparison and monitoring system, the check code generation unit changes the difference between the data obtained from each of the first and second transmission paths to the same difference. The check code is generated later.
上記比較監視システムにおいて、前記送信手段は、前記比較情報とともに当該比較情報に対応する前記データを前記比較装置に送信し、前記比較装置は、前記比較手段がアラートを出力する場合に前記第1及び第2の監視プローブ装置から受信した前記データ間の相違部分を表示する表示手段を有することを特徴とする。 In the comparison monitoring system, the transmission means transmits the data corresponding to the comparison information together with the comparison information to the comparison device, and the comparison device outputs the first and the first when the comparison means outputs an alert. It has a display means which displays the difference part between the said data received from the 2nd monitoring probe apparatus, It is characterized by the above-mentioned.
第2の本発明に係る比較監視方法は、第1の伝送路からデータを取得する第1の監視プローブ装置、第2の伝送路からデータを取得する第2の監視プローブ装置、前記第1及び第2の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置による比較監視方法であって、前記第1及び第2の監視プローブ装置それぞれによる、伝送路からデータを取得するステップと、取得した前記データの内容からチェックコードを生成するステップと、前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信するステップと、を有し、前記比較装置による、前記第1及び第2の監視プローブ装置それぞれから受信した前記比較情報を第1及び第2の比較情報バッファそれぞれに蓄積するステップと、前記第1及び第2の比較情報バッファから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力するステップと、を有することを特徴とする。 A comparative monitoring method according to a second aspect of the present invention includes a first monitoring probe device that acquires data from a first transmission line, a second monitoring probe device that acquires data from a second transmission line, A comparison monitoring method by a comparison device for comparing whether or not predetermined data among the data acquired by each of the second monitoring probe devices is the same, and a transmission path by each of the first and second monitoring probe devices The step of acquiring data from the step, the step of generating a check code from the content of the acquired data, and the time stamp of the check code and the data when the value of the check code is different from the value of the check code generated immediately before And transmitting the comparison information including the first and second monitoring probe devices by the comparison device. The step of accumulating the comparison information received from each of the first and second comparison information buffers and the value of the check code included in the comparison information from the first and second comparison information buffers match. Searching for the set of comparison information, and outputting an alert when the time difference between the time stamps included in the set of comparison information exceeds a predetermined time.
本発明によれば、相関性があるデータ列間で、データの出現順番や送信回数が変化する場合でも、一定の相関性を比較監視することができる。 According to the present invention, even when the data appearance order and the number of times of transmission change between correlated data strings, a constant correlation can be compared and monitored.
以下、本発明の実施の形態について図面を用いて説明する。 Hereinafter, embodiments of the present invention will be described with reference to the drawings.
図1は、本実施の形態における比較監視システムの構成を示す機能ブロック図である。同図に示す比較監視システムは、監視プローブ装置20,30及び比較装置40を備え、データストリーム(1)とデータストリーム(2)とを比較し、相違する場合に警告を出力するシステムである。データストリーム(2)は、データストリーム変換部10によりデータストリーム(1)を変換したものである。
FIG. 1 is a functional block diagram showing a configuration of a comparison monitoring system in the present embodiment. The comparison monitoring system shown in the figure includes
データストリーム変換部10は、データストリーム(1)(例えば、地デジ放送データ)を入力し、変換処理してデータストリーム(2)(例えば、地デジIP再送信データ)を出力する。具体的には、データストリーム変換部10は、地デジ放送データの映像データをより符号化効率の高い映像データに変換し、地デジ放送データの音声データ、字幕、データ放送、番組情報等の他のデータを別の形式に変換することなく出力する。データ放送や番組情報など同じ内容のデータが周期的に送られるものに関しては、回数を減らして出力する。例えば、データ放送において同じデータが2回入力された場合に、データストリーム変換部10は、2回目のデータを出力しない。あるいは、1分間に3回送信されるデータを1分間に2回に減らして送信する。なお、本実施の形態における比較監視システムは、データストリーム変換部10が、例えば、音声データや番組情報の符号化方式は変換されずに映像データの符号化方式については変換されるような場合、データの内容が変化しない音声データや番組情報等を比較監視の対象とする。つまり、変換の前後で符号化の形式が異なる映像データは比較監視の対象としない。変換前後の形式が異なる場合として、例えば、元の映像がMPEG2で変換後がH.264の場合、あるいは変換後がMPEG2のままビットレートを下げた場合、あるいは変換後の形式としてMPEG4を用いる場合などがある。本実施の形態では、変換前後の形式が異なる映像データは比較監視の対象としないので、映像データに関していかなる変換が行われてもよい。
The data
図2は、データストリームのイメージを示す模式図である。図2(a)に、変換前のデータストリーム(1)のイメージを示し、図2(b)に、変換後のデータストリーム(2)のイメージを示す。図2中の四角はTransport Stream(TS)パケットを表す。 FIG. 2 is a schematic diagram showing an image of a data stream. FIG. 2A shows an image of the data stream (1) before conversion, and FIG. 2B shows an image of the data stream (2) after conversion. A square in FIG. 2 represents a Transport Stream (TS) packet.
データストリームでは、複数のデータ種別が混在して流れている。データのサイズが大きいものは、パケットに分割されている。図2中のパケット内のA,B,・・・Xなどの英字がデータ種別を示し、英字の横の数字がそのデータ種別のパケットの番号を示している。パケットの右側のボックス内の模様は、データの内容を模式している。データ種別が同じで連続する番号を有し、ボックス内の模様が同じものは、同じ1つのデータから分割されたパケットを示している。例えば、図2(a)のA−5,A−4,A−3のパケットは、1つのデータを分割したパケットである。パケットの下の数字は、各プローブ装置がパケットを受信した時刻を表すタイムスタンプを示している。 In the data stream, a plurality of data types flow together. Data having a large data size is divided into packets. In FIG. 2, the letters such as A, B,... X in the packet indicate the data type, and the number next to the letter indicates the packet number of the data type. The pattern in the box on the right side of the packet represents the contents of the data. A packet having the same data type and having consecutive numbers and having the same pattern in the box indicates a packet divided from the same data. For example, packets A-5, A-4, and A-3 in FIG. 2A are packets obtained by dividing one piece of data. The number below the packet indicates a time stamp indicating the time when each probe device receives the packet.
なお、データストリーム変換部10によるデータストリームの変換前後において、パケットの並び順は保証されていない。つまり、データストリーム間でパケットの並び順は一致しないこともある。例えば、図2(a)ではパケット「X−1」は、パケット「A−3」の次に出現しているが、図2(b)ではパケット「X−1」は、パケット「A−1」の次に出現している。
Note that the order of packets before and after the data stream conversion by the data
また、データストリームの変換前後において相関のあるデータのパケットが出現する時刻に差が存在している。図2に示す例では、データストリーム(1)においてパケット「X−1」に付されたタイムスタンプは「10:12:20.010」であるのに対し、データストリーム(2)においてパケット「X−1」に付されたタイムスタンプは「10:12:20.845」となっている。本実施の形態における比較監視システムは、データが欠落していないか、データストリーム(1),(2)間で対応するデータのタイムスタンプの差が所定の範囲内であるか否かを判定する。 In addition, there is a difference in the time at which correlated data packets appear before and after conversion of the data stream. In the example shown in FIG. 2, the time stamp attached to the packet “X-1” in the data stream (1) is “10: 12: 20.010”, whereas the packet “X” in the data stream (2). The time stamp attached to “−1” is “10: 12: 20.845”. The comparison monitoring system according to the present embodiment determines whether data is missing or whether the difference in time stamps of corresponding data between the data streams (1) and (2) is within a predetermined range. .
図1に戻り、比較監視システムの説明を続ける。監視プローブ装置20は、データストリーム変換部10の入力側の伝送路からデータストリーム(1)を入力して比較情報を生成し、パケットから再構成したデータと比較情報を比較装置40に送信する。監視プローブ装置30は、データストリーム変換部10の出力側の伝送路からデータストリーム(2)を入力して比較情報を生成し、パケットから再構成したデータと比較情報を比較装置40に送信する。比較装置40は、監視プローブ装置20,30から受信した比較情報を比較し、相違を発見したときに警告を出力する。なお、監視プローブ装置20,30は、データ及び比較情報をすべて比較装置40へ送信するのではなく、所定の条件を満たすデータについてのみ、そのデータとそのデータから生成した比較情報を比較装置40に送信する。監視プローブ装置20,30及び比較装置40の詳細については後述する。
Returning to FIG. 1, the description of the comparative monitoring system will be continued. The
監視プローブ装置20,30及び比較装置40が備える各部は、演算処理装置、記憶装置、メモリ等を備えたコンピュータにより構成して、各部の処理がプログラムによって実行されるものとしてもよい。このプログラムは各装置が備える記憶装置に記憶されており、磁気ディスク、光ディスク、半導体メモリ等の記録媒体に記録することも、ネットワークを通して提供することも可能である。なお、本実施の形態では、監視プローブ装置20,30及び比較装置40を別々の装置として構成したが、もちろん各部を1つの装置で構成するものでもよい。以下、各装置の詳細について説明する。
Each unit included in the
監視プローブ装置20と監視プローブ装置30は、取得するデータストリームが異なる以外は同じであるので、ここでは監視プローブ装置20について説明する。監視プローブ装置20は、パケット解析部21と複数の比較情報生成部22A,22B,・・・,22Xを有する。
Since the
パケット解析部21は、複数のデータ種別のパケットが混在して伝送されるデータストリームを入力し、入力したパケットをデータ種別毎に分類する。データ種別は、例えば、音声、字幕、データ放送、番組情報などである。データ種別毎に分類されたパケットは、データ種別毎に用意された比較情報生成部22A,22B,・・・,22Xへ送信される。
The
比較情報生成部22A,22B,・・・,22Xは、パケット解析部21からパケットを受信してデータを再構成し、比較情報を生成して比較装置40へ送信する。比較情報生成部22A,22B,・・・,22Xそれぞれは、受信するデータ種別が異なる以外は同じである。監視プローブ装置30は、監視プローブ装置20と同様に、データ種別毎の比較情報生成部32A,32B,・・・,32Xを有する。つまり、監視プローブ装置20,30は、それぞれ同数の比較情報生成部を有する。
The comparison
比較情報生成部22A,22B,・・・,22Xのそれぞれは、パケットを結合してデータを再構築する結合部221A,221B,・・・,221X、再構築したデータの内容からチェックコードを生成するチェックコード生成部222A,222B,・・・,222X、および再構築したデータと比較情報を比較装置40へ送信するか否か判定する変化検出部223A,223B,・・・,223Xを有する。比較情報は、チェックコード生成部222A,222B,・・・,222Xが生成したチェックコードと再構築したデータのタイムスタンプを含む情報である。チェックコードは、例えばCyclic Redundancy Check(CRC:巡回冗長検査)を用いてデータから生成した数バイト程度の値である。
Each of the comparison
図3は、比較情報生成部の処理を説明する模式図である。図3(a)〜(c)は、監視プローブ装置20が有する比較情報生成部22A,22B,22Xの処理の様子を示し、図3(d)〜(f)は、監視プローブ装置30が有する比較情報生成部32A,32B,32Xの処理の様子を示す。同図では、パケットを受信した順に下から上に並べている。いずれも同様の処理を行うので、ここでは比較情報生成部22Aの処理を示す図3(a)に着目して説明する。
FIG. 3 is a schematic diagram illustrating the processing of the comparison information generation unit. 3A to 3C show the processing of the comparison
監視プローブ装置20において、データ種別が「A」のパケットは、比較情報生成部22Aに送信される。図3(a)では、A−5,A−4,A−3,・・・,A6のデータ種別「A」のパケットを受信している。結合部221Aは、同じ1つのデータを分割したパケットを結合してデータを再構築する。図3(a)では、例えばA−5,A−4,A−3のパケットを結合してデータを再構築している。このとき再構築したデータのタイムスタンプを、一番最後のパケットであるA−3に付されたタイムスタンプ「10:12:19.099」とする。なお、図3(b),(e)の最上段の点線は、データを再構築するためのパケットがまだ揃っていないことを示している。また、図3(c),(f)のように、データが分割されておらず1つのパケットが1つのデータに対応しているものもある。
In the
チェックコード生成部222Aは、再構築したデータのCRCを計算してチェックコードを生成する。例えば、図3(a)において、A−5,A−4,A−3から再構築したデータのチェックコードは、0x995Cであり、A−2,A−1,A0から再構築したデータのチェックコードは、0xD238である。
The check
なお、データストリーム変換部10が特定のデータ種別の所定の箇所のビットを書き換えるものである場合、チェックコード生成部222Aは、書き換えられる箇所をビットマスクしてチェックコードを生成する。例えば、データストリーム変換部10がデータ種別「B」のデータの先頭から10〜15ビット目を書き換えて出力するものである場合、チェックコード生成部222B,322Bは、データの10〜15ビット目を固定値で上書きしてチェックコードを生成する。これにより、書き換えられた箇所以外が同じならば同じ値のチェックコードが生成される。あるいは、データストリーム変換部10が所定の規則に従ってデータの一部を変更する場合、変更前のデータを扱うチェックコード生成部222Bは、変更されるデータの一部が変更後と同一となるように、そのデータの一部を変更した後でチェックコードを生成する。
When the data
変化検出部223Aは、チェックコード生成部222Aが生成したチェックコードが変化する変化点を検出し、変化点を検出した場合、再構築したデータと比較情報を比較装置40へ送信する。図3(a)では、下から2番目と3番目のチェックコードは共に0xD238で変化せず、下から2番目、4番目においてチェックコードが変化している(図3では「変化点」として示している)。したがって、下から2番目、4番目においてデータと比較情報を比較装置40へ送信する。比較装置40へ送信する比較情報はチェックコードとタイムスタンプを含む。例えば、図3(a)の下から2番目のデータの比較情報は、チェックコード「0xD238」とタイムスタンプ「10:12:20.124」を含む。なお、生成したチェックコードの値を直前に生成したチェックコードの値と比較するため、生成したチェックコードは変化検出部223Aの有する記憶手段に一時的に蓄積される。
The
続いて比較装置40について説明する。比較装置40は、監視プローブ装置20,30それぞれから受信した対応する比較情報同士を比較し、比較した比較情報が相違していればアラートを出力する。比較装置40は、監視プローブ装置20,30それぞれが送信するデータと比較情報を受信して蓄積する比較情報受信部42,43、データ種別毎に比較情報を比較する比較部44A,44B,・・・,44Xを有する。
Next, the
比較情報受信部42は、データ種別毎に比較情報バッファ421A,421B,・・・,421X、および蓄積部422A,422B,・・・,422Xを有する。比較情報バッファ421A,421B,・・・,421Xは、監視プローブ装置20が送信した比較情報をデータ種別毎に一時的に蓄積する。蓄積部422A,422B,・・・,422Xは、監視プローブ装置20が送信したデータをデータ種別毎に蓄積する。例えば、比較情報バッファ421Aには、監視プローブ装置20の比較情報生成部22Aが送信した比較情報、つまり、データストリーム(1)のデータ種別「A」のデータに関する比較情報が一時的に蓄積される。蓄積部422Aには、データストリーム(1)のデータ種別「A」のデータが蓄積される。なお、比較情報受信部43も同様に、データ種別毎に比較情報バッファ431A,431B,・・・,431X、および蓄積部432A,432B,・・・,432Xを有し、監視プローブ装置30が送信した比較情報とデータを蓄積する。
The comparison
比較部44A,44B,・・・,44Xはデータ種別毎に用意され、比較情報受信部42,43それぞれから対応するデータ種別の比較情報を読み出して比較し、比較情報が相違している場合にアラートを出力する。比較部44A,44B,・・・,44Xは、比較情報バッファ421A,421B,・・・,421Xと比較情報バッファ431A,431B,・・・,431Xそれぞれから対応する比較情報を取得し、その比較情報の組のタイムスタンプの時間差が所定の時間以内であるか否かを判定する。そして、対応する比較情報が取得できない場合、あるいは、タイムスタンプの時間差が所定の時間を超えている場合にアラートを出力する。また、対応する比較情報が取得できない場合もアラートを出力する。
The
比較部44Aを例にとり、アラートを出力する処理をより具体的に説明する。
Taking the
まず、比較部44Aは、比較情報バッファ421A,431Aそれぞれから比較情報を古い順に取り出し、比較情報のチェックコードを比較する。
First, the
同一のチェックコードを有する比較情報が見つからない場合、その比較情報を受信した時刻から所定の時間以上経過したか否か判定し、所定の時間以上経過していた場合は、タイムアウトのアラートを出力する。なお、比較情報に含まれるタイムスタンプを比較情報を受信した時刻として用いてもよい。 When comparison information having the same check code is not found, it is determined whether or not a predetermined time has elapsed since the time when the comparison information was received. If the predetermined time has elapsed, a time-out alert is output. . Note that the time stamp included in the comparison information may be used as the time when the comparison information is received.
同一のチェックコードを有する比較情報が比較情報バッファ421A,431Aそれぞれから見つかった場合、比較情報それぞれのタイムスタンプの差が所定の時間以内であるか否か判定し、タイムスタンプの差が所定の時間を超えていた場合は、時間差エラーのアラートを出力する。 When comparison information having the same check code is found from each of the comparison information buffers 421A and 431A, it is determined whether or not the time stamp difference of each comparison information is within a predetermined time, and the time stamp difference is a predetermined time. If it exceeds, a time difference error alert is output.
チェックコードが同一で、タイムスタンプの差が所定の時間以内の比較情報はマッチング成立と判断し、比較情報バッファ421A,431Aそれぞれからその比較情報を取り除く。そして、マッチングが成立した比較情報より前に受信した比較情報が比較情報バッファ421A,431Aに残っている場合、その比較情報に対応する比較情報は欠落したものと判断し、欠落エラーを出力する。 Comparison information having the same check code and a time stamp difference within a predetermined time is determined to be matched, and the comparison information is removed from each of the comparison information buffers 421A and 431A. If the comparison information received before the comparison information for which matching is established remains in the comparison information buffers 421A and 431A, it is determined that the comparison information corresponding to the comparison information is missing, and a missing error is output.
マッチングが成立した比較情報より後に受信した比較情報が比較情報バッファ421A,431Aに存在する場合は、上記の処理を繰り返す。 When the comparison information received after the comparison information for which matching is established is present in the comparison information buffers 421A and 431A, the above processing is repeated.
図4は、比較装置40の処理を説明する模式図である。図4(a)は図3(a),(d)、図4(b)は図3(b),(e)、図4(c)は図3(c),(f)の比較情報を比較する様子を示す。図4(a)〜(c)では、左側にデータストリーム(1)側(比較情報受信部42)の比較情報バッファ、右側にデータストリーム(2)側(比較情報受信部43)の比較情報バッファの内容を示している。
FIG. 4 is a schematic diagram for explaining the processing of the
図4(a)では、チェックコードが同一の対応する比較情報が取得でき、各比較情報のタイムスタンプの時間差も1000ミリ秒以内である。この場合、正常と判断してアラートは出力されない。 In FIG. 4A, corresponding comparison information with the same check code can be acquired, and the time difference between the time stamps of each comparison information is also within 1000 milliseconds. In this case, it is determined that the alert is normal and no alert is output.
図4(b)では、チェックコードが同一の対応する比較情報が取得できているが、下から3番目の比較情報[n+2]のタイムスタンプの時間差が1000ミリ秒を超えているので、時間差エラーのアラートが出力される。 In FIG. 4B, the corresponding comparison information having the same check code can be acquired, but the time difference of the time stamp of the third comparison information [n + 2] from the bottom exceeds 1000 milliseconds, so a time difference error Alert is output.
図4(c)では、データストリーム(1)側の下から2番目の比較情報[n+1]に対応するデータストリーム(2)側の比較情報が取得できないので、欠落エラーのアラートが出力される。図4(c)に示す例では、データストリーム(1)の下から3番目の比較情報[n+2]に対応するデータストリーム(2)側の比較情報が取得できたときに、データストリーム(2)側の、データストリーム(1)側の比較情報[n+1]に対応する比較情報が欠落したと判断する。 In FIG. 4C, since the comparison information on the data stream (2) side corresponding to the second comparison information [n + 1] from the bottom on the data stream (1) side cannot be acquired, a missing error alert is output. In the example shown in FIG. 4C, when the comparison information on the data stream (2) side corresponding to the third comparison information [n + 2] from the bottom of the data stream (1) can be acquired, the data stream (2) It is determined that the comparison information corresponding to the comparison information [n + 1] on the data stream (1) side is missing.
また、図示していないが、どちらかのデータストリームの比較情報が比較情報バッファに蓄積されてから、所定の時間以上経過しても、対応する比較情報が別のデータストリーム側から取得できない場合、タイムアウトのアラートが出力される。 Although not shown, when the comparison information of either data stream is accumulated in the comparison information buffer and the corresponding comparison information cannot be acquired from another data stream side even after a predetermined time has elapsed, A timeout alert is output.
図5は、比較装置40がデータの相違部分を表示するための変化データ取り出し部45を示す図である。変化データ取り出し部45は、比較部44A,44B,・・・,44Xが相違していると判定した比較情報に対応するデータを各蓄積部422A,432Aから読み出し、読み出したデータ間の相違部分を表示する。蓄積部422A,422B,・・・,422Xがデータにタイムスタンプを関連付けて蓄積することで、比較情報に対応するデータを容易に検索することができる。図6に相違部分を表示した例を示す。
FIG. 5 is a diagram illustrating a change
次に、比較監視システムの処理の流れについて説明する。 Next, the processing flow of the comparison monitoring system will be described.
まず、監視プローブ装置20,30それぞれが変換前後のデータストリームを取得する。監視プローブ装置20が変換前のデータストリーム(1)を取得し、監視プローブ装置30が変換後のデータストリーム(2)を取得する。
First, each of the
続いて、監視プローブ装置20のパケット解析部21がパケットをデータ種別毎に分類し、対応する比較情報生成部22A,22B,・・・,22Xに送信する。監視プローブ装置30のパケット解析部31も同様の処理を行う。以下、監視プローブ装置30において行われる同様の処理については説明を省略する。
Subsequently, the
続いて、結合部221A,221B,・・・,221Xがパケットを結合してデータを再構成し、チェックコード生成部222A,222B,・・・,222Xがデータのチェックコードを生成する。
Subsequently, the combining
そして、変化検出部223A,223B,・・・,223Xがチェックコードが変化したか否かを調べることにより、比較対象のデータであるか否か判定する。比較対象のデータでない場合は、そのデータについての処理を終了する。本実施の形態では、繰り返して送信されるデータの送信回数の違いを無視して相関性を比較監視するために、データ種別毎にチェックコードが変化した場合、つまりデータが変化した場合を比較対象のデータとする。例えば、データストリーム(1)では1分間に3回送信されたデータがデータストリーム(2)では1分間に2回しか送信されない場合でも、どちらも比較対象となるデータは最初の1つである。
Then, the
比較対象のデータの場合、比較情報生成部22A,22B,・・・,22Xは、再構成したデータおよびチェックコードとタイムスタンプを含む比較情報を比較装置40へ送信し、比較装置40は、受信した比較情報を比較情報バッファ421A,・・・,421Xに、受信したデータを蓄積部422A,422B,・・・,422Xに蓄積する。
In the case of data to be compared, the comparison
そして、比較部44A,44B,・・・,44Xは、比較情報バッファ421A,・・・,421X、比較情報バッファ431A,・・・,431Xそれぞれから比較情報を読み出して比較し、比較情報に相違を検出した場合は、アラートを出力するとともに、本実施の形態では、相違を検出した比較情報に対応するデータを比較情報受信部42,43それぞれから読み出して相違部分を比較表示する。
The
また、本実施の形態における比較監視システムは、監視プローブ装置20,30が入力したパケットのタイムスタンプを比較して、一方のデータストリームが停止しているか否か判定する。具体的には、監視プローブ装置20,30は、データ種別毎に、最後に入力したパケットのタイムスタンプを最終タイムスタンプとして取得して比較装置40に送信する。最終タイムスタンプはパケットを取得すると更新される。比較装置40は、監視プローブ装置20,30それぞれから受信した最終タイムスタンプを比較し、その差が所定の時間を超えていた場合にアラームを出力する。なお、データストリームの帯域を比較してデータストリームの停止を判定してもよい。
Further, the comparison and monitoring system in the present embodiment compares the time stamps of the packets input by the
以上説明したように、本実施の形態によれば、監視プローブ装置20,30それぞれが取得したデータの内容からチェックコードを算出し、チェックコードの値が直前に生成したチェックコードと異なる場合に、そのチェックコードとデータのタイムスタンプを含む比較情報を比較装置40へ送信し、比較装置40は監視プローブ装置20,30それぞれから受信した比較情報を比較し、比較情報に相違が検出された場合にアラートを出力することにより、同じチェックコードが連続した場合、つまり同じデータを連続して受信した場合には、比較処理を行わないので、データの送信回数の違いを無視してデータストリーム間の相関性を比較監視することができる。
As described above, according to the present embodiment, when the check code is calculated from the contents of the data acquired by each of the
本実施の形態によれば、比較装置40がデータを直接比較せず、データの内容から算出したチェックコードを比較するので、データ量にばらつきがある場合でも、比較装置40の比較処理の処理量のバラツキを抑制することができる。
According to the present embodiment, the
本実施の形態によれば、パケット解析部21が入力したパケットをデータ種別毎に分類し、データ種別毎に比較情報生成部22A,22B,・・・,22Xを有することにより、データストリーム間で出現するデータの順番が異なる場合でも、データの相関性を比較監視することができる。
According to the present embodiment, the packets input by the
なお、本実施の形態では、データストリーム変換部10が入力したデータの送信回数を減らす処理を行う場合について説明したが、データストリーム変換部10が入力したデータの送信回数を増やす場合でも、データストリーム間の相関性を比較監視することができる。
In the present embodiment, the case where the process of reducing the number of transmissions of data input by the data
本実施の形態では、変化検出部がチェックコードの変化点を検出することで比較対象のデータを検出したが、変化検出部の判定条件は、データストリーム変換部10の仕様に合わせて変更できる。例えば、データストリーム変換部10が音声データの無音部分を削除する処理を行う場合、変化検出部が無音部分を検出し、無音部分以外のデータを比較対象のデータとして、そのデータの内容から生成したチェックコードを比較装置40に送信することで比較監視することが可能である。
In the present embodiment, the change detection unit detects the data to be compared by detecting the change point of the check code. However, the determination condition of the change detection unit can be changed according to the specification of the data
10…データストリーム変換部
20,30…監視プローブ装置
21,31…パケット解析部
22A,22B,22X,32A,32B,32X…比較情報生成部
221A,221B,…結合部
222A,222B,222X,322A,322B,322X…チェックコード生成部
223A,223B,223X,323A,323B,323X…変化検出部
40…比較装置
42,43…比較情報受信部
421A,421B,421X,431A,431B,431X…比較情報バッファ
422A,422B,422X,432A,432B,432X…蓄積部
44A,44B,44X…比較部
45…変化データ取りだし部
DESCRIPTION OF
Claims (7)
前記第1及び第2の監視プローブ装置それぞれは、
伝送路からデータを取得する取得手段と、
取得した前記データの内容からチェックコードを生成するチェックコード生成手段と、
前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信する送信手段と、を有し、
前記比較装置は、
前記第1及び第2の監視プローブ装置それぞれから受信した前記比較情報をそれぞれ蓄積する第1及び第2の比較情報バッファと、
前記第1及び第2の比較情報バッファそれぞれから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力する比較手段と、を有すること
を特徴とする比較監視システム。 A first monitoring probe device that acquires data from the first transmission path, a second monitoring probe device that acquires data from the second transmission path, and the data acquired by each of the first and second monitoring probe devices A comparison monitoring system comprising a comparison device for comparing whether or not predetermined data is the same,
Each of the first and second monitoring probe devices includes:
Obtaining means for obtaining data from the transmission line;
Check code generation means for generating a check code from the content of the acquired data;
Transmission means for transmitting comparison information including the check code and the time stamp of the data to the comparison device when the value of the check code is different from the value of the check code generated immediately before,
The comparison device includes:
First and second comparison information buffers for storing the comparison information received from the first and second monitoring probe devices, respectively.
The set of comparison information in which the value of the check code included in the comparison information matches is searched from each of the first and second comparison information buffers, and a time difference of time stamps included in the set of comparison information is a predetermined time A comparison means for outputting an alert when the time is exceeded.
前記第1及び第2の監視プローブ装置それぞれは、
取得した前記データを種別毎に分類する分類手段と、
種別毎に前記チェックコード生成手段及び前記送信手段を有し、
前記比較装置は、
種別毎に前記比較手段を有すること
を特徴とする請求項1又は2記載の比較監視システム。 A plurality of types of data are transmitted to the first and second transmission lines,
Each of the first and second monitoring probe devices includes:
Classification means for classifying the acquired data for each type;
The check code generation means and the transmission means for each type,
The comparison device includes:
The comparison monitoring system according to claim 1, wherein the comparison unit is provided for each type.
一番最後に取得した前記データのタイムスタンプを最終タイムスタンプとして取得し、前記比較装置に送信する最終タイムスタンプ取得手段を有し、
前記比較装置は、
前記第1及び第2の監視プローブ装置それぞれから受信した前記最終タイムスタンプの時間差が所定の時間を超える場合にアラートを出力する最終タイムスタンプ比較手段を有すること
を特徴とする請求項1乃至3のいずれかに記載の比較監視システム。 The first and second monitoring probe devices include:
A last time stamp obtaining means for obtaining the last time stamp of the data obtained as the last time stamp and transmitting to the comparison device;
The comparison device includes:
The last time stamp comparison means for outputting an alert when the time difference between the last time stamps received from each of the first and second monitoring probe devices exceeds a predetermined time. The comparative monitoring system according to any one of the above.
前記比較装置は、
前記比較手段がアラートを出力する場合に前記第1及び第2の監視プローブ装置から受信した前記データ間の相違部分を表示する表示手段を有すること
を特徴とする請求項1乃至5のいずれかに記載の比較監視システム。 The transmission means transmits the data corresponding to the comparison information together with the comparison information to the comparison device,
The comparison device includes:
6. The display device according to claim 1, further comprising a display unit that displays a difference between the data received from the first and second monitoring probe devices when the comparison unit outputs an alert. The comparative monitoring system described.
前記第1及び第2の監視プローブ装置それぞれによる、
伝送路からデータを取得するステップと、
取得した前記データの内容からチェックコードを生成するステップと、
前記チェックコードの値が直前に生成したチェックコードの値と異なる場合に当該チェックコードと前記データのタイムスタンプを含む比較情報を前記比較装置に送信するステップと、を有し、
前記比較装置による、
前記第1及び第2の監視プローブ装置それぞれから受信した前記比較情報を第1及び第2の比較情報バッファそれぞれに蓄積するステップと、
前記第1及び第2の比較情報バッファから前記比較情報に含まれる前記チェックコードの値が一致する前記比較情報の組を検索し、当該比較情報の組に含まれるタイムスタンプの時間差が所定の時間を超える場合にアラートを出力するステップと、を有すること
を特徴とする比較監視方法。 A first monitoring probe device that acquires data from the first transmission path, a second monitoring probe device that acquires data from the second transmission path, and the data acquired by each of the first and second monitoring probe devices A comparison monitoring method using a comparison device for comparing whether or not predetermined data is the same,
According to each of the first and second monitoring probe devices,
Acquiring data from a transmission line;
Generating a check code from the content of the acquired data;
When the value of the check code is different from the value of the check code generated immediately before, sending the comparison information including the check code and the time stamp of the data to the comparison device,
According to the comparison device,
Storing the comparison information received from each of the first and second monitoring probe devices in first and second comparison information buffers, respectively.
The set of comparison information in which the check code values included in the comparison information match is searched from the first and second comparison information buffers, and the time difference between the time stamps included in the set of comparison information is a predetermined time. And a step of outputting an alert when the threshold is exceeded.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2010115587A JP4901977B2 (en) | 2010-05-19 | 2010-05-19 | Comparative monitoring system and comparative monitoring method |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2010115587A JP4901977B2 (en) | 2010-05-19 | 2010-05-19 | Comparative monitoring system and comparative monitoring method |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2011244277A JP2011244277A (en) | 2011-12-01 |
| JP4901977B2 true JP4901977B2 (en) | 2012-03-21 |
Family
ID=45410458
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2010115587A Active JP4901977B2 (en) | 2010-05-19 | 2010-05-19 | Comparative monitoring system and comparative monitoring method |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP4901977B2 (en) |
Families Citing this family (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN112053735B (en) * | 2019-06-05 | 2023-03-28 | 建兴储存科技(广州)有限公司 | Repeated data processing method of solid-state storage device |
| JP7356663B2 (en) * | 2021-03-17 | 2023-10-05 | 株式会社インフォシティ | Broadcasting service communication network distribution apparatus and method |
Family Cites Families (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JPH11122203A (en) * | 1997-10-09 | 1999-04-30 | Video Research:Kk | Broadcast confirmation system, and video material production device and broadcast confirmation device used in this system |
| JP2001160978A (en) * | 1999-12-02 | 2001-06-12 | Mitsubishi Electric Corp | Broadcast data monitoring method, broadcast data monitoring device, and data broadcasting device |
| JP2002057646A (en) * | 2000-08-10 | 2002-02-22 | Insaito:Kk | Broadcast distribution checker and broadcast distribution checking system using the same |
| JP2002290358A (en) * | 2001-03-27 | 2002-10-04 | Mitsubishi Electric Corp | State monitoring method and system |
| JP4433772B2 (en) * | 2003-11-14 | 2010-03-17 | 日本テレビ放送網株式会社 | Data broadcasting transmission confirmation system and control program |
| JP2009284184A (en) * | 2008-05-22 | 2009-12-03 | Nec Corp | Television broadcasting retransmission monitoring system, monitoring method and monitoring control program |
-
2010
- 2010-05-19 JP JP2010115587A patent/JP4901977B2/en active Active
Also Published As
| Publication number | Publication date |
|---|---|
| JP2011244277A (en) | 2011-12-01 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| USRE50577E1 (en) | Watermark based content recognition improvements | |
| JP4434242B2 (en) | Transmission device, reception device, error correction system, transmission method, and error correction method | |
| US20100083060A1 (en) | System and method for mpeg crc error based video network fault detection | |
| CN101841733A (en) | Information acquisition system, data acquisition device and data acquisition method | |
| CN103703786A (en) | Highly scalable audience measurement system with client event pre-processing | |
| US7134064B2 (en) | Error detecting method and apparatus | |
| US9667384B2 (en) | Apparatus and method for transmitting and receiving forward error correction packet | |
| CA2757817A1 (en) | A system for and method of targeting broadcast messages | |
| US20190098248A1 (en) | Captured image display device, captured image display method, and captured image display program | |
| JP4901977B2 (en) | Comparative monitoring system and comparative monitoring method | |
| KR20160141771A (en) | Orthogonal data organization for error detection and correction in serial video interfaces | |
| US20090310865A1 (en) | Video Surveillance System, Annotation And De-Annotation Modules Thereof | |
| US20090245346A1 (en) | Method and apparatus for generating and processing packet | |
| KR20190081048A (en) | Method And Apparatus for Repairing and Detecting Packet Loss | |
| JP4696008B2 (en) | IP transmission apparatus and IP transmission method | |
| JP2014093584A (en) | Transmission device, transmission method, receiving device, reception method and computer program | |
| JP2015082842A (en) | Closed caption inspection system and method | |
| KR20160020420A (en) | System and method for remote maintenance of user units | |
| JP2009188674A (en) | Transmitting apparatus, receiving apparatus, video / audio transmission quality evaluation method, and video / audio transmission quality evaluation program | |
| CN114051164B (en) | Decoding abnormal code stream generation method and device, electronic equipment and readable storage medium | |
| KR101879194B1 (en) | Method and Apparatus for Recovering Packet Loss | |
| JP2005151176A (en) | Image transmission method and apparatus | |
| KR20170083844A (en) | Set-Top Box for Measuring Frame Loss in a Video Stream and Method for Operating Same | |
| JP2010074513A (en) | Monitoring device | |
| US10313708B1 (en) | Distributed upload of television content |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| TRDD | Decision of grant or rejection written | ||
| A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 Effective date: 20111129 |
|
| A01 | Written decision to grant a patent or to grant a registration (utility model) |
Free format text: JAPANESE INTERMEDIATE CODE: A01 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20111227 |
|
| R150 | Certificate of patent or registration of utility model |
Ref document number: 4901977 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R150 Free format text: JAPANESE INTERMEDIATE CODE: R150 |
|
| FPAY | Renewal fee payment (event date is renewal date of database) |
Free format text: PAYMENT UNTIL: 20150113 Year of fee payment: 3 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| S531 | Written request for registration of change of domicile |
Free format text: JAPANESE INTERMEDIATE CODE: R313531 |
|
| R350 | Written notification of registration of transfer |
Free format text: JAPANESE INTERMEDIATE CODE: R350 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| S111 | Request for change of ownership or part of ownership |
Free format text: JAPANESE INTERMEDIATE CODE: R313115 |
|
| R350 | Written notification of registration of transfer |
Free format text: JAPANESE INTERMEDIATE CODE: R350 |
|
| RD02 | Notification of acceptance of power of attorney |
Free format text: JAPANESE INTERMEDIATE CODE: R3D02 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |
|
| S533 | Written request for registration of change of name |
Free format text: JAPANESE INTERMEDIATE CODE: R313533 |
|
| R350 | Written notification of registration of transfer |
Free format text: JAPANESE INTERMEDIATE CODE: R350 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |