Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
JP4901977B2 - Comparative monitoring system and comparative monitoring method - Google Patents
[go: Go Back, main page]

JP4901977B2 - Comparative monitoring system and comparative monitoring method - Google Patents

Comparative monitoring system and comparative monitoring method Download PDF

Info

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
Application number
JP2010115587A
Other languages
Japanese (ja)
Other versions
JP2011244277A (en
Inventor
宏基 入江
克彰 嶋寺
峰延 大橋
友宏 日比野
祥資 澤田
俊哉 堀田
功史 福間
祥明 吉田
將人 佐々木
珠紅 中澤
宏信 柴田
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
TRAFFIC SIM CO., LTD.
NTT Docomo Business Inc
Original Assignee
TRAFFIC SIM CO., LTD.
NTT Docomo Business Inc
NTT Communications Corp
Priority date (The priority date 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 date listed.)
Filing date
Publication date
Application filed by TRAFFIC SIM CO., LTD., NTT Docomo Business Inc, NTT Communications Corp filed Critical TRAFFIC SIM CO., LTD.
Priority to JP2010115587A priority Critical patent/JP4901977B2/en
Publication of JP2011244277A publication Critical patent/JP2011244277A/en
Application granted granted Critical
Publication of JP4901977B2 publication Critical patent/JP4901977B2/en
Active legal-status Critical Current
Anticipated expiration legal-status Critical

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, Patent Document 1 discloses a technique for monitoring a television broadcast that is retransmitted by IP.

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.

特開2009−284184号公報JP 2009-284184 A

したがって、地上デジタル放送、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.

本実施の形態における比較監視システムの構成を示す機能ブロック図である。It is a functional block diagram which shows the structure of the comparison monitoring system in this Embodiment. データストリームのイメージを示す模式図である。It is a schematic diagram which shows the image of a data stream. 上記比較監視システムの比較情報生成部の処理を説明する模式図である。It is a schematic diagram explaining the process of the comparison information generation part of the said comparison monitoring system. 上記比較監視システムの比較装置の処理を説明する模式図である。It is a schematic diagram explaining the process of the comparison apparatus of the said comparison monitoring system. 比較装置が有する変化データ取り出し部の構成を示す機能ブロック図である。It is a functional block diagram which shows the structure of the change data extraction part which a comparison apparatus has. 上記変化データ取り出し部の表示例を示す図である。It is a figure which shows the example of a display of the said change data extraction part.

以下、本発明の実施の形態について図面を用いて説明する。   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 monitoring probe devices 20 and 30 and a comparison device 40, compares the data stream (1) and the data stream (2), and outputs a warning if they are different. The data stream (2) is obtained by converting the data stream (1) by the data stream conversion unit 10.

データストリーム変換部10は、データストリーム(1)(例えば、地デジ放送データ)を入力し、変換処理してデータストリーム(2)(例えば、地デジIP再送信データ)を出力する。具体的には、データストリーム変換部10は、地デジ放送データの映像データをより符号化効率の高い映像データに変換し、地デジ放送データの音声データ、字幕、データ放送、番組情報等の他のデータを別の形式に変換することなく出力する。データ放送や番組情報など同じ内容のデータが周期的に送られるものに関しては、回数を減らして出力する。例えば、データ放送において同じデータが2回入力された場合に、データストリーム変換部10は、2回目のデータを出力しない。あるいは、1分間に3回送信されるデータを1分間に2回に減らして送信する。なお、本実施の形態における比較監視システムは、データストリーム変換部10が、例えば、音声データや番組情報の符号化方式は変換されずに映像データの符号化方式については変換されるような場合、データの内容が変化しない音声データや番組情報等を比較監視の対象とする。つまり、変換の前後で符号化の形式が異なる映像データは比較監視の対象としない。変換前後の形式が異なる場合として、例えば、元の映像がMPEG2で変換後がH.264の場合、あるいは変換後がMPEG2のままビットレートを下げた場合、あるいは変換後の形式としてMPEG4を用いる場合などがある。本実施の形態では、変換前後の形式が異なる映像データは比較監視の対象としないので、映像データに関していかなる変換が行われてもよい。   The data stream conversion unit 10 receives the data stream (1) (for example, terrestrial digital broadcasting data), performs conversion processing, and outputs the data stream (2) (for example, terrestrial digital IP retransmission data). Specifically, the data stream conversion unit 10 converts the video data of the terrestrial digital broadcasting data into video data with higher encoding efficiency, and other than the audio data of the terrestrial digital broadcasting data, subtitles, data broadcasting, program information, etc. Output without converting to other formats. If data with the same contents such as data broadcasting and program information are sent periodically, the number of times is reduced and output. For example, when the same data is input twice in the data broadcast, the data stream conversion unit 10 does not output the second data. Alternatively, the data transmitted three times per minute is reduced to two times per minute for transmission. In the comparison monitoring system according to the present embodiment, the data stream conversion unit 10 converts, for example, the encoding method of video data without converting the encoding method of audio data or program information. Audio data, program information, etc. whose data contents do not change are subject to comparative monitoring. That is, video data having different encoding formats before and after conversion are not subject to comparison and monitoring. As a case where the format before and after conversion is different, for example, the original video is MPEG2 and the converted video is H.264. In the case of H.264, the bit rate is lowered with MPEG2 being converted, or MPEG4 is used as the format after conversion. In this embodiment, video data having different formats before and after conversion is not subject to comparison and monitoring, and any conversion may be performed on the video 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 stream conversion unit 10 is not guaranteed. That is, the order of the packets may not match between the data streams. For example, in FIG. 2A, the packet “X-1” appears next to the packet “A-3”, but in FIG. 2B, the packet “X-1” is the packet “A-1”. "Is appearing next.

また、データストリームの変換前後において相関のあるデータのパケットが出現する時刻に差が存在している。図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 monitoring probe device 20 inputs the data stream (1) from the transmission path on the input side of the data stream conversion unit 10 to generate comparison information, and transmits the data reconstructed from the packet and the comparison information to the comparison device 40. The monitoring probe device 30 receives the data stream (2) from the transmission line on the output side of the data stream conversion unit 10, generates comparison information, and transmits the data reconstructed from the packet and the comparison information to the comparison device 40. The comparison device 40 compares the comparison information received from the monitoring probe devices 20 and 30, and outputs a warning when a difference is found. Note that the monitoring probe devices 20 and 30 do not transmit all data and comparison information to the comparison device 40, but only the data that satisfies a predetermined condition, the comparison information generated from the data and the comparison information to the comparison device 40. Send. Details of the monitoring probe devices 20 and 30 and the comparison device 40 will be described later.

監視プローブ装置20,30及び比較装置40が備える各部は、演算処理装置、記憶装置、メモリ等を備えたコンピュータにより構成して、各部の処理がプログラムによって実行されるものとしてもよい。このプログラムは各装置が備える記憶装置に記憶されており、磁気ディスク、光ディスク、半導体メモリ等の記録媒体に記録することも、ネットワークを通して提供することも可能である。なお、本実施の形態では、監視プローブ装置20,30及び比較装置40を別々の装置として構成したが、もちろん各部を1つの装置で構成するものでもよい。以下、各装置の詳細について説明する。   Each unit included in the monitoring probe devices 20 and 30 and the comparison device 40 may be configured by a computer including an arithmetic processing device, a storage device, a memory, and the like, and the processing of each unit may be executed by a program. This program is stored in a storage device included in each device, and can be recorded on a recording medium such as a magnetic disk, an optical disk, or a semiconductor memory, or provided through a network. In the present embodiment, the monitoring probe devices 20 and 30 and the comparison device 40 are configured as separate devices, but each unit may of course be configured as a single device. Details of each device will be described below.

監視プローブ装置20と監視プローブ装置30は、取得するデータストリームが異なる以外は同じであるので、ここでは監視プローブ装置20について説明する。監視プローブ装置20は、パケット解析部21と複数の比較情報生成部22A,22B,・・・,22Xを有する。   Since the monitoring probe device 20 and the monitoring probe device 30 are the same except that the data streams to be acquired are different, the monitoring probe device 20 will be described here. The monitoring probe device 20 includes a packet analysis unit 21 and a plurality of comparison information generation units 22A, 22B,.

パケット解析部21は、複数のデータ種別のパケットが混在して伝送されるデータストリームを入力し、入力したパケットをデータ種別毎に分類する。データ種別は、例えば、音声、字幕、データ放送、番組情報などである。データ種別毎に分類されたパケットは、データ種別毎に用意された比較情報生成部22A,22B,・・・,22Xへ送信される。   The packet analysis unit 21 inputs a data stream transmitted by mixing a plurality of data type packets, and classifies the input packets for each data type. The data type is, for example, audio, caption, data broadcast, program information, or the like. Packets classified for each data type are transmitted to comparison information generation units 22A, 22B,..., 22X prepared for each data type.

比較情報生成部22A,22B,・・・,22Xは、パケット解析部21からパケットを受信してデータを再構成し、比較情報を生成して比較装置40へ送信する。比較情報生成部22A,22B,・・・,22Xそれぞれは、受信するデータ種別が異なる以外は同じである。監視プローブ装置30は、監視プローブ装置20と同様に、データ種別毎の比較情報生成部32A,32B,・・・,32Xを有する。つまり、監視プローブ装置20,30は、それぞれ同数の比較情報生成部を有する。   The comparison information generation units 22A, 22B,..., 22X receive packets from the packet analysis unit 21, reconstruct data, generate comparison information, and transmit the comparison information to the comparison device 40. Each of the comparison information generation units 22A, 22B,..., 22X is the same except that the received data type is different. Similar to the monitoring probe apparatus 20, the monitoring probe apparatus 30 includes comparison information generation units 32A, 32B,..., 32X for each data type. That is, each of the monitoring probe devices 20 and 30 has the same number of comparison information generation units.

比較情報生成部22A,22B,・・・,22Xのそれぞれは、パケットを結合してデータを再構築する結合部221A,221B,・・・,221X、再構築したデータの内容からチェックコードを生成するチェックコード生成部222A,222B,・・・,222X、および再構築したデータと比較情報を比較装置40へ送信するか否か判定する変化検出部223A,223B,・・・,223Xを有する。比較情報は、チェックコード生成部222A,222B,・・・,222Xが生成したチェックコードと再構築したデータのタイムスタンプを含む情報である。チェックコードは、例えばCyclic Redundancy Check(CRC:巡回冗長検査)を用いてデータから生成した数バイト程度の値である。   Each of the comparison information generation units 22A, 22B,..., 22X generates a check code from the contents of the reconstructed data by combining units 221A, 221B,. , 222X, and change detection units 223A, 223B,..., 223X for determining whether to transmit the reconstructed data and the comparison information to the comparison device 40. The comparison information is information including a check code generated by the check code generation units 222A, 222B, ..., 222X and a time stamp of the reconstructed data. The check code is a value of about several bytes generated from data using, for example, cyclic redundancy check (CRC: cyclic redundancy check).

図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 information generation units 22A, 22B, and 22X included in the monitoring probe device 20, and FIGS. 3D to 3F include the monitoring probe device 30. A state of processing of the comparison information generation units 32A, 32B, and 32X is shown. In the figure, the packets are arranged from bottom to top in the order received. In both cases, the same processing is performed, and therefore, description will be given here with a focus on FIG. 3A showing the processing of the comparison information generation unit 22A.

監視プローブ装置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 monitoring probe device 20, the packet with the data type “A” is transmitted to the comparison information generation unit 22A. In FIG. 3A, packets of data type “A” of A-5, A-4, A-3,..., A6 are received. The combining unit 221A combines the packets obtained by dividing the same single data to reconstruct the data. In FIG. 3A, data is reconstructed by combining, for example, packets A-5, A-4, and A-3. The time stamp of the reconstructed data at this time is assumed to be the time stamp “10: 12: 19.099” attached to the last packet A-3. Note that the uppermost dotted lines in FIGS. 3B and 3E indicate that packets for reconstructing data are not yet prepared. In some cases, as shown in FIGS. 3C and 3F, data is not divided and one packet corresponds to one data.

チェックコード生成部222Aは、再構築したデータのCRCを計算してチェックコードを生成する。例えば、図3(a)において、A−5,A−4,A−3から再構築したデータのチェックコードは、0x995Cであり、A−2,A−1,A0から再構築したデータのチェックコードは、0xD238である。   The check code generation unit 222A calculates a CRC of the reconstructed data and generates a check code. For example, in FIG. 3A, the check code of the data reconstructed from A-5, A-4, and A-3 is 0x995C, and the data reconstructed from A-2, A-1, and A0 is checked. The code is 0xD238.

なお、データストリーム変換部10が特定のデータ種別の所定の箇所のビットを書き換えるものである場合、チェックコード生成部222Aは、書き換えられる箇所をビットマスクしてチェックコードを生成する。例えば、データストリーム変換部10がデータ種別「B」のデータの先頭から10〜15ビット目を書き換えて出力するものである場合、チェックコード生成部222B,322Bは、データの10〜15ビット目を固定値で上書きしてチェックコードを生成する。これにより、書き換えられた箇所以外が同じならば同じ値のチェックコードが生成される。あるいは、データストリーム変換部10が所定の規則に従ってデータの一部を変更する場合、変更前のデータを扱うチェックコード生成部222Bは、変更されるデータの一部が変更後と同一となるように、そのデータの一部を変更した後でチェックコードを生成する。   When the data stream conversion unit 10 rewrites a bit at a predetermined location of a specific data type, the check code generation unit 222A generates a check code by bit-masking the rewritten location. For example, when the data stream conversion unit 10 rewrites and outputs the 10th to 15th bits from the beginning of the data of the data type “B”, the check code generation units 222B and 322B output the 10th to 15th bits of the data. Overwrite with a fixed value to generate a check code. As a result, a check code having the same value is generated if the portions other than the rewritten portion are the same. Alternatively, when the data stream conversion unit 10 changes a part of the data according to a predetermined rule, the check code generation unit 222B that handles the data before the change is configured so that the part of the changed data is the same as after the change. , Generate a check code after changing some of 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 change detection unit 223A detects a change point where the check code generated by the check code generation unit 222A changes. When the change point is detected, the change detection unit 223A transmits the reconstructed data and the comparison information to the comparison device 40. In FIG. 3A, both the second and third check codes from the bottom do not change at 0xD238, and the check code changes from the second to the fourth from the bottom (shown as “change point” in FIG. 3). ing). Therefore, the data and the comparison information are transmitted to the comparison device 40 in the second and fourth from the bottom. The comparison information transmitted to the comparison device 40 includes a check code and a time stamp. For example, the comparison information of the second data from the bottom in FIG. 3A includes a check code “0xD238” and a time stamp “10: 12: 20.124”. In order to compare the value of the generated check code with the value of the check code generated immediately before, the generated check code is temporarily stored in the storage unit included in the change detection unit 223A.

