[go: up one dir, main page]

JP2006048290A - 情報処理装置、分散処理システム、分散処理方法及びそのプログラム - Google Patents

情報処理装置、分散処理システム、分散処理方法及びそのプログラム Download PDF

Info

Publication number
JP2006048290A
JP2006048290A JP2004226809A JP2004226809A JP2006048290A JP 2006048290 A JP2006048290 A JP 2006048290A JP 2004226809 A JP2004226809 A JP 2004226809A JP 2004226809 A JP2004226809 A JP 2004226809A JP 2006048290 A JP2006048290 A JP 2006048290A
Authority
JP
Japan
Prior art keywords
information processing
processing apparatus
mobile agent
information
program
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.)
Pending
Application number
JP2004226809A
Other languages
English (en)
Inventor
Tomonori Yokoyama
知典 横山
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.)
Sony Corp
Original Assignee
Sony 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 Sony Corp filed Critical Sony Corp
Priority to JP2004226809A priority Critical patent/JP2006048290A/ja
Publication of JP2006048290A publication Critical patent/JP2006048290A/ja
Pending legal-status Critical Current

Links

Images

Landscapes

  • Computer And Data Communications (AREA)

Abstract

【課題】
処理を実行させるノードを効率良く選択することにより、ネットワーク上の通信量を大幅に削減し、分散処理システムの処理能力を高めることが可能な情報処理装置、分散処理システム、分散処理方法及びそのプログラムを提供すること。
【解決手段】
情報処理装置1が、所定の探索条件を指定した移動エージェントを生成して情報処理装置2へ送信すると、移動エージェントは情報処理装置2が探索条件を満たすか否かを判定し、満たさない場合には更に情報処理装置3へ移動する。移動エージェントは、情報処理装置3が探索条件を満たすと判定した場合には、情報処理装置3の計算資源を予約した上で、情報処理装置1へ発見通知を送信する。それに対して情報処理装置1は、情報処理装置3を分散処理に使用する旨を通知し、続いてジョブを送信することにより情報処理装置3においてジョブが実行される。
【選択図】 図15

Description

