【手続補正書】
【提出日】平成20年4月25日(2008.4.25)
【手続補正１】
【補正対象書類名】明細書
【補正対象項目名】特許請求の範囲
【補正方法】変更
【補正の内容】
【特許請求の範囲】    
【請求項１】 
複数のデータ処理装置からの各要求に基づいて、送信されてくるデータストリームから各要求に対応する特定条件を満たすデータを抽出して取得し、取得したデータを要求元のデータ処理装置に返すデータ取得装置であって、
前記複数のデータ処理装置から、特定のデータを取得したい旨の前記要求を受け取る要求受け取り手段と、
前記要求受け取り手段から前記要求を受け取り、対応する前記条件を生成する条件生成手段と、
生成された前記条件の設定を受け付け、設定された前記条件のいずれかを満たすデータが前記データストリーム中に含まれているか否かを監視し、含まれている場合にはそのデータを抽出して取得するデータ抽出手段と、
受け取った前記要求に対応する前記条件の待ち行列を生成し、その待ち行列に従って、前記データ抽出手段に前記設定を行うことにより、データ取得を開始させ、前記データ抽出手段から前記設定を削除することにより、データ取得を終了させ、データ取得をスケジューリングするスケジューリング手段と、
前記データ抽出手段により取得されたデータを要求元のデータ処理装置に出力する出力手段と
を備えることを特徴とするデータ取得装置。
【請求項２】 
前記要求受け取り手段は、前記要求とともに、その要求に対するデータ取得の優先度を受け取り、
前記スケジューリング手段は、受け取った優先度の高い要求に対応する前記条件によるデータ取得が優先されるように前記待ち行列を生成する
ことを特徴とする請求項1記載のデータ取得装置。
【請求項３】 
前記要求受け取り手段は、前記要求とともに、その要求に対するデータ取得の態様を指定した監視状態情報を受け取り、
前記スケジューリング手段は、受け取った監視状態情報が常時監視によるデータ取得を指定している場合には、その要求に対応するデータ取得が継続されるように前記データ抽出手段への前記条件の設定を行い、
受け取った監視状態情報が間欠監視によるデータ取得を指定している場合には、その要求に対するデータ取得が定期的に開始されるように前記データ抽出手段への前記条件の設定と削除を行い、
受け取った監視状態情報が監視不要によるデータ取得を指定している場合には、その要求に対するデータ取得が１回だけ行われるように前記データ抽出手段への前記条件の設定と削除を行う
ことを特徴とする請求項1記載のデータ取得装置。
【請求項４】 
前記データ取得装置は、さらに、前記条件を一時的に記録しておくための記録手段を備え、
前記条件生成手段は、生成した前記条件を前記記録手段に記録し、
前記スケジューリング手段は、前記記録手段に記録された前記条件を読み出して並び替えた後に前記記録手段に書き戻すことによって前記待ち行列を生成することを特徴とする請求項1記載のデータ取得装置。
【請求項５】 
前記要求受け取り手段は、前記要求とともに、その要求の種類を示すヘッダ情報を受け取り、
前記条件生成手段は、前記要求受け取り手段から、前記要求と前記ヘッダ情報を受け取り、受け取った前記要求に対応する前記条件を生成し、生成した前記条件と受け取った前記ヘッダ情報とを関連付けて前記記録手段に記録し、
前記スケジューリング手段は、前記記録手段に記録されたヘッダ情報に基づいて、前記データ抽出手段に設定された前記条件を削除することによって特定の要求に対するデータ取得を終了させる
ことを特徴とする請求項４記載のデータ取得装置。
【請求項６】 
前記データ取得装置は、さらに、現在時刻を示すタイマー手段を備え、
前記要求受け取り手段は、前記要求とともに、その要求の種類を示すヘッダ情報を受け取り、
前記条件生成手段は、前記要求受け取り手段から、前記要求と前記ヘッダ情報を受け取り、受け取った前記要求に対応する前記条件を生成し、前記ヘッダ情報に基づいて、データ取得を中断させる時刻を示すタイムアウト時刻を生成し、生成した前記条件と関連付けて前記記録手段に記録し、
前記スケジューリング手段は、前記データ抽出手段に設定されている前記条件について、前記タイマー手段が示す現在時刻と前記記録手段に記録されている対応するタイムアウト時刻とを比較することによってタイムアウト時刻が到来したか否かを判断し、到来したと判断した前記条件については、前記データ抽出手段における設定から削除することによってデータ取得を終了させる
ことを特徴とする請求項４記載のデータ取得装置。
【請求項７】 
前記データ取得装置は、さらに、現在時刻を示すタイマー手段を備え、
前記条件生成手段は、前記要求受け取り手段から、前記要求を受け取ったときに、その要求に対応する前記条件とその時刻を示す要求生成時刻情報を生成し、生成した前記条件と関連付けて前記要求生成時刻情報を前記記録手段に記録し、  
前記スケジューリング手段は、前記タイマー手段が示す現在時刻と前記記録手段に記録された要求生成時刻情報が示す時刻とを比較することによって、前記要求を受け取ったときからの経過時間を算出し、その経過時間に基づいて前記スケジューリングをする
ことを特徴とする請求項４記載のデータ取得装置。
【請求項８】 
前記条件生成手段は、前記要求受け取り手段から、前記要求を受け取ると、その要求に対応する前記条件を生成し、生成した前記条件と前記記録手段に既に記録されている条件とを比較することによって、それらを結合することができるか否かを判断し、結合できると判断した場合には、それら条件を結合した新たな条件を生成して前記記録手段に記録し、
前記スケジューリング手段は、結合によって生成された新たな条件を前記記録手段から読み出し、その新たな条件を前記待ち行列に組み入れた後に前記データ抽出手段に設定することによってデータ取得を開始させるとともに、結合に用いられた条件を前記データ抽出手段における設定から削除することによってデータ取得を終了させる
ことを特徴とする請求項４記載のデータ取得装置。
【請求項９】 
前記条件生成手段は、前記要求受け取り手段から、前記要求を受け取ると、その要求に対応する前記条件を生成し、その条件を識別するための識別情報を生成するとともに、前記結合によって新たな条件を生成した場合には、結合に用いられた条件と結合によって生成された条件とを関連付ける結合情報を前記識別情報を用いて生成し、それら識別情報及び結合情報を、識別情報に対応する前記条件と関連付けて前記記録手段に記録し、
前記スケジューリング手段は、前記記録手段に記録された識別情報及び結合情報に基づいて、結合によって新たに生成された条件及び結合に用いられた条件を特定し、それぞれ、データ取得の開始及び終了を制御する
ことを特徴とする請求項８記載のデータ取得装置。
【請求項１０】 
前記条件生成手段は、結合の対象となる２以上の前記条件それぞれに共通する内容が含まれている場合に、それら条件を結合することができると判断し、共通する内容だけを条件とする新たな条件を生成する
ことを特徴とする請求項９記載のデータ取得装置。
【請求項１１】 
前記データ取得装置は、さらに、現在時刻を示すタイマー手段を備え、
前記スケジューリング手段は、データ取得を開始させた場合には、その開始時刻から一定時間だけ経過した時刻を示すタイムアウト時刻を生成し、対応する前記条件と関連付けて前記記録手段に記録し、前記タイマー手段が示す現在時刻と前記記録手段に記録されている対応するタイムアウト時刻とを比較することによってタイムアウト時刻が到来したか否かを判断し、
タイムアウト時刻が到来したと判断した場合には、前記データ抽出手段に設定された前記条件を削除することによってデータ取得を終了させるとともに、その終了時刻から一定時間だけ経過した時刻を示すタイムアウト復活時刻を生成し、対応する前記条件と関連付けて前記記録手段に記録し、前記タイマー手段が示す現在時刻と前記記録手段に記録されている対応するタイムアウト復活時刻とを比較することによってタイムアウト復活時刻が到来したか否かを判断し、
タイムアウト復活時刻が到来したと判断した場合には、その条件を前記待ち行列に組み入れた後に前記データ抽出手段に設定することによってデータ取得を開始させる
ことを特徴とする請求項４記載のデータ取得装置。
【請求項１２】 
前記データ抽出手段は、設定されている前記条件について、データが取得されたか否かを示すデータ取得情報を出力し、前記スケジューリング手段は、前記データ取得情報に基づいて、前記記録手段に記録されている前記条件について、データが取得されたか否かを示すデータ取得判定情報を生成し、対応する前記条件と関連付けて前記記録手段に記録するとともに、生成したデータ取得判定情報に基づいて、前記スケジューリングをすることを特徴とする請求項４記載のデータ取得装置。
【請求項１３】 
前記データ取得装置は、さらに、現在時刻を示すタイマー手段を備え、
前記条件生成手段は、前記要求受け取り手段から、前記要求を受け取ったときに、その要求に対応する前記条件を生成するとともに、その時刻を示す条件生成時刻情報を生成し、生成した前記条件と関連付けて前記条件生成時刻情報を前記記録手段に記録し、
前記スケジューリング手段は、前記データ抽出手段に設定されている前記条件に対応するデータ取得について、前記タイマー手段が示す現在時刻と前記記録手段に記録された条件生成時刻情報が示す時刻とを比較するとともに、前記記録手段に記録されたデータ取得判定情報を参照することによって、前記要求を受け取ってから一定時間を超えてデータが取得されていない前記条件が前記記録手段に存在するか否かを判断し、その判断結果に基づいて、前記スケジューリングをする
ことを特徴とする請求項１２記載のデータ取得装置。
【請求項１４】 
前記条件生成手段は、前記要求受け取り手段から、前記要求を受け取ると、その要求に対応する前記条件を生成し、生成した前記条件と前記記録手段に既に記録されている条件とを比較することによって、それらを結合することができるか否かを判断し、結合できると判断した場合には、それら条件を結合した新たな条件を生成して前記条件生成時刻情報とともに前記記録手段に記録し、
前記スケジューリング手段は、結合によって生成された新たな条件を前記記録手段から読み出し、前記待ち行列に組み入れた後にその条件を前記データ抽出手段に設定することによってデータ取得を開始させるとともに、結合に用いられた条件を前記データ抽出手段における設定から削除することによってデータ取得を終了させ、結合によって新たに生成された条件について、前記要求を受け取ってから一定時間を超えてデータが取得されていないと判断した場合には、前記データ抽出手段に設定された前記条件を削除することによってその新たな条件に対応するデータ取得を終了させ、結合に用いられた条件を前記記録手段から読み出し、前記待ち行列に組み入れた後にそれら条件を前記データ抽出手段に設定することによってデータ取得を開始させる
ことを特徴とする請求項１３記載のデータ取得装置。
【請求項１５】 
前記データ取得装置は、さらに、現在時刻を示すタイマー手段を備え、
前記要求受け取り手段は、前記要求とともに、その要求に対するデータ取得の態様を指定した監視状態情報を受け取り、
前記スケジューリング手段は、タイムアウト時刻の到来によってデータ取得を終了させた要求に対応する前記監視状態情報が監視不要によるデータ取得を指定している場合には、その終了時刻から一定時間だけ経過した時刻を示すタイムアウト復活時刻を生成した後に、前記タイマー手段が示す現在時刻と前記タイムアウト復活時刻とを比較することによってタイムアウト復活時刻が到来したか否かを判断し、タイムアウト復活時刻が到来したと判断したときに、その要求に対応する前記条件を前記待ち行列に組み入れた後に前記データ抽出手段に設定することによってデータ取得を開始させる
ことを特徴とする請求項１記載のデータ取得装置。
【請求項１６】 
前記要求受け取り手段は、前記要求とともに、その要求に対するデータ取得の態様を指定した監視状態情報及びデータ取得の優先度を受け取り、
前記スケジューリング手段は、前記データ抽出手段に設定されている前記条件に対応する前記監視状態情報が監視不要によるデータ取得を指定しており、かつ、そのデータが取得されていない場合であって、その条件に対応する優先度よりも高い優先度の条件が前記待ち行列にある場合には、前記データ抽出手段に設定されている前記条件を削除することによって前記データ取得を終了させるとともに、前記待ち行列にある前記条件を前記データ抽出手段に設定することによってデータ取得を開始させる
ことを特徴とする請求項１記載のデータ取得装置。
【請求項１７】 
前記要求受け取り手段は、前記要求とともに、その要求に対するデータ取得の態様を指定した監視状態情報、データ取得の優先度及びその要求を識別するための識別情報を受け取り、
前記条件生成手段は、前記要求受け取り手段から、前記要求と前記監視状態情報と前記識別情報を受け取り、その要求に対応する前記条件を生成し、生成した前記条件と関連付けて前記監視状態情報と前記識別情報とを前記記録手段に記録し、
前記データ抽出手段は、前記データストリーム中に含まれるヘッダ情報を参照することにより、前記データストリームに含まれるデータに対応する前記識別情報及びそのバージョンを示すバージョン情報を抽出して出力し、
前記スケジューリング手段は、前記データ抽出手段が出力した前記識別情報及び前記バージョン情報に基づいて、前記記録手段に記録されている前記条件それぞれについて、対応するデータが取得されたか否かを示すデータ取得判定情報と、対応するデータの最新バージョンを示す最新バージョン情報と、その最新バージョンを更新した回数を示すバージョン更新回数情報とを生成して前記記録手段に記録するとともに、前記監視状態情報が監視不要によるデータ取得を示し、かつ、前記優先度が同一であり、かつ、前記データ取得判定情報の内容が同一である複数の前記条件が前記待ち行列にある場合には、それら条件のうち、前記記録手段に記録された対応する前記バージョン更新回数情報が示すバージョンの更新回数が多い条件を優先して前記データ抽出手段に設定することによってデータ取得を開始させる
ことを特徴とする請求項４記載のデータ取得装置。
【請求項１８】 
複数のデータ処理装置からの各要求に基づいて、送信されてくるデータストリームから各要求に対応する特定条件を満たすデータを抽出して取得し、取得したデータを要求元のデータ処理装置に返すデータ取得方法であって、
前記複数のデータ処理装置から、特定のデータを取得したい旨の前記要求を受け取る要求受け取りステップと、
前記要求受け取りステップから前記要求を受け取り、対応する前記条件を生成する条件生成ステップと、
生成された前記条件の設定を受け付け、設定された前記条件のいずれかを満たすデータが前記データストリーム中に含まれているか否かを監視し、含まれている場合にはそのデータを抽出して取得するデータ抽出ステップと、
受け取った前記要求に対応する前記条件の待ち行列を生成し、その待ち行列に従って、前記データ抽出ステップに前記設定を行うことにより、データ取得を開始させ、前記データ抽出手段から前記設定を削除することにより、データ取得を終了させ、データ取得をスケジューリングするスケジューリングステップと、前記データ抽出ステップにより取得されたデータを要求元のデータ処理装置に出力する出力ステップとを含む
ことを特徴とするデータ取得方法。
【請求項１９】 
複数のデータ処理装置からの要求に基づいて、送信されてくるデータストリームから特定の条件を満たすデータを抽出して取得し、取得したデータを要求元のデータ処理装置に返すデータ取得装置のためのプログラムを記録したコンピュータ読み取り可能な記録媒体であって、
前記プログラムは、コンピュータに、前記複数のデータ処理装置から、特定のデータを取得したい旨の前記要求を受け取る要求受け取りステップと、前記要求受け取りステップから前記要求を受け取り、対応する前記条件を生成する条件生成ステップと、生成された前記条件の設定を受け付け、設定された前記条件のいずれかを満たすデータが前記データストリーム中に含まれているか否かを監視し、含まれている場合にはそのデータを抽出して取得するデータ抽出ステップと、受け取った前記要求に対応する前記条件の待ち行列を生成し、その待ち行列に従って、前記データ抽出ステップに前記設定を行うことにより、データ取得を開始させ、前記データ抽出手段から前記設定を削除することにより、データ取得を終了させ、データ取得をスケジューリングするスケジューリングステップと、前記データ抽出ステップにより取得されたデータを要求元のデータ処理装置に出力する出力ステップとを実行させる
ことを特徴とする記録媒体。    
【手続補正２】
【補正対象書類名】明細書
【補正対象項目名】００１０
【補正方法】変更
【補正の内容】
【００１０】
また、本発明は、上記データ取得装置における各手段をステップとするデータ取得方法として実現したり、そのようなステップをコンピュータに実行させるプログラムとして実現することもできる。また、本発明のデータ取得装置は、複数のデータ処理装置からの各要求に基づいて、送信されてくるデータストリームから前記要求に対応する特定の条件を満たすデータを抽出して取得し、取得したデータを要求元の各データ処理装置に返すデータ取得装置であって、複数のデータ処理装置から、前記要求に対応する前記条件を取得する取得手段と、前記条件の設定を受け付け、設定された前記条件のいずれかを満たすデータが前記データストリーム中に含まれているか否かを監視し、含まれている場合にはそのデータを抽出して取得するデータ抽出手段と、前記条件と、前記データ抽出手段に前記条件の設定が「有る」か、「無い」かを示す設定情報と、前記条件の取得順序に対応した値を示し、前記条件の設定が前記データ抽出手段から削除されたときに最も新しい前記取得順序を示す値に初期化される順序値との対応関係を示すテーブルを保持するテーブル保持手段と、前記取得手段によって新たに前記条件が取得される毎に、新たに取得された前記条件と、当該前記条件の前記設定情報と、最も新しい前記取得順序を示す前記順序値とを組にして前記テーブルに記録し、前記テーブルに記録された前記設定情報と前記順序値を参照することにより、前記データ抽出手段への前記条件の設定を制御するスケジューリング手段と前記データ抽出手段により取得されたデータを要求元のデータ処理装置に出力する出力手段とを備えることを特徴としてもよい。