続いて比較装置40について説明する。比較装置40は、監視プローブ装置20,30それぞれから受信した対応する比較情報同士を比較し、比較した比較情報が相違していればアラートを出力する。比較装置40は、監視プローブ装置20,30それぞれが送信するデータと比較情報を受信して蓄積する比較情報受信部42,43、データ種別毎に比較情報を比較する比較部44A,44B,・・・,44Xを有する。   Next, the comparison device 40 will be described. The comparison device 40 compares corresponding comparison information received from each of the monitoring probe devices 20 and 30, and outputs an alert if the compared comparison information is different. The comparison device 40 includes comparison information receiving units 42 and 43 that receive and store data and comparison information transmitted by the monitoring probe devices 20 and 30, respectively, and comparison units 44A and 44B that compare comparison information for each data type.・ Has 44X

比較情報受信部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 information receiving unit 42 includes comparison information buffers 421A, 421B,..., 421X and storage units 422A, 422B,. The comparison information buffers 421A, 421B,..., 421X temporarily store the comparison information transmitted by the monitoring probe device 20 for each data type. The storage units 422A, 422B,..., 422X store the data transmitted by the monitoring probe device 20 for each data type. For example, the comparison information buffer 421A temporarily stores comparison information transmitted by the comparison information generation unit 22A of the monitoring probe device 20, that is, comparison information regarding data of the data type “A” of the data stream (1). . In the storage unit 422A, data of the data type “A” of the data stream (1) is stored. Similarly, the comparison information receiving unit 43 has comparison information buffers 431A, 431B,..., 431X and storage units 432A, 432B,. The comparison information and data are stored.