本発明は、所定の処理を分散して実行することが可能な情報処理装置、分散処理システム、分散処理方法及びそのプログラム関する。
従来から、ネットワークに接続された複数の情報処理装置間で一の処理を分散して実行するネットワークシステムが存在する。このようなネットワークシステムにおいては、例えば、各情報処理装置間でソフトウェアセルを用いてプログラムやデータをやり取りして、各情報処理装置を協調動作させることにより、高い演算能力を実現することが可能である。(例えば、特許文献1参照)。
特開2002−366533号公報(図1等)
上記のような分散処理システムにおいては、処理を割り当てるノードとしての情報処理装置を選択するために、分散処理システムを構成する多数の情報処理装置からプロセッサ使用率やメモリ使用率等の装置情報を予め取得しておく必要がある。しかしながら、ネットワーク上に多数の情報処理装置が存在し、各情報処理装置が処理を割り当てる情報処理装置を選択しようとする場合には、上記装置情報を取得するために大量の通信トラフィックが発生し、ネットワークを混雑させてシステムの性能を大幅に低下させてしまう可能性がある。
以上のような事情に鑑み、本発明の目的は、処理を実行させるノードを効率良く選択することにより、ネットワーク上の通信量を大幅に削減し、分散処理システムの処理能力を向上させることが可能な情報処理装置、分散処理システム、分散処理方法及びそのプログラムを提供することにある。
上述の課題を解決するため、本発明の情報処理装置は、ネットワークを介して接続された他の情報処理装置とともに所定の処理を実行することが可能な情報処理装置であって、当該情報処理装置及び前記他の情報処理装置の間を移動し、前記所定の処理を実行可能な前記他の情報処理装置を探索する移動エージェントを生成する生成手段と、前記生成された移動エージェントを前記他の情報処理装置へ送信する第1の送信手段と、前記送信された移動エージェントから、当該移動エージェントが探索した他の情報処理装置の探索結果の通知を受信する第1の受信手段と、前記受信された探索結果通知を基に、前記所定の処理を実行可能な他の情報処理装置へ当該所定の処理の実行命令を送信する第2の送信手段とを具備する。
上記情報処理装置は、例えばPC(Personal Computer)や、ハードディスクレコーダ、PDA(Personal Digital Assistance)、テレビ等の家電機器であり、コンピュータとしての機能を有していればどのような装置であってもよい。また上記所定の処理とは、例えば上記情報処理装置が画像処理アプリケーションを実行可能なPCの場合には画像処理、ハードディスクレコーダの場合にはコンテンツの記録処理等、複数の情報処理装置で分散可能な処理である。
上記構成によれば、上記生成及び送信した移動エージェントが上記所定の処理を実行可能な他の情報処理装置を自動的に探索して探索結果を通知するため、所定の処理を実行可能な他の情報処理装置を効率良く把握し、処理を実行させることができる。
上記情報処理装置は、前記生成された移動エージェントに、前記所定の処理を実行可能な前記他の情報処理装置を探索するための探索条件を少なくとも設定する設定手段を更に具備し、前記移動エージェントは、前記探索条件を基に前記所定の処理を実行可能な他の情報処理装置を探索するものであってもよい。上記所定の処理を実行可能な他の情報処理装置を移動エージェントに探索させる際に予め探索条件を設定しておくことで、移動エージェントの探索処理も容易になり、また上記情報処理装置も移動エージェントからの探索結果通知を受信するだけで上記所定の処理を実行可能な他の情報処理装置を容易に把握することができる。
上記情報処理装置において、前記探索条件は、前記他の情報処理装置のプロセッサ使用率を基に設定されるものであってもよい。上記所定の処理を実行可能な他の情報処理装置を判断するパラメータをプロセッサ使用率とし、当該判断を移動エージェントに行わせることで、移動エージェントからの探索結果通知を基に、例えばプロセッサ使用率が所定の割合以下の情報処理装置に上記所定の処理を容易に実行させることができる。
上記情報処理装置及び前記他の情報処理装置はそれぞれ複数のプロセッサを有し、前記探索条件は、前記他の情報処理装置の使用プロセッサ数を基に設定されるものであってもよい。これにより、上記情報処理装置及び他の情報処理装置がいわゆるマルチプロセッサ環境にある場合には、例えば使用プロセッサ数が所定の値以下の他の情報処理装置を効率良く把握して処理を実行させることができる。
上記情報処理装置において、前記探索条件は、前記他の情報処理装置のメモリ使用率を基に設定されるものであってもよい。これにより、上記所定の処理の実行に必要な空きメモリを有する他の情報処理装置を効率良く把握して、処理を実行させることができる。
上記情報処理装置において、前記設定手段は、前記移動エージェントが当該情報処理装置及び前記他の情報処理装置間を移動する際の移動範囲を更に設定し、前記移動エージェントは、前記設定された移動範囲内の他の情報処理装置へ移動するものであってもよい。移動範囲を設定することにより、探索条件を満たす情報処理装置を発見するまで移動エージェントがネットワーク上を延々と移動し続けて、ネットワークに通信トラフィックが生じてしまうようなことを防ぐことができる。
上記情報処理装置において、前記移動範囲は、当該情報処理装置及び前記他の情報処理装置の前記ネットワークにおけるIPアドレスを基に設定されるものであってもよい。例えば同一フロアや同一ビルでEthernet(登録商標)等に接続され、IPアドレスのうち同一のネットワークアドレス部分(上位24bitが共通)を有する情報処理装置間を移動範囲とすることができる。
上記情報処理装置において、前記移動範囲は、当該情報処理装置と前記移動エージェントとの間に存在する前記他の情報処理装置の数を基に設定されるものであってもよい。例えば、パケットが宛先に到達するまでに経由する装置の数を表すhop数をカウントすることにより、例えば上記情報処理装置から1hopで届く情報処理装置まで、というような移動範囲を設定することができる。
上記情報処理装置において、前記移動範囲は、前記移動エージェントが要する当該情報処理装置との通信時間を基に設定されるものであってよい。当該通信時間の計測には、例えばICMP(Internet Control Message Protocol)を用いることができる。これにより、例えば上記情報処理装置から20ms以内で移動できる位置まで、というような移動範囲を設定することができる。
上記情報処理装置において、前記設定手段は、前記移動エージェントが生存する生存時間を更に設定し、前記移動エージェントは、前記送信された時から前記生存時間が経過したときに消滅するものであってもよい。これにより、上記移動エージェントがネットワーク上を移動し続けてネットワークに通信トラフィックが生じてしまうことを、上記移動範囲を制限する方法とは別の方法により防ぐことができる。
上記情報処理装置において、前記移動エージェントは、前記他の情報処理装置の動作状態に関する情報を取得する手段と、前記取得した情報を基に、他の情報処理装置が前記探索条件を満たすか否かを判断する手段とを有していてもよい。動作状態に関する情報とは、上記プロセッサ使用率や使用プロセッサ数、メモリ使用率といった情報である。移動エージェントが、送信先の他の情報処理装置内でこれらの情報を自動的に取得することで、上記情報処理装置は自らの処理に拠らなくとも所定の処理を実行可能な他の情報処理装置を効率良く把握することができる。
上記情報処理装置において、前記移動エージェントは、前記他の情報処理装置が前記探索条件を満たす場合に、当該他の情報処理装置内で前記所定の処理を実行するための計算資源を予約する手段を更に有していてもよい。計算資源を予約しておくことで、移動エージェントから探索結果の通知を受けた後、上記実行命令を送信するまでの間に他の情報処理装置に計算資源を使われてしまうことを防ぐことができる。
上記情報処理装置において、前記移動エージェントは、前記計算資源を予約してから所定時間経過したときに前記計算資源の予約を解除する手段を更に有していてもよい。これにより、所定時間経過後は他の情報処理装置が別の処理のために計算資源を用いることができるため、上記予約の状態が長時間続くことにより計算資源が使用されない時間を極力無くし、システムを効率的に稼動させることができる。
上記情報処理装置及び前記他の情報処理装置は、それぞれの装置を識別するための識別情報を有し、前記探索結果通知は、前記所定の処理を実行可能な他の情報処理装置の識別情報であってもよい。これにより、上記情報処理装置は上記識別情報を受信するだけで上記所定の処理を実行可能な他の情報処理装置の存在を把握することができる。
上記情報処理装置において、前記他の情報処理装置は前記ネットワーク上に複数存在し、前記第1の送信手段は、前記移動エージェントを前記複数の他の情報処理装置へそれぞれ送信し、前記第2の送信手段は、前記第1の受信手段により前記複数の他の情報処理装置の識別情報が受信された場合に、複数の他の情報処理装置のうち一の情報処理装置を選択して当該他の情報処理装置へ前記実行命令を送信し、当該情報処理装置は、前記第2の送信手段により選択されなかった他の情報処理装置に送信された前記移動エージェントに、前記計算資源の予約の解除を指示する手段を更に具備していてもよい。移動エージェントを複数送信することで、上記所定の処理を実行可能な他の情報処理装置を迅速に把握することができるとともに、選択されなかった他の情報処理装置の計算資源の予約解除を指示することで、予約解除により解放された計算資源を他の用途に使用させる等、システムを効率良く稼動させることができる。
上記情報処理装置は、前記他の情報処理装置において生成及び送信された移動エージェントを受信する第2の受信手段と、前記受信された移動エージェントから前記他の情報処理装置へ送信された前記探索結果通知を基に前記他の情報処理装置から送信された前記所定の処理の実行命令を受信する第3の受信手段と、前記受信された実行命令を基に前記所定の処理を実行する実行手段とを更に具備していてもよい。他の情報処理装置から移動エージェントを受信することで、他の情報処理装置のマスター装置として機能するだけでなく、他の情報処理装置へ自身の動作状態を報知し、自身が実行可能な場合には、マスターである他の情報処理装置から指示された処理をスレーブとして実行することができる。
上記情報処理装置は、前記他の情報処理装置から送信された移動エージェントを認証する手段と、前記認証手段により前記移動エージェントが認証されない場合に、前記移動エージェントを破棄する手段とを更に具備していてもよい。当該認証には、例えばRSA公開鍵暗号方式等が用いられる。これにより、移動エージェントが何者かに改竄されていないか、信頼できる発信元か等の確認をすることができ、それらの確認が取れない場合には移動エージェントを破棄できるため、悪意ある移動エージェントにより、情報が漏洩したり上記情報処理装置及びシステム全体の動作が不安定になったりすることを防ぐことができる。
本発明の分散処理システムは、ネットワークを介して接続された第1及び第2の情報処理装置が所定の処理を分散して実行する分散処理システムであって、前記第1の情報処理装置は、前記分散処理システム内を移動し、前記所定の処理を実行可能な前記第2の情報処理装置を探索する移動エージェントを生成する手段と、前記生成された移動エージェントを前記第2の情報処理装置へ送信する手段と、前記送信された移動エージェントから、当該移動エージェントが探索した第2の情報処理装置の探索結果の通知を受信する手段と、前記受信された探索結果通知を基に、前記所定の処理を実行可能な第2の情報処理装置へ当該所定の処理の実行命令を送信する手段とを有し、前記第2の情報処理装置は、前記送信された移動エージェントを受信する手段と、前記第1の情報処理装置から前記所定の処理の実行命令を受信する手段と、前記受信された実行命令を基に前記所定の処理を実行する手段とを有している。
この構成によれば、上記移動エージェントの探索処理により、上記分散処理システムにおいて所定の処理を実行させるノードとしての第2の情報処理装置を効率良く選択して分散処理を行い、通信量を削減してシステムの処理能力を向上させることができる。
本発明の分散処理方法は、情報処理装置が、ネットワークを介して接続された他の情報処理装置とともに所定の処理を実行する方法であって、当該情報処理装置及び前記他の情報処理装置の間を移動し、前記所定の処理を実行可能な前記他の情報処理装置を探索する移動エージェントを生成するステップと、前記生成された移動エージェントを前記他の情報処理装置へ送信するステップと、前記送信された移動エージェントから、当該移動エージェントが探索した他の情報処理装置の探索結果の通知を受信するステップと、前記受信された探索結果通知を基に、前記所定の処理を実行可能な他の情報処理装置へ当該所定の処理の実行命令を送信するステップとを具備する。
また、本発明のプログラムは、ネットワークを介して接続された他の情報処理装置とともに所定の処理を実行することが可能な情報処理装置に、当該情報処理装置及び前記他の情報処理装置の間を移動し、前記所定の処理を実行可能な前記他の情報処理装置を探索する移動エージェントを生成するステップと、前記生成された移動エージェントを前記他の情報処理装置へ送信するステップと、前記送信された移動エージェントから、当該移動エージェントが探索した他の情報処理装置の探索結果の通知を受信するステップと、前記受信された探索結果通知を基に、前記所定の処理を実行可能な他の情報処理装置へ当該所定の処理の実行命令を送信するステップとを実行させるものである。
本発明によれば、処理を実行させるノードを効率良く選択することにより、ネットワーク上の通信量を大幅に削減し、分散処理システムの処理能力を向上させることができる。
以下、本発明の実施の形態を図面に基づき説明する。
まず、本実施形態において前提となるネットワークシステムについて説明する。図1は、当該ネットワークシステムの一例を示し、ネットワーク9を介して複数の情報処理装置1、2、3、4が接続されたものである。情報処理装置1、2、3、4は、例えばPCや各種のAV機器、ポータブル機器等である。
情報処理装置1について示すと、情報処理装置1は、コンピュータ機能部として情報処理コントローラ11を備える。情報処理コントローラ11は、メインプロセッサ21−1、サブプロセッサ23−1,23−2,23−3、DMAC(ダイレクトメモリアクセスコントローラ)25−1及びDC(ディスクコントローラ)27−1を有する。
メインプロセッサ21−1は、サブプロセッサ23−1,23−2,23−3によるプログラム実行(データ処理)のスケジュール管理と、情報処理コントローラ11(情報処理装置1)の全般的な管理とを行う。ただし、メインプロセッサ21−1内で管理のためのプログラム以外のプログラムが動作するように構成することもできる。その場合には、メインプロセッサ21−1はサブプロセッサとしても機能することになる。メインプロセッサ21−1は、LS(ローカルストレージ)22−1を有する。
サブプロセッサは、1つでもよいが、望ましくは複数とする。本例は、複数の場合である。各サブプロセッサ23−1,23−2,23−3は、メインプロセッサ21−1の制御によって並列的かつ独立にプログラムを実行し、データを処理する。更に、場合によってメインプロセッサ21−1内のプログラムがサブプロセッサ23−1,23−2,23−3内のプログラムと連携して動作するように構成することもできる。後述する機能プログラムもメインプロセッサ21−1内で動作するプログラムである。各サブプロセッサ23−1,23−2,23−3も、LS(ローカルストレージ)24−1,24−2,24−3を有する。
DMAC25−1は、情報処理コントローラ11に接続されたDRAM(ダイナミックRAM)などからなるメインメモリ26−1に格納されているプログラム及びデータにアクセスするものであり、DC27−1は、情報処理コントローラ11に接続された外部記録部28−1,28−2にアクセスするものである。
外部記録部28−1,28−2は、固定ディスク(ハードディスク)でも、リムーバブルディスクでもよく、また、MO,CD±RW,DVD±RWなどの光ディスク、メモリディスク、SRAM(スタティックRAM)、ROMなど、各種のものを用いることができる。したがって、DC27−1は、ディスクコントローラと称するが、外部記録部コントローラである。図1の例のように、情報処理コントローラ11に対して外部記録部28を複数接続できるように、情報処理コントローラ11を構成することができる。
メインプロセッサ21−1、各サブプロセッサ23−1,23−2,23−3、DMAC25−1及びDC27−1は、バス29−1によって接続される。
情報処理コントローラ11には、当該の情報処理コントローラ11を備える情報処理装置1を、ネットワーク全体を通して一意的に識別できる識別子が、情報処理装置IDとして割り当てられる。
メインプロセッサ21−1及び各サブプロセッサ23−1,23−2,23−3に対しても同様に、それぞれを特定できる識別子が、メインプロセッサID及びサブプロセッサIDとして割り当てられる。
情報処理コントローラ11は、ワンチップIC(集積回路)として構成することが望ましい。他の情報処理装置2、3、4も、上記と同様に構成される。ここで、図1において親番号が同一であるユニットは枝番号が異なっていても、特に断りがない限り同じ働きをするものとする。また、以下の説明において枝番号が省略されている場合には、枝番号の違いにいる差異を生じないものとする。
上述したように、1つの情報処理コントローラ内の各サブプロセッサ23は、独立にプログラムを実行し、データを処理するが、異なるサブプロセッサがメインメモリ26内の同一領域に対して同時に読み出しまたは書き込みを行った場合には、データの不整合を生じ得る。そこで、サブプロセッサ23からメインメモリ26へのアクセスは、以下のような手順によって行う。
図2(A)に示すように、メインメモリ26は、複数のアドレスを指定できるメモリロケーションによって構成される。各メモリロケーションに対しては、データの状態を示す情報を格納するための追加セグメントが割り振られる。追加セグメントは、F/Eビット、サブプロセッサID及びLSアドレス(ローカルストレージアドレス)を含むものとされる。また、各メモリロケーションには、後述のアクセスキーも割り振られる。F/Eビットは、以下のように定義される。
F/Eビット=0は、サブプロセッサ23によって読み出されている処理中のデータ、または空き状態であるため最新データではない無効データであり、読み出し不可であることを示す。また、F/Eビット=0は、当該メモリロケーションにデータ書き込み可能であることを示し、書き込み後に1に設定される。
F/Eビット=1は、当該メモリロケーションのデータがサブプロセッサ23によって読み出されておらず、未処理の最新データであることを示す。当該メモリロケーションのデータは読み出し可能であり、サブプロセッサ23によって読み出された後に0に設定される。また、F/Eビット=1は、当該メモリロケーションがデータ書き込み不可であることを示す。
更に、上記F/Eビット=0(読み出し不可/書き込み可)の状態において、当該メモリロケーションについて読み出し予約を設定することは可能である。F/Eビット=0のメモリロケーションに対して読み出し予約を行う場合には、サブプロセッサ23は、読み出し予約を行うメモリロケーションの追加セグメントに、読み出し予約情報として当該サブプロセッサ23のサブプロセッサID及びLSアドレスを書き込む。
その後、データ書き込み側のサブプロセッサ23によって、読み出し予約されたメモリロケーションにデータが書き込まれ、F/Eビット=1(読み出し可/書き込み不可)に設定されたとき、予め読み出し予約情報として追加セグメントに書き込まれたサブプロセッサID及びLSアドレスに読み出される。
複数のサブプロセッサによってデータを多段階に処理する必要がある場合、このように各メモリロケーションのデータの読み出し/書き込みを制御することによって、前段階の処理を行うサブプロセッサ23が、処理済みのデータをメインメモリ26上の所定のアドレスに書き込んだ後に即座に、後段階の処理を行う別のサブプロセッサ23が前処理後のデータを読み出すことが可能となる。
図2(B)に示すように、各サブプロセッサ23内のLS24も、複数のアドレスを指定できるメモリロケーションによって構成される。各メモリロケーションに対しては、同様に追加セグメントが割り振られる。追加セグメントは、ビジービットを含むものとされる。
サブプロセッサ23がメインメモリ26内のデータを自身のLS24のメモリロケーションに読み出すときには、対応するビジービットを1に設定して予約する。ビジービットが1であるメモリロケーションには、他のデータは格納することができない。LS24のメモリロケーションに読み出し後、ビジービットは0になり、任意の目的に使用できるようになる。
図2(A)に示すように、さらに、各情報処理コントローラと接続されたメインメモリ26には、複数のサンドボックスが含まれる。サンドボックスは、メインメモリ26内の領域を画定するものであり、各サンドボックスは、各サブプロセッサ23に割り当てられ、そのサブプロセッサが排他的に使用することができる。すなわち、各々のサブプロセッサ23は、自身に割り当てられたサンドボックスを使用できるが、この領域を超えてデータのアクセスを行うことはできない。メインメモリ26は、複数のメモリロケーションから構成されるが、サンドボックスは、これらのメモリロケーションの集合である。
更に、メインメモリ26の排他的な制御を実現するために、図2(C)に示すようなキー管理テーブルが用いられる。キー管理テーブルは、情報処理コントローラ内のSRAM等の比較的高速のメモリに格納され、DMAC25と関連付けられる。キー管理テーブル内の各エントリには、サブプロセッサID、サブプロセッサキー及びキーマスクが含まれる。
サブプロセッサ23がメインメモリ26を使用する際のプロセスは、以下の通りである。まず、サブプロセッサ23はDMAC25に、読み出しまたは書き込みのコマンドを出力する。このコマンドには、自身のサブプロセッサIDと、使用要求先であるメインメモリ26のアドレスが含まれる。
DMAC25は、このコマンドを実行する前に、キー管理テーブルを参照して、使用要求元のサブプロセッサのサブプロセッサキーを調べる。次に、DMAC25は、調べた使用要求元のサブプロセッサキーと、使用要求先であるメインメモリ26内の図2(A)に示したメモリロケーションに割り振られたアクセスキーとを比較して、2つのキーが一致した場合にのみ、上記のコマンドを実行する。
図2(C)に示したキー管理テーブル上のキーマスクは、その任意のビットが1になることによって、そのキーマスクに関連付けられたサブプロセッサキーの対応するビットが0または1になることができる。例えば、サブプロセッサキーが1010であるとする。通常、このサブプロセッサキーによって1010のアクセスキーを持つサンドボックスへのアクセスだけが可能になる。しかし、このサブプロセッサキーと関連付けられたキーマスクが0001に設定されている場合には、キーマスクのビットが1に設定された桁のみにつき、サブプロセッサキーとアクセスキーとの一致判定がマスクされ、このサブプロセッサキー1010によってアクセスキーが1010または1011のいずれかであるアクセスキーを持つサンドボックスへのアクセスが可能となる。
以上のようにして、メインメモリ26のサンドボックスの排他性が実現される。すなわち、1つの情報処理コントローラ内の複数のサブプロセッサによってデータを多段階に処理する必要がある場合、以上のように構成することによって、前段階の処理を行うサブプロセッサと、後段階の処理を行うサブプロセッサのみが、メインメモリ26の所定アドレスにアクセスできるようになり、データを保護することができる。
例えば、以下のように使用することが考えられる。まず、情報処理装置の起動直後においては、キーマスクの値は全てゼロである。メインプロセッサ内のプログラムが実行され、サブプロセッサ内のプログラムと連携動作するものとする。第1のサブプロセッサにより出力された処理結果データを一旦メインメモリに格納し、第2のサブプロセッサに入力したいときには、該当するメインメモリ領域は、当然どちらのサブプロセッサからもアクセス可能である必要がある。そのような場合に、メインプロセッサ内のプログラムは、キーマスクの値を適切に変更し、複数のサブプロセッサからアクセスできるメインメモリ領域を設けることにより、サブプロセッサによる多段階的な処理を可能にする。
より具体的には、他の情報処理装置からのデータ→第1のサブプロセッサによる処理→第1のメインメモリ領域→第2のサブプロセッサによる処理→第2のメインメモリ領域、という手順で多段階処理が行われるときには、
第1のサブプロセッサのサブプロセッサキー:0100、
第1のメインメモリ領域のアクセスキー :0100、
第2のサブプロセッサのサブプロセッサキー:0101、
第2のメインメモリ領域のアクセスキー :0101
というような設定のままだと、第2のサブプロセッサは第1のメインメモリ領域にアクセスすることができない。そこで、第2のサブプロセッサのキーマスクを0001にすることにより、第2のサブプロセッサによる第1のメインメモリ領域へのアクセスを可能にすることができる。
図1のネットワークシステムでは、情報処理装置1、2、3、4間での分散処理のために、情報処理装置1、2、3、4間でソフトウェアセルが伝送される。すなわち、ある情報処理装置内の情報処理コントローラに含まれるメインプロセッサ21は、コマンド、プログラム及びデータを含むソフトウェアセルを生成し、ネットワーク9を介して他の情報処理装置に送信することによって、処理を分散することができる。
図3に、ソフトウェアセルの構成の一例を示す。この例のソフトウェアセルは、全体として、送信元ID、送信先ID、応答先ID、セルインターフェース、DMAコマンド、プログラム及びデータによって構成される。
送信元IDには、ソフトウェアセルの送信元である情報処理装置のネットワークアドレス及び当該情報処理装置の情報処理装置ID、更に、その情報処理装置内の情報処理コントローラが備えるメインプロセッサ21及び各サブプロセッサ23の識別子(メインプロセッサID及びサブプロセッサID)が含まれる。
送信先ID及び応答先IDには、それぞれ、ソフトウェアセルの送信先である情報処理装置、及びソフトウェアセルの実行結果の応答先である情報処理装置についての、同じ情報が含まれる。
セルインターフェースは、ソフトウェアセルの利用に必要な情報であり、グローバルID、必要なサブプロセッサの情報、サンドボックスサイズ及び前回のソフトウェアセルIDから構成される。
グローバルIDは、ネットワーク全体を通して当該ソフトウェアセルを一意的に識別できるものであり、送信元ID及びソフトウェアセルの作成または送信の日時(日付及び時刻)に基づいて作成される。
必要なサブプロセッサの情報は、当該ソフトウェアセルの実行に必要なサブプロセッサの数を設定する。サンドボックスサイズは、当該ソフトウェアセルの実行に必要なメインメモリ26内及びサブプロセッサ23のLS24内のメモリ量を設定する。前回のソフトウェアセルIDは、ストリーミングデータなどのシーケンシャルな実行を要求する1グループのソフトウェアセル内の、前回のソフトウェアセルの識別子である。
ソフトウェアセルの実行セクションは、DMAコマンド、プログラム及びデータから構成される。DMAコマンドには、プログラムの起動に必要な一連のDMAコマンドが含まれ、プログラムには、サブプロセッサ23によって実行されるサブプロセッサプログラムが含まれる。ここでのデータは、このサブプロセッサプログラムを含むプログラムによって処理されるデータである。
更に、DMAコマンドには、ロードコマンド、キックコマンド、機能プログラム実行コマンド、ステータス要求コマンド、及びステータス返信コマンドが含まれる。
ロードコマンドは、メインメモリ26内の情報をサブプロセッサ23内のLS24にロードするコマンドであり、ロードコマンド自体のほかに、メインメモリアドレス、サブプロセッサID及びLSアドレスを含む。メインメモリアドレスは、情報のロード元であるメインメモリ26内の所定領域のアドレスを示す。サブプロセッサID及びLSアドレスは、情報のロード先であるサブプロセッサ23の識別子及びLS24のアドレスを示す。
キックコマンドは、プログラムの実行を開始するコマンドであり、キックコマンド自体のほかに、サブプロセッサID及びプログラムカウンタを含む。サブプロセッサIDは、キック対象のサブプロセッサ23を識別し、プログラムカウンタは、プログラム実行用プログラムカウンタのためのアドレスを与える。
機能プログラム実行コマンドは、後述のように、ある情報処理装置が他の情報処理装置に対して、機能プログラムの実行を要求するコマンドである。機能プログラム実行コマンドを受信した情報処理装置内の情報処理コントローラは、後述の機能プログラムIDによって、起動すべき機能プログラムを識別する。
ステータス要求コマンドは、送信先IDで示される情報処理装置の現在の動作状態(状況)に関する装置情報を、応答先IDで示される情報処理装置宛に送信要求するコマンドである。機能プログラムについては後述するが、図6に示す情報処理コントローラのメインメモリ26が記憶するソフトウェアの構成図において機能プログラムにカテゴライズされるプログラムである。機能プログラムは、メインメモリ26にロードされ、メインプロセッサ21により実行される。
ステータス返信コマンドは、上記のステータス要求コマンドを受信した情報処理装置が、自身の装置情報を当該ステータス要求コマンドに含まれる応答先IDで示される情報処理装置に応答するコマンドである。ステータス返信コマンドは、実行セクションのデータ領域に装置情報を格納する。
図4に、DMAコマンドがステータス返信コマンドである場合におけるソフトウェアセルのデータ領域の構造を示す。
情報処理装置IDは、情報処理コントローラを備える情報処理装置を識別するための識別子であり、ステータス返信コマンドを送信する情報処理装置のIDを示す。情報処理装置IDは、電源投入時、その情報処理装置内の情報処理コントローラに含まれるメインプロセッサ21によって、電源投入時の日時、情報処理装置のネットワークアドレス及び情報処理装置内の情報処理コントローラに含まれるサブプロセッサ23の数などに基づいて生成される。
情報処理装置種別IDには、当該情報処理装置の特徴を表す値が含まれる。情報処理装置の特徴とは、例えば、オーディオプレーヤや、ハードディスクレコーダ等である。また、情報処理装置種別IDは、音響再生、動画記録再生等の機能を表すものであってもよい。情報処理装置の特徴や機能を表す値は予め決定されているものとし、情報処理装置種別IDを読み出すことにより、当該情報処理装置の特徴や機能を把握することが可能である。
MS(マスター/スレーブ)ステータスは、後述のように情報処理装置がマスター装置またはスレーブ装置のいずれで動作しているかを表すもので、これが0に設定されている場合にはマスター装置として動作していることを示し、1に設定されている場合にはスレーブ装置として動作していることを示す。
メインプロセッサ動作周波数は、情報処理コントローラ内のメインプロセッサ21の動作周波数を表す。メインプロセッサ使用率は、メインプロセッサ21で現在動作している全てのプログラムについての、メインプロセッサ21での使用率を表す。メインプロセッサ使用率は、対象メインプロセッサの全処理能力に対する使用中の処理能力の比率を表した値で、例えばプロセッサ処理能力評価のための単位であるMIPSを単位として算出され、または単位時間あたりのプロセッサ使用時間に基づいて算出される。後述のサブプロセッサ使用率についても同様である。
サブプロセッサ数は、当該の情報処理コントローラが備えるサブプロセッサ23の数を表す。サブプロセッサIDは、当該の情報処理コントローラ内の各サブプロセッサ23を識別するための識別子である。
サブプロセッサステータスは、各サブプロセッサ23の状態を表すものであり、unused,reserved,busyなどの状態がある。unusedは、当該のサブプロセッサが現在使用されてなく、使用の予約もされていないことを示す。reservedは、現在は使用されていないが、予約されている状態を示す。busyは、現在使用中であることを示す。
サブプロセッサ使用率は、当該のサブプロセッサで現在実行している、または当該のサブプロセッサに実行が予約されているプログラムについての、当該サブプロセッサでの使用率を表す。すなわち、サブプロセッサ使用率は、サブプロセッサステータスがbusyである場合には、現在の使用率を示し、サブプロセッサステータスがreservedである場合には、後に使用される予定の推定使用率を示す。
サブプロセッサID、サブプロセッサステータス及びサブプロセッサ使用率は、1つのサブプロセッサ23に対して一組設定され、1つの情報処理コントローラ内のサブプロセッサ23に対応する組数が設定される。
メインメモリ総容量及びメインメモリ使用量は、それぞれ、当該の情報処理コントローラに接続されているメインメモリ26の総容量及び現在使用中の容量を表す。
外部記録部数は、当該の情報処理コントローラに接続されている外部記録部28の数を表す。外部記録部IDは、当該の情報処理コントローラに接続されている外部記録部28を一意的に識別する情報である。外部記録部種別IDは、当該の外部記録部の種類(例えば、ハードディスク、CD±RW、DVD±RW、メモリディスク、SRAM、ROMなど)を表す。
外部記録部総容量及び外部記録部使用量は、それぞれ、外部記録部IDによって識別される外部記録部28の総容量及び現在使用中の容量を表す。
外部記録部ID、外部記録部種別ID、外部記録部総容量及び外部記録部使用量は、1つの外部記録部28に対して一組設定されるものであり、当該の情報処理コントローラに接続されている外部記録部28の数の組数だけ設定される。すなわち、1つの情報処理コントローラに複数の外部記録部が接続されている場合、各々の外部記録部には異なる外部記録部IDが割り当てられ、外部記録部種別ID、外部記録部総容量及び外部記録部使用量も別々に管理される。
ある情報処理装置内の情報処理コントローラに含まれるメインプロセッサ21は、以上のような構成のソフトウェアセルを生成し、ネットワーク9を介して他の情報処理装置及び当該装置内の情報処理コントローラに送信する。送信元の情報処理装置、送信先の情報処理装置、応答先の情報処理装置、及び各装置内の情報処理コントローラは、それぞれ、上記の送信元ID、送信先ID及び応答先IDによって識別される。
ソフトウェアセルを受信した情報処理装置内の情報処理コントローラに含まれるメインプロセッサ21は、そのソフトウェアセルをメインメモリ26に格納する。さらに、送信先のメインプロセッサ21は、ソフトウェアセルを読み出し、それに含まれるDMAコマンドを処理する。具体的には、送信先のメインプロセッサ21は、まず、ロードコマンドを実行する。これによって、ロードコマンドで指示されたメインメモリアドレスから、ロードコマンドに含まれるサブプロセッサID及びLSアドレスで特定されるサブプロセッサ内のLS24の所定領域に、情報がロードされる。ここでロードされる情報は、受信したソフトウェアセルに含まれるサブプロセッサプログラムまたはデータ、あるいはその他の指示されたデータである。
次に、メインプロセッサ21は、キックコマンドを、これに含まれるサブプロセッサIDで指示されたサブプロセッサに、同様にキックコマンドに含まれるプログラムカウンタと共に出力する。指示されたサブプロセッサは、そのキックコマンド及びプログラムカウンタに従って、サブプロセッサプログラムを実行する。そして、実行結果をメインメモリ26に格納した後、実行を完了したことをメインプロセッサ21に通知する。
なお、送信先の情報処理装置内の情報処理コントローラにおいてソフトウェアセルを実行するプロセッサはサブプロセッサ23に限定されるものではなく、メインプロセッサ21がソフトウェアセルに含まれる機能プログラムなどのメインメモリ用プログラムを実行するように指定することも可能である。
この場合には、送信元の情報処理装置は、送信先の情報処理装置宛に、サブプロセッサプログラムの代わりに、メインメモリ用プログラム及びそのメインメモリ用プログラムによって処理されるデータを含み、DMAコマンドがロードコマンドであるソフトウェアセルを送信し、メインメモリ26にメインメモリ用プログラム及びそれによって処理されるデータを記憶させる。次に、送信元の情報処理装置は、送信先の情報処理装置宛に、送信先の情報処理装置内の情報処理コントローラについてのメインプロセッサID、メインメモリアドレス、メインメモリ用プログラムを識別するための後述の機能プログラムIDなどの識別子、及びプログラムカウンタを含み、DMAコマンドがキックコマンドまたは機能プログラム実行コマンドであるソフトウェアセルを送信して、メインプロセッサ21に当該メインメモリ用プログラムを実行させる。
以上のように、この発明のネットワークシステムでは、送信元の情報処理装置は、サブプロセッサプログラムまたはメインメモリ用プログラムをソフトウェアセルによって送信先の情報処理装置に送信するとともに、当該サブプロセッサプログラムを送信先の情報処理装置内の情報処理コントローラに含まれるサブプロセッサ23にロードさせ、当該サブプロセッサプログラムまたは当該メインメモリ用プログラムを送信先の情報処理装置に実行させることができる。
送信先の情報処理装置内の情報処理コントローラでは、受信したソフトウェアセルに含まれるプログラムがサブプロセッサプログラムである場合には、当該サブプロセッサプログラムを指定されたサブプロセッサにロードさせる。そして、ソフトウェアセルに含まれるサブプロセッサプログラムまたはメインメモリ用プログラムを実行させる。したがって、ユーザが送信先の情報処理装置を操作しなくても自動的に、当該サブプロセッサプログラムまたは当該メインメモリ用プログラムを送信先の情報処理装置内の情報処理コントローラに実行させることができる。
このようにして情報処理装置は、自装置内の情報処理コントローラがサブプロセッサプログラムまたは機能プログラムなどのメインメモリ用プログラムを有していない場合には、ネットワークに接続された他の情報処理装置からそれらを取得することができる。更に、各サブプロセッサ間ではDMA方式によりデータ転送を行い、また上述したサンドボックスを使用することによって、1つの情報処理コントローラ内でデータを多段階に処理する必要がある場合でも、高速かつ高セキュリティに処理を実行することができる。
ソフトウェアセルの使用による分散処理の結果、図5の上段に示すようにネットワーク9に接続されている複数の情報処理装置1、2、3、4は、図5の下段に示すように、仮想的な1台の情報処理装置7として動作する。ただし、そのためには、以下のような構成によって、以下のような処理が実行される必要がある。
図6に、個々の情報処理コントローラのメインメモリ26が記憶するソフトウェアの構成を示す。これらのソフトウェア(プログラム)は、情報処理装置に電源が投入される前においては、当該の情報処理コントローラに接続される外部記録部28に記録されているものである。各プログラムは、機能または特徴によって、制御プログラム、機能プログラム及びデバイスドライバにカテゴライズされる。
制御プログラムは、各情報処理コントローラが同じものを備え、各情報処理コントローラのメインプロセッサ21が実行するもので、後述のMS(マスター/スレーブ)マネージャ及び能力交換プログラムを含む。
機能プログラムは、メインプロセッサ21が実行するもので、記録用、再生用、素材検索用など、情報処理コントローラごとに情報処理装置に応じたものが備えられる。
デバイスドライバは、情報処理コントローラ(情報処理装置)の入出力(送受信)用で、放送受信、モニタ出力、ビットストリーム入出力、ネットワーク入出力など、情報処理コントローラ毎に情報処理装置に応じたものが備えられる。
情報処理装置が物理的にネットワーク9に接続された状態で、情報処理装置に主電源が投入され、情報処理装置が電気的・機能的にもネットワーク9に接続されると、その情報処理装置の情報処理コントローラのメインプロセッサ21は、制御プログラムに属する各プログラム、及びデバイスドライバに属する各プログラムを、メインメモリ26にロードする。
ロード手順としては、メインプロセッサ21は、まず、DC27に読み出し命令を実行させることによって、外部記録部28からプログラムを読み出し、次に、DMAC25に書き込み命令を実行させることによって、そのプログラムをメインメモリ26に書き込む。
機能プログラムに属する各プログラムについては、必要なときに必要なプログラムだけをロードするように構成してもよく、または、他のカテゴリに属するプログラムと同様に、主電源投入直後に各プログラムをロードするように構成してもよい。
ここで、機能プログラムに属する各プログラムは、ネットワークに接続された全ての情報処理装置の外部記録部28に記録されている必要はなく、いずれか1つの情報処理装置の外部記録部28に記録されていれば、前述の方法によって他の情報処理装置からロードすることができるので、結果的に図5の下段に示すように、仮想的な1台の情報処理装置7として機能プログラムを実行することができる。
また、前述したようにメインプロセッサ21によって処理される機能プログラムは、サブプロセッサ23によって処理されるサブプロセッサプログラムと連携動作する場合がある。そこでメインプロセッサ21が外部記録部28から機能プログラムを読み出し、メインメモリ26に書き込む際に対象となる機能プログラムと連携動作するサブプロセッサプログラムが存在する場合には、当該サブプロセッサプログラムも併せて同じメインメモリ26に書き込むものとする。この場合、連携動作するサブプロセッサプログラムは1個である場合もあるし、複数個であることもあり得る。複数個である場合には、全ての連携動作するサブプロセッサプログラムをメインメモリ26に書き込むことになる。メインメモリ26に書き込まれたサブプロセッサプログラムはその後、サブプロセッサ23内のLS24に書き込まれ、メインプロセッサ21によって処理される機能プログラムと連携動作する。
図3のソフトウェアセルに示したように、機能プログラムには、プログラムごとにプログラムを一意的に識別できる識別子が、機能プログラムIDとして割り当てられる。機能プログラムIDは、機能プログラムの作成の段階で、作成日時や情報処理装置IDなどから決定される。
そしてサブプロセッサプログラムにもサブプロセッサプログラムIDが割り当てられ、これによりサブプロセッサプログラムを一意的に識別可能である。割り当てられるサブプロセッサプログラムIDは、連携動作する相手となる機能プログラムの機能プログラムIDと関連性のある識別子、例えば機能プログラムIDを親番号とした上で最後尾に枝番号を付加させたもの等であることもあり得るし、連携動作する相手となる機能プログラムの機能プログラムIDとは関連性のない識別子であってもよい。いずれにしても機能プログラムとサブプロセッサプログラムが連携動作する場合には、両者とも相手の識別子であるプログラムIDを自プログラム内に互いに記憶しておく必要がある。機能プログラムが複数個のサブプロセッサプログラムと連携動作する場合にも、当該機能プログラムは複数個ある全てのサブプロセッサプログラムのサブプロセッサプログラムIDを記憶しておくことになる。
メインプロセッサ21は、自身が動作する情報処理装置の装置情報(動作状態に関する情報)を格納するための領域をメインメモリ26に確保し、当該情報を自装置の装置情報テーブルとして記録する。ここでの装置情報は、図4に示した情報処理装置ID以下の各情報である。
上述したネットワークシステムでは、ある情報処理装置への主電源投入時、その情報処理装置の情報処理コントローラのメインプロセッサ21は、マスター/スレーブマネージャ(以下、MSマネージャ)をメインメモリ26にロードし、実行する。
MSマネージャは、自身が動作する情報処理装置がネットワーク9に接続されていることを検知すると、同じネットワーク9に接続されている他の情報処理装置の存在を確認する。ここでの「接続」または「存在」は、上述したように、情報処理装置が物理的にネットワーク9に接続されているだけでなく、電気的・機能的にもネットワーク9に接続されていることを示す。また、自身が動作する情報処理装置を自装置、他の情報処理装置を他装置と称する。当該装置も、当該情報処理装置を示すものとする。
MSマネージャが同じネットワーク9に接続されている他の情報処理装置の存在を確認する方法を以下に示す。
MSマネージャは、DMAコマンドがステータス要求コマンドであり、送信元ID及び応答先IDが当該情報処理装置で、送信先IDを特定しないソフトウェアセルを生成して、当該情報処理装置が接続されたネットワーク上に送信して、ネットワーク接続確認用のタイマーを設定する。タイマーのタイムアウト時間は、例えば10分とされる。
当該ネットワークシステム上に他の情報処理装置が接続されている場合、その他の装置は、上記ステータス要求コマンドのソフトウェアセルを受信し、上記応答先IDで特定されるステータス要求コマンドを発行した情報処理装置に対して、DMAコマンドがステータス返信コマンドであり、かつデータとして自身(その他装置)の装置情報を含むソフトウェアセルを送信する。このステータス返信コマンドのソフトウェアセルには、少なくとも当該他装置を特定する情報(情報処理装置ID、メインプロセッサに関する情報、サブプロセッサに関する情報など)及び当該他装置のMSステータスが含まれる。
ステータス要求コマンドを発行した情報処理装置のMSマネージャは、上記ネットワーク接続確認用のタイマーがタイムアウトするまで、当該ネットワーク上の他装置から送信されるステータス返信コマンドのソフトウェアセルの受信を監視する。その結果、MSステータス=0(マスター装置)を示すステータス返信コマンドが受信された場合には、自装置の装置情報テーブルにおけるMSステータスを1に設定する。これによって、当該装置は、スレーブ装置となる。
一方、上記ネットワーク接続確認用のタイマーがタイムアウトするまでの間にステータス返信コマンドが全く受信されなかった場合、またはMSステータス=0(マスター装置)を示すステータス返信コマンドが受信されなかった場合には、自装置の装置情報テーブルにおけるMSステータスを0に設定する。これによって、当該装置は、マスター装置となる。
すなわち、いずれの装置もネットワーク9に接続されていない状態、またはネットワーク9上にマスター装置が存在しない状態において、新たな情報処理装置がネットワーク9に接続されると、当該装置は自動的にマスター装置として設定される。一方、ネットワーク9上に既にマスター装置が存在する状態において、新たな情報処理装置がネットワーク9に接続されると、当該装置は自動的にスレーブ装置として設定される。
マスター装置及びスレーブ装置のいずれについても、MSマネージャは、定期的にステータス要求コマンドをネットワーク9上の他装置に送信してステータス情報を照会することにより、他装置の状況を監視する。その結果、ネットワーク9に接続されている情報処理装置の主電源が遮断され、またはネットワーク9から情報処理装置が切り離されることにより、予め判定用に設定された所定期間内に特定の他装置からステータス返信コマンドが返信されなかった場合や、ネットワーク9に新たな情報処理装置が接続された場合など、ネットワーク9の接続状態に変化があった場合には、その情報を後述の能力交換プログラムに通知する。
メインプロセッサ21は、MSマネージャから、ネットワーク9上の他装置の照会及び自装置のMSステータスの設定完了の通知を受けると、能力交換プログラムを実行する。
能力交換プログラムは、自装置がマスター装置である場合には、ネットワーク9に接続されている全ての他装置の装置情報、すなわち各スレーブ装置の装置情報を取得する。他装置の装置情報の取得は、上述したように、DMAコマンドがステータス要求コマンドであるソフトウェアセルを生成して他装置に送信し、その後、DMAコマンドがステータス返信コマンドで、かつデータとして他装置の装置情報を含むソフトウェアセルを他装置から受信することによって可能である。
能力交換プログラムは、マスター装置である自装置の装置情報テーブルと同様に、ネットワーク9に接続されている全ての他装置(各スレーブ装置)の装置情報を格納するための領域を自装置のメインメモリ26に確保し、これら情報を他装置(スレーブ装置)の装置情報テーブルとして記録する。すなわち、マスター装置のメインメモリ26には、自装置を含むネットワーク9に接続されている全ての情報処理装置の装置情報が、装置情報テーブルとして記録される。
一方、自装置がスレーブ装置である場合には、能力交換プログラムは、ネットワーク9に接続されている全ての他装置の装置情報、すなわちマスター装置及び自装置以外の各スレーブ装置の装置情報を取得し、これら装置情報に含まれる情報処理装置ID及びMSステータスを、自装置のメインメモリ26に記録する。すなわち、スレーブ装置のメインメモリ26には、自装置の装置情報が、装置情報テーブルとして記録されるとともに、自装置以外のネットワーク9に接続されているマスター装置及び各スレーブ装置についての情報処理装置ID及びMSステータスが、別の装置情報テーブルとして記録される。
また、マスター装置及びスレーブ装置のいずれについても、能力交換プログラムは、上記のようにMSマネージャから、新たにネットワーク9に情報処理装置が接続されたことが通知されたときには、その情報処理装置の装置情報を取得し、上述したようにメインメモリ26に記録する。
なお、MSマネージャ及び能力交換プログラムは、メインプロセッサ21で実行されることに限らず、いずれかのサブプロセッサ23で実行されてもよい。また、MSマネージャ及び能力交換プログラムは、情報処理装置の主電源が投入されている間は常時動作する常駐プログラムであることが望ましい。
マスター装置及びスレーブ装置のいずれについても、能力交換プログラムは、上記のようにMSマネージャから、ネットワーク9に接続されている情報処理装置の主電源が遮断され、またはネットワーク9から情報処理装置が切り離されたことが通知されたときには、その情報処理装置の装置情報テーブルを自装置のメインメモリ26から削除する。
更に、このようにネットワーク9から切断された情報処理装置がマスター装置である場合には、以下のような方法によって、新たにマスター装置が決定される。
具体的には、例えば、ネットワーク9から切断されていない情報処理装置は、それぞれ、自装置及び他装置の情報処理装置IDを数値に置き換えて、自装置の情報処理装置IDを他装置の情報処理装置IDと比較し、自装置の情報処理装置IDがネットワーク9から切断されていない情報処理装置中で最小である場合、そのスレーブ装置は、マスター装置に移行して、MSステータスを0に設定し、マスター装置として、上述したように、ネットワーク9に接続されている全ての他装置(各スレーブ装置)の装置情報を取得して、メインメモリ26に記録する。
図5の下段に示したようにネットワーク9に接続されている複数の情報処理装置1、2、3、4を仮想的な1台の情報処理装置7として動作させるためには、マスター装置がユーザの操作及びスレーブ装置の動作状態を把握する必要がある。
図7に、4台の情報処理装置が仮想的な1台の情報処理装置7として動作する様子を示す。情報処理装置1がマスター装置、情報処理装置2、3、4がスレーブ装置A、B、Cとして、動作しているものとする。
ユーザがネットワーク9に接続されている情報処理装置を操作した場合、操作対象がマスター装置1であれば、その操作情報は、マスター装置1において直接把握され、操作対象がスレーブ装置であれば、その操作情報は、操作されたスレーブ装置からマスター装置1に送信される。すなわち、ユーザの操作対象がマスター装置1とスレーブ装置のいずれであるかにかかわらず、その操作情報は常にマスター装置1において把握される。操作情報の送信は、例えば、DMAコマンドが操作情報送信コマンドであるソフトウェアセルによって行われる。
そして、マスター装置1内の情報処理コントローラ11に含まれるメインプロセッサ21−1は、その操作情報に従って、実行する機能プログラムを選択する。その際、必要であれば、マスター装置1内の情報処理コントローラ11に含まれるメインプロセッサ21−1は、上記の方法によって自装置の外部記録部28−1、28−2からメインメモリ26−1に機能プログラムをロードするが、他の情報処理装置(スレーブ装置)がマスター装置1に機能プログラムを送信してもよい。
機能プログラムには、その実行単位毎に必要となる、図4に示した各情報として表される情報処理装置種別ID、メインプロセッサまたはサブプロセッサの処理能力、メインメモリ使用量、外部記録部に関する条件等の、装置に関する要求スペックが規定されている。
マスター装置1内の情報処理コントローラ11に含まれるメインプロセッサ21−1は、各機能プログラムについて必要となる上記要求スペックを読み出す。また、予め能力交換プログラムによってメインメモリ26−1に記録された装置情報テーブルを参照し、各情報処理装置の装置情報を読み出す。ここでの装置情報は、図4に示した情報処理装置ID以下の各情報を示し、メインプロセッサ、サブプロセッサ、メインメモリ及び外部記録部に関する情報である。
マスター装置1内の情報処理コントローラ11に含まれるメインプロセッサ21−1は、ネットワーク9上に接続された各情報処理装置の上記装置情報と、機能プログラム実行に必要となる上記要求スペックとを順次比較する。
そして、例えば、機能プログラムが録画機能を必要とする場合には、情報処理装置種別IDに基づいて、録画機能を有する情報処理装置のみを特定して抽出する。更に、機能プログラムを実行するために必要なメインプロセッサまたはサブプロセッサの処理能力、メインメモリ使用量、外部記録部に関する条件を確保できるスレーブ装置を、実行要求候補装置として特定する。ここで、複数の実行要求候補装置が特定された場合には、当該候補装置から1つの実行要求候補装置を特定して選択する。
実行要求するスレーブ装置が特定されたら、マスター装置1内の情報処理コントローラ11に含まれるメインプロセッサ21−1は、その特定されたスレーブ装置について、自装置内の情報処理コントローラ11に含まれるメインメモリ26−1に記録されている当該スレーブ装置の装置情報テーブルを更新する。
更に、マスター装置1内の情報処理コントローラ11に含まれるメインプロセッサ21−1は、DMAコマンドが機能プログラム実行コマンドであるソフトウェアセルを生成し、当該ソフトウェアセルのセルインターフェースに、機能プログラムに関する必要なサブプロセッサの情報及びサンドボックスサイズ(図3参照)を設定して、上記実行要求されるスレーブ装置に対して送信する。
機能プログラムの実行を要求されたスレーブ装置は、その機能プログラムを実行するとともに、自装置の装置情報テーブルを更新する。その際、必要であれば、スレーブ装置内の情報処理コントローラに含まれるメインプロセッサ21は、上記の方法によって自装置の外部記録部28からメインメモリ26に機能プログラムおよび当該機能プログラムと連携動作するサブプロセッサプログラムをロードする。
機能プログラムの実行を要求されたスレーブ装置の外部記録部28に、必要な機能プログラムまたは当該機能プログラムと連携動作するサブプロセッサプログラムが記録されていない場合には、他の情報処理装置が当該機能プログラムまたはサブプロセッサプログラムを、その機能プログラム実行要求先スレーブ装置に送信するように、システムを構成すればよい。
サブプロセッサプログラムについては、前述のロードコマンドおよびキックコマンドを利用して他の情報処理装置に実行させることもできる。
機能プログラムの実行終了後、機能プログラムを実行したスレーブ装置内の情報処理コントローラに含まれるメインプロセッサ21は、終了通知をマスター装置1内の情報処理コントローラ11に含まれるメインプロセッサ21−1に送信するとともに、自装置の装置情報テーブルを更新する。マスター装置1内の情報処理コントローラ11に含まれるメインプロセッサ21−1は、その終了通知を受信して、機能プログラムを実行したスレーブ装置の装置情報テーブルを更新する。
マスター装置1内の情報処理コントローラ11に含まれるメインプロセッサ21−1は、自装置及び他装置の装置情報テーブルの参照結果から、当該の機能プログラムを実行することができる情報処理装置として、自身を選択する場合もあり得る。その場合には、マスター装置1が当該機能プログラムを実行する。
図7の例で、ユーザがスレーブ装置A(情報処理装置2)を操作し、当該操作に応じた機能プログラムを別のスレーブ装置B(情報処理装置3)が実行する場合について、図8を用いてその分散処理の例を説明する。
図8の例では、ユーザがスレーブ装置Aを操作することによって、スレーブ装置Aを含むネットワークシステム全体の分散処理が開始して、まず、スレーブ装置Aは、ステップ81で、その操作情報をマスター装置1に送信する。
マスター装置1は、ステップ72で、その操作情報を受信し、さらにステップ73に進んで、自装置のメインメモリ26−1に記録されている自装置及び他装置の装置情報テーブルから、各情報処理装置の動作状態を調べて、受信した操作情報に応じた機能プログラムを実行することができる情報処理装置を選択する。この例は、スレーブ装置Bが選択される場合である。
次に、マスター装置1は、ステップ74で、その選択したスレーブ装置Bに対して機能プログラムの実行を要求する。
スレーブ装置Bは、ステップ95で、その実行要求を受信し、さらにステップ96に進んで、実行要求された機能プログラムを実行する。
以上のように、ユーザは、1台の情報処理装置のみを操作することによって、他の情報処理装置を操作することなく、複数の情報処理装置1、2、3、4を仮想的な1台の情報処理装置7として動作させることができる。
次に、以上説明したネットワークシステムに、本発明を適用した場合の実施の形態について説明する。
上述のネットワークシステムにおいては、各情報処理装置はDMAコマンドがステータス要求コマンドであるソフトウェアセルを送信先IDで示される情報処理装置宛に送信し、当該情報処理装置からステータス返信コマンドの応答を受けることにより当該情報処理装置のプロセッサ動作周波数、プロセッサ使用率等の装置情報を取得し、当該装置情報を基に所定の処理(以下、ジョブという)を割り当てている。
しかし、多数の各情報処理装置が他の情報処理装置の装置情報を取得するためにソフトウェアセルを送受信すると、ネットワークに大量の通信トラフィックが発生して、システムの性能を低下させる可能性がある。そこで本実施形態においては、上記装置情報の取得に移動エージェントを用いることとしている。
図9は、本実施形態における分散処理システムの構成を示した図である。同図において、上記図7と同様の構成となる部分については同一の符号を付し、説明を省略する。
同図に示すように、本実施形態における分散処理システムは、例えば上記情報処理装置1、2及び3で構成され、ネットワーク9を介して相互に接続されている。ネットワーク9は例えばEthernet(登録商標)、Fibre Channel、IEEE1394等であり、バス型、ツリー型、リング型等様々なトポロジをとることができる。またネットワーク9は無線でも有線でも構わない。接続される情報処理装置の数も3台に限定されるものではない。
各情報処理装置は、上記図7等における各情報処理コントローラに加えて、それぞれエージェントプラットフォーム31、32及び33を有している。各エージェントプラットフォームは、各情報処理装置で実行されるプログラムであり、移動エージェントの生成・発信・移動及び実行手段をそれぞれ提供する。
また、上記図1の場合と同様、各情報処理装置の各情報処理コントローラは、上記メインプロセッサ、サブプロセッサ等をそれぞれ有し、上記DMAコマンド等によりソフトウェアセルを実行したり、各種データをやり取りしたりすることが可能である。よって、各情報処理装置には、それぞれを識別するための上記情報処理装置IDが付与されている。
図10は、本実施形態における移動エージェントを示した図である。同図に示すように、移動エージェント40は、電子署名41、探索条件42、生存時間43、移動範囲44、発信元ID45、エージェントID46、エージェントプログラム47及びデータ48で構成される。移動エージェント40は、各情報処理装置のエージェントプラットフォーム上で生成され、異なる情報処理装置の上記エージェントプラットフォーム間を移動して、滞在中のエージェントプラットフォーム上でエージェントプログラム47を実行することが可能である。
電子署名41は、移動エージェント40の発信元を確認したり、移動エージェントが改竄されていないか等を確認したりするために用いられる。上記エージェントプログラム47の実行前には当該電子署名41により移動先の情報処理装置内で認証が行われる。電子署名41は、例えばRSA公開鍵暗号方式、楕円曲線暗号方式、ElGamal暗号方式等の暗号方式を用いて、秘密鍵により特定の符号を暗号化することで作成される。同図においては、例えば発信元等を示すデータが「1E87A04F7B9C002D」という文字列に暗号化されている。
探索条件42は、上記移動エージェント40が探索する情報処理装置の条件を示しており、例えば各情報処理装置のプロセッサ動作周波数、各情報処理装置が複数のプロセッサ(サブプロセッサ)を有する場合には未使用(または使用)プロセッサ数をパラメータとする。同図においては、プロセッサ動作周波数が1GHz以上、未使用プロセッサ数が2以上、という探索条件を満たす情報処理装置が探索されることになる。
生存時間43は、上記移動エージェント40が本分散処理システム内で生存できる時間を示している。移動エージェント40は発信されてから当該生存時間43が経過すると消滅する。なお、移動エージェント40は、当該生存時間43に達した時に上記エージェントプログラム47が実行途中の場合には、当エージェントプログラム47の終了を待って消滅するようにしてもよい。同図においては、生存時間43は移動エージェント40が発信されてから120秒となっている。
当該生存時間43を設定することで、上記探索条件42を満たす情報処理装置を発見するまで移動エージェント40が延々とシステム内を移動し続けることによりネットワーク9に通信トラフィックが発生することを防ぐことができる。
移動範囲44は、上記移動エージェント40がネットワーク9上で移動することができる範囲を示している。当該移動範囲44は例えばIPアドレスの範囲で示され、同図においては、ネットワーク9においてIPアドレスが192.168.0.X(0≦X≦255)である情報処理装置までを移動範囲としている。
移動エージェント40は、一の情報処理装置に移動した後、次に移動する情報処理装置を決定する際に、前記移動範囲44を参照して、当該移動範囲44で与えられた範囲内の情報処理装置を適宜選択して移動する。分散処理システムにおいては、あまりにも距離が離れている情報処理装置にジョブを割り当てても、通信時間等の影響で効果的な分散処理を行うことができないが、上記移動範囲44を設定することで距離の近い情報処理装置の中から、ジョブを割り当て可能な情報処理装置を探索してジョブを実行させることができ、システムの稼動効率が低下することを防ぐことができる。また、移動エージェントが延々と移動し続けて通信トラフィックが生じることも防ぐことができる。
発信元ID45は、移動エージェント40を発信した情報処理装置を識別するためのIDであり、ネットワーク9に存在する全ての情報処理装置に対して付与される。当該発信元ID45は例えば同図に示すようにIPアドレスで表され、また情報処理装置が割り当てるジョブの発信元プロセスを識別するプロセス番号を含む。
移動エージェント40は、上記探索条件42を満たす情報処理装置を発見すると、当該発信元ID45に対応する発信元の情報処理装置に対して発見通知を送信する。なお、当該発信元IDは、上記電子署名41と併せて移動エージェント40の認証に用いられてもよい。同図においては、IPアドレスが192.168.0.1、プロセス番号が5となっている。
エージェントID46は、移動エージェント40が何の用途に用いられるものであるかを識別するために、発信元の情報処理装置において移動エージェント生成時に付与されるIDである。
移動エージェント40は、当該移動エージェント40の発信元の情報処理装置に上記発見通知を送信する際に、当該発見通知に当該エージェントID46を付加して送信する。移動エージェント40の発信元の情報処理装置は、当該エージェントID46を参照して、送信した移動エージェント40が何の用途に使うためのものであったかを判断する。例えば、エージェントID46は、情報処理装置が他の情報処理装置へ割り当てようとするジョブと関連付けられ、発見通知を受信した情報処理装置は当該エージェントIDに関連付けられたジョブを、移動エージェント40が発見通知を送信した滞在先の情報処理装置に対して送信する。
エージェントプログラム47は、移動エージェント40が滞在する情報処理装置の上記エージェントプラットフォーム上で実行されるプログラムであり、上記探索条件42を基に、上記プロセッサ動作周波数や未使用プロセッサ数等の当該滞在先の情報処理装置の装置情報を取得し、当該取得した情報から、滞在先の情報処理装置が探索条件42を満たすか否かを判断する。そして、探索条件42を満たすと判断した場合には、滞在先の情報処理装置の情報処理装置IDを発信元の情報処理装置に対して送信する。当該エージェントプログラム47の動作の詳細については後述する。
データ48は、上記エージェントプログラム47の実行状態の一部あるいは全部を記録したものである。移動エージェント40は、移動前の情報処理装置において上記実行状態の一部あるいは全部をデータ48として保持し、移動後の情報処理装置においてデータ48を参照して実行状態を復元する。
また、同図に示すように、データ48は、移動エージェント40の移動履歴49等、実行状態以外に移動エージェント40の活動に必要な情報を含んでいてもよい。移動履歴49は、移動エージェント40が発信後に滞在した情報処理装置の履歴であり、例えば情報処理装置のIPアドレスのリストで表される。また、移動履歴49は、移動エージェント40が滞在した情報処理装置の上記装置情報を含んでいてもよい。
次に、以上説明した移動エージェント40を用いた各情報処理装置の動作について説明する。
まず、移動エージェント40の発信元の情報処理装置の動作について説明する。図11は、情報処理装置が移動エージェント40を発信してから他の情報処理装置へジョブを送信するまでの動作の流れを示したフローチャートである。
同図に示すように、まず、情報処理装置は、例えばユーザから所定のジョブの実行を指示されると、自身のエージェントプラットフォーム上で移動エージェント40を生成し(ステップ51)、当該生成した移動エージェント40を他の情報処理装置のエージェントプラットフォームへ送信する(ステップ52)。この際、同一のエージェントIDを持つ複数の移動エージェントを生成して複数の情報処理装置へ発信するようにしてもよい。
続いて、情報処理装置は、所定の時間間隔で移動エージェント40を発信してからの経過時間を計測し、所定の制限時間を越えたか否かを確認する(ステップ53)。所定の制限時間を越えた場合(ステップ53のNO)には、例えば情報処理装置が有する表示部(図示せず)を介してユーザにエラーを通知し、他の情報処理装置へのジョブの割り当て処理を中止する。なお、この場合、再度移動エージェント40を生成及び発信して探索条件を満たす他の情報処理装置を探索するようにしてもよいし、分散処理を行わずに自身でジョブを実行するようにしてもよい。
制限時間を越えていない場合(ステップ53のYES)には、移動エージェント40から他の情報処理装置の発見通知が届いたか否かを確認する(ステップ54)。発見通知が届いていない場合(ステップ54のNO)には、届くまで確認処理を繰り返す。上記制限時間は例えば1分、3分等任意に設定することが可能である。また当該制限時間は厳密に守られなくてもよく、一定の幅を持たせるようにしても構わない。
移動エージェント40から発見通知が届いた場合(ステップ54のYES)には、当該発見通知に含まれるエージェントID及び自身のメインメモリ26−1等に記憶してある発見通知のログを参照し、既に同じエージェントIDの移動エージェント40から発見通知が届いていたか否かを確認する(ステップ55)。これは、複数の移動エージェント40を発信していた場合には、複数の発見通知が届く可能性があるためである。
同一のエージェントIDを有する発見通知が既に届いていた場合(ステップ55のYES)には、上記発見通知を送信した移動エージェント40に対して、その移動エージェント40が滞在している情報処理装置は分散処理に使用しない旨を応答し(ステップ57)、処理を終了する。まだ届いていない場合(ステップ55のNO)には、当該発見通知を送信した移動エージェント40に対して、当該移動エージェントが滞在している情報処理装置を分散処理に使用する旨を応答し(ステップ56)、実行させるためのジョブを当該滞在先の情報処理装置に対して送信する(ステップ58)。
上記ジョブは、例えば情報処理装置がハードディスクレコーダの場合にはテレビ番組の記録処理であり、上記動作により、移動エージェント発信元の情報処理装置と上記探索条件を満たす情報処理装置とが協働して番組記録処理を実行することになる。なお、当該番組記録処理の場合には、上記探索条件42としてHDDの空き容量を設定してもよい。
なお、本実施形態においては、移動エージェント40の発信元の情報処理装置が通常マスター装置として機能し、移動エージェント40の送信先の情報処理装置がスレーブ装置として機能する。
次に、他の情報処理装置のエージェントプラットフォームが、移動エージェント40を受信した場合の当該エージェントプラットフォームの動作について説明する。図12は、当該動作の流れを示したフローチャートである。
同図に示すように、エージェントプラットフォームは、ネットワーク9を介して送信された移動エージェント40を受信する(ステップ61)。続いて、当該移動エージェント40に含まれる電子署名41を、予め発信元の情報処理装置から与えられた暗号鍵(公開鍵)によって復号化し、得られた復号データと期待値とを比較することで移動エージェントの認証を行う(ステップ62)。復号データと期待値が一致すれば、移動エージェント40の発信元が正しい(信用できる)こと及び移動エージェントが通信途中に改竄されていないことが保証される。認証には、電子署名以外の情報、例えば発信元ID45や予め決められた鍵やパスワード等を併用してもよい。
上記認証により移動エージェント40の発信元が確認されると、エージェントプラットフォームは、当該発信元の情報処理装置からの移動エージェント40の受付が許可されているか否かを判定する(ステップ63)。受付を許可しない場合としては、例えばエージェントプラットフォームがある特定の他の情報処理装置とのみ分散処理を実行することが予め決められているような場合が考えられる。
移動エージェント40の受付を許可または禁止するために必要な発信元の情報処理装置に関する情報は、例えば発信元の情報処理装置の情報処理装置IDや、当該情報処理装置IDと、移動エージェント40を発信したエージェントプログラム47に固有な識別情報とを組み合わせた符号で表される。当該情報は例えば予め各情報処理装置に対して与えられ、各情報処理装置の外部記憶部等に格納されており、各情報処理装置のエージェントプラットフォームは当該情報を参照して上記判定を行う。
上記移動エージェント40が許可されていない発信元から発信されたものであった場合(ステップ63のNO)、エージェントプラットフォームは、当該移動エージェント40を破棄する(ステップ65)。具体的には、受信した移動エージェント40を格納していたメモリ領域を解放し、処理を終了する。
上記移動エージェント40が許可された発信元から発信されたものであった場合(ステップ63のYES)には、エージェントプラットフォームは、移動エージェント40の一部であるエージェントプログラム47を実行する(ステップ64)。当該エージェントプログラム47の実行により、当該移動エージェント40の滞在先の情報処理装置、すなわち当該エージェントプラットフォームを有する情報処理装置の装置情報が取得され、上記探索条件を満たすか否かの判定等が行われる。
次に、上記エージェントプログラム47が、移動エージェント40の滞在先のエージェントプラットフォーム上で実行する処理について説明する。図13は、当該処理の流れを示したフローチャートである。エージェントプログラム47はエージェントプラットフォームによって起動される。
まず、エージェントプログラム47は、滞在先の情報処理装置のプロセッサ動作周波数等の装置情報を取得し、当該装置情報と上記探索条件42とを比較することにより、当該探索条件42を満たすか否かを判定する(ステップ101)。当該装置情報の取得は、滞在先の情報処理装置が持つ装置情報ファイルを参照したり、エージェントプラットフォームが提供するサービスを利用したりすることにより行う。
探索条件を満たす場合(ステップ101のYES)、移動エージェント40の発信元の情報処理装置からジョブが送信されるまでの間に滞在先の情報処理装置の計算資源が使われないよう、予め定められた量の計算資源を予約し(ステップ102)、発信元の情報処理装置に対して発見通知を送信する(ステップ103)。なお計算資源の量は、上記探索条件42で設定された量としてもよい。
発信通知を送信すると、エージェントプログラム47は、当該滞在先の情報処理装置を分散処理に利用するか否かを示す、発信元の情報処理装置からの応答パケットを待つ(ステップ104)。このとき、一定時間応答パケットが届かない場合には、エージェントプログラム47は、上記計算資源の予約を解除し、処理を終了するようにしてもよい。
応答パケットを受信すると(ステップ104のYES)、応答パケットに含まれるデータの内容から、発信元の情報処理装置が、移動エージェント40の滞在先の情報処理装置を分散処理に利用するか否かを判定する(ステップ105)。利用しない場合(ステップ105のNO)には計算資源の予約を解除して終了し(ステップ106)、利用する場合(ステップ105のYES)には計算資源を予約したまま終了する。
滞在先の情報処理装置が上記探索条件42を満たさない場合には、エージェントプログラム47は、自身の生存時間43が経過したか否かを確認する(ステップ107)。経過していた場合(ステップ107のYES)には処理を終了し、経過してない場合(ステップ107のNO)には、次の情報処理装置へ移動するため、ネットワーク9の情報を取得する(ステップ108)。そして、当該取得した情報を基に、移動範囲44内で未到達の情報処理装置が有るか否かを確認し(ステップ109)、既に移動範囲44内の情報処理装置を全て移動していた場合(ステップ109のNO)には処理を終了する。
移動範囲内44で未到達の情報処理装置が存在する場合(ステップ109のYES)には、移動履歴49に次に移動する情報処理装置のIPアドレスを追加して(ステップ110)、当該次の情報処理装置に自身を送信する(ステップ111)。
次の移動先の情報処理装置のエージェントプラットフォーム上でも上記と同様の処理が行われる。
なお、上記移動範囲内か否かを判定する際には、上述したように各情報処理装置のIPアドレスを参照する。図14は、移動エージェント40の移動範囲の例を示した図である。
同図においては、移動エージェントは情報処理装置1から発信されており、IPアドレスの上位24bitが192.168.0(192.168.0.X、0≦X≦255)という条件が与えられているため、移動エージェントが情報処理装置1から移動できる範囲は、情報処理装置2及び3までである。従って、上記ステップ109において、まだ移動していない情報処理装置が、情報処理装置4や5のようにIPアドレスの上位24bitが192.168.0でない装置しかないことが確認された場合には、移動エージェント40はそれ以上移動することなく処理を終了する。
図15は、移動エージェント40が発信されてからジョブが実行されるまでに各情報処理装置間でやり取りされる情報の流れを示したシーケンス図である。同図においては、情報処理装置1が移動エージェント40を情報処理装置2へ送信した場合の情報処理装置1、2及び3における情報の流れを示している。また、情報処理装置2は情報処理装置1が設定した探索条件42を満たさず、情報処理装置3は当該探索条件を満たすものとする。
同図に示すように、まず、情報処理装置1のエージェントプラットフォーム31は、移動エージェント40を生成して、情報処理装置2へ発信する(ステップ121)。情報処理装置2のエージェントプラットフォーム32は移動エージェント40を受信して、認証後、エージェントプログラム47を実行する。エージェントプログラム47は、情報処理装置2の装置情報を取得して、探索条件42を満たすか否かを判定する。この場合情報処理装置2は探索条件42を満たさないため、エージェントプログラム47は移動先の情報処理装置を探す。この場合は上記移動範囲内の情報処理装置3が選択されたものとし、エージェントプログラム47は移動エージェント40を情報処理装置3へ送信する(ステップ122)。
情報処理装置3のエージェントプラットフォーム33は、移動エージェント40を受信し、認証後、エージェントプログラム47を実行する。エージェントプログラム47は、情報処理装置3の装置情報を取得して、探索条件42を満たすか否かを判定する。この場合情報処理装置3は探索条件42を満たすため、エージェントプログラム47は情報処理装置3の計算資源を予約し、情報処理装置1に対して発見通知を送信する(ステップ123)。
発見通知を受信した情報処理装置1は、情報処理装置3を分散処理に利用する旨を移動エージェント40へ応答する(ステップ124)。当該応答を受信した移動エージェント40は、上記計算資源を予約したまま消滅する。そして情報処理装置1は、情報処理装置3へジョブを送信する(ステップ125)。当該ジョブは上記DMAコマンドを含むソフトウェアセルにより送信される。例えば情報処理装置1、2及び3がハードディスクレコーダであった場合には、番組記録要求コマンドを含むソフトウェアセルが情報処理装置1から情報処理装置3へ送信される。
情報処理装置3へ送信されたジョブは分散処理システムの機構により情報処理装置3で実行され、その実行結果が情報処理装置1へ送信される(ステップ126)。当該実行結果もソフトウェアセルで送信され、例えば上記ハードディスクレコーダの場合には番組記録応答コマンドを含むソフトウェアセルが送信される。
以上説明したように、本実施形態によれば、各情報処理装置が生成及び発信した移動エージェント40が、自身に設定された探索条件42を基に、ジョブを実行可能な情報処理装置を自動的に探索して発信元の情報処理装置へ通知するため、各情報処理装置の装置情報を、通信トラフィックを生じさせること無く効率良く取得して、分散処理システムを円滑に稼動させることができる。
なお、本発明は、上述の実施形態にのみ限定されるものではなく、本発明の要旨を逸脱しない範囲内において種々変更を加え得ることは勿論である。
上述の実施形態においては、上記探索条件42としてプロセッサ動作周波数及び未使用プロセッサ数を指定し、また移動範囲44としてIPアドレスを指定していたが、探索条件42及び移動範囲44はこれらに限られるものではない。以下、本発明の他の実施形態について説明する。
図16は、本発明の他の実施形態における移動エージェント40を示した図である。同図に示すように、本実施形態においては、探索条件42として、プロセッサ使用率及び空きメモリ量を指定しており、例えばプロセッサ使用率が30%以下で、空きメモリ量が128MB以上の情報処理装置が探索される。
また、移動範囲44としては、移動エージェント40の発信元の情報処理装置から移動エージェント40の滞在先の情報処理装置までの間に存在する情報処理装置の数、及び発信元の情報処理装置までの通信時間が指定されている。
上記発信元の情報処理装置から移動エージェント40の滞在先の情報処理装置までの間に存在する情報処理装置の数は、例えばhop数で表すことができる。hop数とはパケットが宛先に到達するまでに経由する装置の数を示すもので、発信元から宛先に直接届く場合のhop数は1であり、"1hopで届く"のように表現する。同図の例では、発信元から3hopで届く範囲、すなわち発信元の情報処理装置から滞在先の情報処理装置までの間に存在する情報処理装置の数が3台である範囲が指定されている。
また上記発信元の情報処理御装置までの通信時間は、ICMPを用いることにより計測することができる。ICMPは、TCP/IPパケットの転送中において発生した各種のエラーの通知や、動作の確認(Echo検査)等を行なうために利用される制御用プロトコルである。同図の例では、発信元の情報処理装置までの通信時間が10msまでの範囲が指定されている。
図17は、本実施形態における移動エージェント40の移動範囲44の例を示した図である。同図に示すように、情報処理装置1から発信された移動エージェント40が移動できる範囲を判断する際には、まず情報処理装置1からのhop数を確認する。移動エージェント40が情報処理装置4に滞在する場合には、hop数は2であるため、hop数3という上記条件を満たすことになる。そして、もう一つの条件である通信時間を計測する。具体的には、移動エージェント40は、例えば情報処理装置4へ移動すると、上記ICMPのEcho要求を情報処理装置1へ送信し、情報処理装置1からEcho応答が返ってきた時間から通信時間を求めて、移動範囲内にあるか否かを確認する。仮に、移動エージェント40が情報処理装置4から送信したEcho要求及びそのEcho応答により、情報処理装置1との通信時間が20msであった場合には、上記10msという条件を満たさないため、移動エージェント40は情報処理装置2へ戻って、再度移動範囲内の情報処理装置を選択する(例えば情報処理装置3)。
次に、本実施形態におけるエージェントプログラム47の動作について説明する。図18は、当該動作の流れを示したフローチャートである。同図において、上記図13と同様の処理となる箇所については説明を省略または簡略化する。
まず、エージェントプログラム47は、ある情報処理装置に移動すると、上記hop数及び通信時間を計測して(ステップ201)、自身が移動範囲内にあるか否かを確認する(ステップ202)。移動範囲内に無かった場合(ステップ202のNO)には、エージェントプログラム47は実行を終了して、前に滞在していた情報処理装置へ戻り、他に移動範囲内の情報処理装置がある場合には当該情報処理装置へ移動し、無い場合には処理を終了する。
移動範囲内にあった場合(ステップ202のYES)には、上記プロセッサ使用率及び空きメモリ量の探索条件42を満たすか否かを判定し(ステップ203)、探索条件42を満たす場合(ステップ203のYES)には、上記図13のステップ102〜106と同様の処理が行われる(ステップ204〜208)。
探索条件42を満たさなかった場合(ステップ203のNO)には、自身の生存時間を確認し(ステップ209)、生存時間内である場合(ステップ209)には次に移動すべき情報処理装置を選択して当該選択された情報処理装置のIPアドレスを移動履歴49に追加して(ステップ210)、自身を当該選択された情報処理装置へ送信する。移動後は以上の処理が繰り返される。
なお、上記探索条件42としては、上述した以外にも、メモリの総容量、外部記憶部の容量、通信性能、情報処理装置が持つプログラム等、様々なパラメータを指定することができる。
また、本実施形態においては、上記移動範囲44は、上記hop数と通信時間とのAND条件を指定していたが、もちろんそれらのOR条件で指定するものであっても構わない。
上記実施形態においては、移動エージェントの認証は、移動エージェントを受信した情報処理装置のエージェントプラットフォームが行っていたが、例えばネットワーク9上に認証サーバを設けておき、移動エージェント40を受信した情報処理装置が当該認証サーバに電子署名41や発信元ID45を送信して、当該認証サーバから認証結果を受信することで実現しても構わない。
また、上記実施形態においては、移動エージェント40の受付許可/禁止の判定に必要な、発信元の情報処理装置に関する情報は、当該移動エージェントを受信した情報処理装置が予め保持していたが、特定の管理サーバをネットワーク9上に設けて、当該管理サーバから判定に必要な情報を取得するようにしてもよい。
更に、上記認証サーバと管理サーバとを組み合わせて、移動エージェント発信元の認証と移動エージェントの受付許可判定を認証管理サーバが行い、その結果をエージェントプラットフォームが受信するようにしても構わない。
本発明の一実施形態において前提となるシステムの構成を示した図である。 情報処理装置が備える情報処理コントローラの説明に供する図である。 ソフトウェアセルの一例を示す図である。 DMAコマンドがステータス返信コマンドである場合のソフトウェアセルのデータ領域を示す図である。 複数の情報処理装置が仮想的な1台の情報処理装置として動作する様子を示す図である。 情報処理コントローラのソフトウェア構成の一例を示す図である。 4台の情報処理装置が仮想的な1台の情報処理装置として動作する様子を示す図である。 図7のシステムにおける分散処理の例を示す図である。 本発明の一実施形態におけるシステムの構成を示した図である。 本発明の一実施形態における移動エージェントを示した図である。 情報処理装置が移動エージェント40を発信してから他の情報処理装置へジョブを送信するまでの動作の流れを示したフローチャートである。 移動エージェント40を受信したエージェントプラットフォームの動作の流れを示したフローチャートである。 エージェントプログラム47が滞在先のエージェントプラットフォーム上で実行する処理の流れを示したフローチャートである。 移動エージェント40の移動範囲の例を示した図である。 移動エージェント40が発信されてからジョブが実行されるまでに各情報処理装置間でやり取りされる情報の流れを示したシーケンス図である。 本発明の他の実施形態における移動エージェント40を示した図である。 本発明の他の実施形態における移動エージェント40の移動範囲の例を示した図である。 本発明の他の実施形態におけるエージェントプログラム47の処理の流れを示したフローチャートである。
符号の説明
1、2、3…情報処理装置
9…ネットワーク
40…移動エージェント
41…電子署名
42…探索条件
43…生存時間
44…移動範囲
45…発信元ID
46…エージェントID
47…エージェントプログラム
48…データ
49…移動履歴