比較部44A,44B,・・・,44Xはデータ種別毎に用意され、比較情報受信部42,43それぞれから対応するデータ種別の比較情報を読み出して比較し、比較情報が相違している場合にアラートを出力する。比較部44A,44B,・・・,44Xは、比較情報バッファ421A,421B,・・・,421Xと比較情報バッファ431A,431B,・・・,431Xそれぞれから対応する比較情報を取得し、その比較情報の組のタイムスタンプの時間差が所定の時間以内であるか否かを判定する。そして、対応する比較情報が取得できない場合、あるいは、タイムスタンプの時間差が所定の時間を超えている場合にアラートを出力する。また、対応する比較情報が取得できない場合もアラートを出力する。   The comparison units 44A, 44B,..., 44X are prepared for each data type. When the comparison information is different from the comparison information receiving units 42 and 43, the comparison information of the corresponding data types is read and compared. Output an alert. The comparison units 44A, 44B,..., 44X acquire corresponding comparison information from the comparison information buffers 421A, 421B,..., 421X and the comparison information buffers 431A, 431B,. It is determined whether or not the time difference between the time stamps of the information set is within a predetermined time. An alert is output when the corresponding comparison information cannot be acquired, or when the time difference between the time stamps exceeds a predetermined time. An alert is also output when the corresponding comparison information cannot be acquired.

比較部44Aを例にとり、アラートを出力する処理をより具体的に説明する。   Taking the comparison unit 44A as an example, the process of outputting an alert will be described more specifically.

まず、比較部44Aは、比較情報バッファ421A,431Aそれぞれから比較情報を古い順に取り出し、比較情報のチェックコードを比較する。   First, the comparison unit 44A extracts the comparison information from the comparison information buffers 421A and 431A in order from the oldest, and compares the check codes of the comparison information.

同一のチェックコードを有する比較情報が見つからない場合、その比較情報を受信した時刻から所定の時間以上経過したか否か判定し、所定の時間以上経過していた場合は、タイムアウトのアラートを出力する。なお、比較情報に含まれるタイムスタンプを比較情報を受信した時刻として用いてもよい。   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 comparison device 40. 4A is a comparison information of FIGS. 3A and 3D, FIG. 4B is a comparison information of FIGS. 3B and 3E, and FIG. 4C is a comparison information of FIGS. 3C and 3F. It shows how to compare. 4A to 4C, the comparison information buffer on the data stream (1) side (comparison information receiving unit 42) is on the left side, and the comparison information buffer on the data stream (2) side (comparison information receiving unit 43) is on the right side. The contents are shown.

図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 data extraction unit 45 for the comparison device 40 to display a different portion of data. The change data extraction unit 45 reads the data corresponding to the comparison information determined to be different between the comparison units 44A, 44B,..., 44X from the storage units 422A and 432A, and displays the difference between the read data. indicate. The storage units 422A, 422B,..., 422X store data in association with time stamps, so that data corresponding to the comparison information can be easily retrieved. FIG. 6 shows an example in which different parts are displayed.