Claims (20)

  1. ネットワークを介して接続された他の情報処理装置とともに所定の処理を実行することが可能な情報処理装置であって、
    当該情報処理装置及び前記他の情報処理装置の間を移動し、前記所定の処理を実行可能な前記他の情報処理装置を探索する移動エージェントを生成する生成手段と、
    前記生成された移動エージェントを前記他の情報処理装置へ送信する第1の送信手段と、
    前記送信された移動エージェントから、当該移動エージェントが探索した他の情報処理装置の探索結果の通知を受信する第1の受信手段と、
    前記受信された探索結果通知を基に、前記所定の処理を実行可能な他の情報処理装置へ当該所定の処理の実行命令を送信する第2の送信手段と
    を具備することを特徴とする情報処理装置。
  2. 請求項1に記載の情報処理装置であって、
    前記生成された移動エージェントに、前記所定の処理を実行可能な前記他の情報処理装置を探索するための探索条件を少なくとも設定する設定手段を更に具備し、
    前記移動エージェントは、前記探索条件を基に前記所定の処理を実行可能な他の情報処理装置を探索することを特徴とする情報処理装置。
  3. 請求項2に記載の情報処理装置であって、
    前記探索条件は、前記他の情報処理装置のプロセッサ使用率を基に設定されることを特徴とする情報処理装置。
  4. 請求項2に記載の情報処理装置であって、
    前記情報処理装置及び前記他の情報処理装置はそれぞれ複数のプロセッサを有し、
    前記探索条件は、前記他の情報処理装置の使用プロセッサ数を基に設定されることを特徴とする情報処理装置。
  5. 請求項2に記載の情報処理装置であって、
    前記探索条件は、前記他の情報処理装置のメモリ使用率を基に設定されることを特徴とする情報処理装置。
  6. 請求項1に記載の情報処理装置であって、
    前記設定手段は、前記移動エージェントが当該情報処理装置及び前記他の情報処理装置間を移動する際の移動範囲を更に設定し、
    前記移動エージェントは、前記設定された移動範囲内の他の情報処理装置へ移動することを特徴とする情報処理装置。
  7. 請求項6に記載の情報処理装置であって、
    前記移動範囲は、当該情報処理装置及び前記他の情報処理装置の前記ネットワークにおけるIPアドレスを基に設定されることを特徴とする情報処理装置。
  8. 請求項6に記載の情報処理装置であって、
    前記移動範囲は、当該情報処理装置と前記移動エージェントとの間に存在する前記他の情報処理装置の数を基に設定されることを特徴とする情報処理装置。
  9. 請求項6に記載の情報処理装置であって、
    前記移動範囲は、前記移動エージェントが要する当該情報処理装置との通信時間を基に設定されることを特徴とする情報処理装置。
  10. 請求項1に記載の情報処理装置であって、
    前記設定手段は、前記移動エージェントが生存する生存時間を更に設定し、
    前記移動エージェントは、前記送信された時から前記生存時間が経過したときに消滅することを特徴とする情報処理装置。
  11. 請求項1に記載の情報処理装置であって、
    前記移動エージェントは、前記他の情報処理装置の動作状態に関する情報を取得する手段と、前記取得した情報を基に、他の情報処理装置が前記探索条件を満たすか否かを判断する手段とを有することを特徴とする情報処理装置。
  12. 請求項11に記載の情報処理装置であって、
    前記移動エージェントは、前記他の情報処理装置が前記探索条件を満たす場合に、当該他の情報処理装置内で前記所定の処理を実行するための計算資源を予約する手段を更に有することを特徴とする情報処理装置。
  13. 請求項12に記載の情報処理装置であって、
    前記移動エージェントは、前記計算資源を予約してから所定時間経過したときに前記計算資源の予約を解除する手段を更に有することを特徴とする情報処理装置。
  14. 請求項12に記載の情報処理装置であって、
    当該情報処理装置及び前記他の情報処理装置は、それぞれの装置を識別するための識別情報を有し、
    前記探索結果通知は、前記所定の処理を実行可能な他の情報処理装置の識別情報であることを特徴とする情報処理装置。
  15. 請求項14に記載の情報処理装置であって、
    前記他の情報処理装置は前記ネットワーク上に複数存在し、
    前記第1の送信手段は、前記移動エージェントを前記複数の他の情報処理装置へそれぞれ送信し、
    前記第2の送信手段は、前記第1の受信手段により前記複数の他の情報処理装置の識別情報が受信された場合に、複数の他の情報処理装置のうち一の情報処理装置を選択して当該他の情報処理装置へ前記実行命令を送信し、
    当該情報処理装置は、前記第2の送信手段により選択されなかった他の情報処理装置に送信された前記移動エージェントに、前記計算資源の予約の解除を指示する手段を更に具備することを特徴とする情報処理装置。
  16. 請求項1に記載の情報処理装置であって、
    前記他の情報処理装置において生成及び送信された移動エージェントを受信する第2の受信手段と、
    前記受信された移動エージェントから前記他の情報処理装置へ送信された前記探索結果通知を基に前記他の情報処理装置から送信された前記所定の処理の実行命令を受信する第3の受信手段と、
    前記受信された実行命令を基に前記所定の処理を実行する実行手段と
    を更に具備することを特徴とする情報処理装置。
  17. 請求項16に記載の情報処理装置であって、
    前記他の情報処理装置から送信された移動エージェントを認証する手段と、
    前記認証手段により前記移動エージェントが認証されない場合に、前記移動エージェントを破棄する手段と
    を更に具備することを特徴とする情報処理装置。
  18. ネットワークを介して接続された第1及び第2の情報処理装置が所定の処理を分散して実行する分散処理システムであって、
    前記第1の情報処理装置は、
    前記分散処理システム内を移動し、前記所定の処理を実行可能な前記第2の情報処理装置を探索する移動エージェントを生成する手段と、
    前記生成された移動エージェントを前記第2の情報処理装置へ送信する手段と、
    前記送信された移動エージェントから、当該移動エージェントが探索した第2の情報処理装置の探索結果の通知を受信する手段と、
    前記受信された探索結果通知を基に、前記所定の処理を実行可能な第2の情報処理装置へ当該所定の処理の実行命令を送信する手段とを有し、
    前記第2の情報処理装置は、
    前記送信された移動エージェントを受信する手段と、
    前記第1の情報処理装置から前記所定の処理の実行命令を受信する手段と、
    前記受信された実行命令を基に前記所定の処理を実行する手段とを有する
    ことを特徴とする分散処理システム。
  19. 情報処理装置が、ネットワークを介して接続された他の情報処理装置とともに所定の処理を実行する方法であって、
    当該情報処理装置及び前記他の情報処理装置の間を移動し、前記所定の処理を実行可能な前記他の情報処理装置を探索する移動エージェントを生成するステップと、
    前記生成された移動エージェントを前記他の情報処理装置へ送信するステップと、
    前記送信された移動エージェントから、当該移動エージェントが探索した他の情報処理装置の探索結果の通知を受信するステップと、
    前記受信された探索結果通知を基に、前記所定の処理を実行可能な他の情報処理装置へ当該所定の処理の実行命令を送信するステップと
    を具備することを特徴とする分散処理方法。
  20. ネットワークを介して接続された他の情報処理装置とともに所定の処理を実行することが可能な情報処理装置に、
    当該情報処理装置及び前記他の情報処理装置の間を移動し、前記所定の処理を実行可能な前記他の情報処理装置を探索する移動エージェントを生成するステップと、
    前記生成された移動エージェントを前記他の情報処理装置へ送信するステップと、
    前記送信された移動エージェントから、当該移動エージェントが探索した他の情報処理装置の探索結果の通知を受信するステップと、
    前記受信された探索結果通知を基に、前記所定の処理を実行可能な他の情報処理装置へ当該所定の処理の実行命令を送信するステップと
    を実行させるためのプログラム。