次に、比較監視システムの処理の流れについて説明する。   Next, the processing flow of the comparison monitoring system will be described.

まず、監視プローブ装置20,30それぞれが変換前後のデータストリームを取得する。監視プローブ装置20が変換前のデータストリーム(1)を取得し、監視プローブ装置30が変換後のデータストリーム(2)を取得する。   First, each of the monitoring probe devices 20 and 30 acquires a data stream before and after conversion. The monitoring probe device 20 acquires the data stream (1) before conversion, and the monitoring probe device 30 acquires the data stream (2) after conversion.

続いて、監視プローブ装置20のパケット解析部21がパケットをデータ種別毎に分類し、対応する比較情報生成部22A,22B,・・・,22Xに送信する。監視プローブ装置30のパケット解析部31も同様の処理を行う。以下、監視プローブ装置30において行われる同様の処理については説明を省略する。   Subsequently, the packet analysis unit 21 of the monitoring probe device 20 classifies the packets for each data type and transmits the packets to corresponding comparison information generation units 22A, 22B,. The packet analysis unit 31 of the monitoring probe device 30 performs the same processing. Hereinafter, description of the same processing performed in the monitoring probe apparatus 30 will be omitted.

続いて、結合部221A,221B,・・・,221Xがパケットを結合してデータを再構成し、チェックコード生成部222A,222B,・・・,222Xがデータのチェックコードを生成する。   Subsequently, the combining units 221A, 221B,..., 221X combine the packets to reconstruct the data, and the check code generation units 222A, 222B,.

そして、変化検出部223A,223B,・・・,223Xがチェックコードが変化したか否かを調べることにより、比較対象のデータであるか否か判定する。比較対象のデータでない場合は、そのデータについての処理を終了する。本実施の形態では、繰り返して送信されるデータの送信回数の違いを無視して相関性を比較監視するために、データ種別毎にチェックコードが変化した場合、つまりデータが変化した場合を比較対象のデータとする。例えば、データストリーム(1)では1分間に3回送信されたデータがデータストリーム(2)では1分間に2回しか送信されない場合でも、どちらも比較対象となるデータは最初の1つである。   Then, the change detection units 223A, 223B,..., 223X determine whether the check code has changed, thereby determining whether the data is to be compared. If it is not the data to be compared, the process for that data is terminated. In the present embodiment, in order to compare and monitor the correlation by ignoring the difference in the number of transmissions of repeatedly transmitted data, the comparison target is when the check code changes for each data type, that is, when the data changes. Data. For example, even when data transmitted three times per minute in the data stream (1) is transmitted only twice per minute in the data stream (2), the data to be compared is the first one.

比較対象のデータの場合、比較情報生成部22A,22B,・・・,22Xは、再構成したデータおよびチェックコードとタイムスタンプを含む比較情報を比較装置40へ送信し、比較装置40は、受信した比較情報を比較情報バッファ421A,・・・,421Xに、受信したデータを蓄積部422A,422B,・・・,422Xに蓄積する。   In the case of data to be compared, the comparison information generation units 22A, 22B,..., 22X transmit the reconstructed data and comparison information including the check code and time stamp to the comparison device 40, and the comparison device 40 receives the comparison information. The comparison information is stored in the comparison information buffers 421A,..., 421X, and the received data is stored in the storage units 422A, 422B,.

そして、比較部44A,44B,・・・,44Xは、比較情報バッファ421A,・・・,421X、比較情報バッファ431A,・・・,431Xそれぞれから比較情報を読み出して比較し、比較情報に相違を検出した場合は、アラートを出力するとともに、本実施の形態では、相違を検出した比較情報に対応するデータを比較情報受信部42,43それぞれから読み出して相違部分を比較表示する。   The comparison units 44A, 44B,..., 44X read the comparison information from the comparison information buffers 421A,..., 421X and the comparison information buffers 431A,. Is detected, and in the present embodiment, data corresponding to the comparison information in which the difference is detected is read from each of the comparison information receiving units 42 and 43 and the difference is compared and displayed.

また、本実施の形態における比較監視システムは、監視プローブ装置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 monitoring probe devices 20 and 30, and determines whether one of the data streams is stopped. Specifically, the monitoring probe devices 20 and 30 acquire the time stamp of the last input packet for each data type as a final time stamp and transmit it to the comparison device 40. The last time stamp is updated when the packet is acquired. The comparison device 40 compares the last time stamp received from each of the monitoring probe devices 20 and 30, and outputs an alarm when the difference exceeds a predetermined time. The stop of the data stream may be determined by comparing the bandwidth of the data stream.

以上説明したように、本実施の形態によれば、監視プローブ装置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 monitoring probe devices 20 and 30, and the value of the check code is different from the check code generated immediately before, The comparison information including the check code and the data time stamp is transmitted to the comparison device 40. The comparison device 40 compares the comparison information received from each of the monitoring probe devices 20 and 30, and when a difference is detected in the comparison information. By outputting an alert, if the same check code is consecutive, that is, if the same data is received continuously, comparison processing is not performed, so the correlation between data streams is ignored by ignoring the difference in the number of data transmissions. Gender can be compared and monitored.