JP2004226809A 2004-08-03 2004-08-03 情報処理装置、分散処理システム、分散処理方法及びそのプログラム Pending JP2006048290A (ja)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2004226809A JP2006048290A (ja) 2004-08-03 2004-08-03 情報処理装置、分散処理システム、分散処理方法及びそのプログラム

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2004226809A JP2006048290A (ja) 2004-08-03 2004-08-03 情報処理装置、分散処理システム、分散処理方法及びそのプログラム

Publications (1)

Publication Number Publication Date
JP2006048290A true JP2006048290A (ja) 2006-02-16

Family

ID=36026781

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2004226809A Pending JP2006048290A (ja) 2004-08-03 2004-08-03 情報処理装置、分散処理システム、分散処理方法及びそのプログラム

Country Status (1)

Country Link
JP (1) JP2006048290A (ja)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2010262533A (ja) * 2009-05-08 2010-11-18 Yahoo Japan Corp デバイス間でキャラクタが移動するデバイス及び通信システムの制御方法

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2010262533A (ja) * 2009-05-08 2010-11-18 Yahoo Japan Corp デバイス間でキャラクタが移動するデバイス及び通信システムの制御方法

Similar Documents

Publication Publication Date Title
CN100370450C (zh) 网络系统、分布式处理方法和信息处理装置
KR101186392B1 (ko) 분산형 메시 네트워크
JP4645049B2 (ja) コンテンツ送信装置およびコンテンツ送信方法
CN101420427B (zh) 密码加密模块选择设备
CN111625496B (zh) 分布式文件系统在虚拟机环境下的部署方法、装置及设备
JP2008512746A (ja) オペレーティングシステム独立エージェント
JP2006120121A (ja) 機器ネットワーク運用方法
JP2006323707A (ja) コンテンツ送信装置、コンテンツ受信装置、コンテンツ送信方法及びコンテンツ受信方法
JP4155341B2 (ja) 情報の管理方法及び情報処理装置
US8898312B2 (en) Element terminal and communication system
CN110324415B (zh) 一种对等网络的路由实现方法、装置、设备和介质
CN100465901C (zh) 网络系统、管理计算机以及集群管理方法
JP5949552B2 (ja) アクセス制御情報生成システム
JP5200424B2 (ja) 情報の管理方法及び情報処理装置
CN103559080B (zh) 移动设备上的后台应用代码的受约束执行
JP2006048290A (ja) 情報処理装置、分散処理システム、分散処理方法及びそのプログラム
JP2006033396A (ja) 送信装置、受信装置、通信システム、送信方法、受信方法、送信プログラム、受信プログラム及びサーバ装置
JP2010039661A (ja) サーバ負荷分散装置,方法およびプログラム
JP4349189B2 (ja) ネットワークシステム、番組録画予約方法および情報処理装置
JP2007158793A (ja) リモートアクセスシステム、リモートアクセス方法、接続管理サーバ、プログラム、および記録媒体
JP2005352909A (ja) 情報処理装置および方法、記録媒体、並びに予約処理プログラム
JP5673294B2 (ja) 通信管理装置
US9270530B1 (en) Managing imaging of multiple computing devices
JP2005339401A (ja) 情報処理装置及びその制御方法、情報処理コントローラ、情報処理ユニット及びその制御方法、並びにコンピュータプログラム
JP4412078B2 (ja) ネットワーク管理装置,中継装置,ネットワーク管理システム及びネットワーク管理プログラム

Legal Events

Date Code Title Description
RD04 Notification of resignation of power of attorney

Free format text: JAPANESE INTERMEDIATE CODE: A7424

Effective date: 20060424