本実施の形態によれば、比較装置40がデータを直接比較せず、データの内容から算出したチェックコードを比較するので、データ量にばらつきがある場合でも、比較装置40の比較処理の処理量のバラツキを抑制することができる。   According to the present embodiment, the comparison device 40 does not directly compare the data, but compares the check code calculated from the contents of the data. Therefore, even if the data amount varies, the amount of comparison processing performed by the comparison device 40 Can be suppressed.

本実施の形態によれば、パケット解析部21が入力したパケットをデータ種別毎に分類し、データ種別毎に比較情報生成部22A,22B,・・・,22Xを有することにより、データストリーム間で出現するデータの順番が異なる場合でも、データの相関性を比較監視することができる。   According to the present embodiment, the packets input by the packet analysis unit 21 are classified for each data type, and the comparison information generation units 22A, 22B,. Even when the order of appearing data is different, the correlation of data can be compared and monitored.

なお、本実施の形態では、データストリーム変換部10が入力したデータの送信回数を減らす処理を行う場合について説明したが、データストリーム変換部10が入力したデータの送信回数を増やす場合でも、データストリーム間の相関性を比較監視することができる。   In the present embodiment, the case where the process of reducing the number of transmissions of data input by the data stream conversion unit 10 has been described. However, even when the number of transmissions of data input by the data stream conversion unit 10 is increased, the data stream The correlation between them can be compared and monitored.

本実施の形態では、変化検出部がチェックコードの変化点を検出することで比較対象のデータを検出したが、変化検出部の判定条件は、データストリーム変換部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 stream conversion unit 10. For example, when the data stream conversion unit 10 performs a process of deleting the silent portion of the audio data, the change detection unit detects the silent portion and generates data other than the silent portion as comparison target data from the content of the data. By sending a check code to the comparison device 40, comparison and monitoring can be performed.

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 SYMBOLS 10 ... Data stream conversion part 20, 30 ... Monitoring probe apparatus 21, 31 ... Packet analysis part 22A, 22B, 22X, 32A, 32B, 32X ... Comparison information generation part 221A, 221B, ... Combining part 222A, 222B, 222X, 322A , 322B, 322X ... check code generation unit 223A, 223B, 223X, 323A, 323B, 323X ... change detection unit 40 ... comparison device 42, 43 ... comparison information reception unit 421A, 421B, 421X, 431A, 431B, 431X ... comparison information Buffers 422A, 422B, 422X, 432A, 432B, 432X ... Accumulation unit 44A, 44B, 44X ... Comparison unit 45 ... Change data extraction unit

Claims (7)

第1の伝送路からデータを取得する第1の監視プローブ装置、第2の伝送路からデータを取得する第2の監視プローブ装置、前記第1及び第2の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置を備えた比較監視システムであって、
前記第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記載の比較監視システム。   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. The comparative monitoring system described. 前記第1及び第2の伝送路には複数の種別のデータが伝送されるものであって、
前記第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及び第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乃至4のいずれかに記載の比較監視システム。   The check code generation means, for a known different portion existing in a part between the data acquired from each of the first and second transmission lines, changes the difference portion to the same and then changes the check code. The comparison monitoring system according to claim 1, wherein the comparison monitoring system is generated. 前記送信手段は、前記比較情報とともに当該比較情報に対応する前記データを前記比較装置に送信し、
前記比較装置は、
前記比較手段がアラートを出力する場合に前記第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の伝送路からデータを取得する第1の監視プローブ装置、第2の伝送路からデータを取得する第2の監視プローブ装置、前記第1及び第2の監視プローブ装置それぞれが取得したデータのうち所定のデータが同一であるか否か比較する比較装置による比較監視方法であって、
前記第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.
JP2010115587A 2010-05-19 2010-05-19 Comparative monitoring system and comparative monitoring method Active JP4901977B2 (en)

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)

* Cited by examiner, † Cited by third party
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)

* Cited by examiner, † Cited by third party
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

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