[go: up one dir, main page]

JP7010272B2 - リアルタイム通信処理システム、およびリアルタイム通信処理方法 - Google Patents

リアルタイム通信処理システム、およびリアルタイム通信処理方法 Download PDF

Info

Publication number
JP7010272B2
JP7010272B2 JP2019185258A JP2019185258A JP7010272B2 JP 7010272 B2 JP7010272 B2 JP 7010272B2 JP 2019185258 A JP2019185258 A JP 2019185258A JP 2019185258 A JP2019185258 A JP 2019185258A JP 7010272 B2 JP7010272 B2 JP 7010272B2
Authority
JP
Japan
Prior art keywords
real
time communication
virtual machine
virtual
physical
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
JP2019185258A
Other languages
English (en)
Other versions
JP2021060858A (ja
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.)
Yokogawa Electric Corp
Original Assignee
Yokogawa Electric 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 Yokogawa Electric Corp filed Critical Yokogawa Electric Corp
Priority to JP2019185258A priority Critical patent/JP7010272B2/ja
Priority to CN202011065461.9A priority patent/CN112631714B/zh
Priority to US17/064,702 priority patent/US11556434B2/en
Publication of JP2021060858A publication Critical patent/JP2021060858A/ja
Application granted granted Critical
Publication of JP7010272B2 publication Critical patent/JP7010272B2/ja
Active legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Classifications

    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F11/00Error detection; Error correction; Monitoring
    • G06F11/07Responding to the occurrence of a fault, e.g. fault tolerance
    • G06F11/14Error detection or correction of the data by redundancy in operation
    • G06F11/1479Generic software techniques for error detection or fault masking
    • G06F11/1482Generic software techniques for error detection or fault masking by means of middleware or OS functionality
    • G06F11/1484Generic software techniques for error detection or fault masking by means of middleware or OS functionality involving virtual machines
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F11/00Error detection; Error correction; Monitoring
    • G06F11/30Monitoring
    • G06F11/34Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation ; Recording or statistical evaluation of user activity, e.g. usability assessment
    • G06F11/3409Recording or statistical evaluation of computer activity, e.g. of down time, of input/output operation ; Recording or statistical evaluation of user activity, e.g. usability assessment for performance assessment
    • GPHYSICS
    • G05CONTROLLING; REGULATING
    • G05BCONTROL OR REGULATING SYSTEMS IN GENERAL; FUNCTIONAL ELEMENTS OF SUCH SYSTEMS; MONITORING OR TESTING ARRANGEMENTS FOR SUCH SYSTEMS OR ELEMENTS
    • G05B19/00Programme-control systems
    • G05B19/02Programme-control systems electric
    • G05B19/418Total factory control, i.e. centrally controlling a plurality of machines, e.g. direct or distributed numerical control [DNC], flexible manufacturing systems [FMS], integrated manufacturing systems [IMS] or computer integrated manufacturing [CIM]
    • G05B19/4185Total factory control, i.e. centrally controlling a plurality of machines, e.g. direct or distributed numerical control [DNC], flexible manufacturing systems [FMS], integrated manufacturing systems [IMS] or computer integrated manufacturing [CIM] characterised by the network communication
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F11/00Error detection; Error correction; Monitoring
    • G06F11/07Responding to the occurrence of a fault, e.g. fault tolerance
    • G06F11/0703Error or fault processing not based on redundancy, i.e. by taking additional measures to deal with the error or fault not making use of redundancy in operation, in hardware, or in data representation
    • G06F11/0766Error or fault reporting or storing
    • G06F11/0772Means for error signaling, e.g. using interrupts, exception flags, dedicated error registers
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F11/00Error detection; Error correction; Monitoring
    • G06F11/07Responding to the occurrence of a fault, e.g. fault tolerance
    • G06F11/16Error detection or correction of the data by redundancy in hardware
    • G06F11/20Error detection or correction of the data by redundancy in hardware using active fault-masking, e.g. by switching out faulty elements or by switching in spare elements
    • G06F11/202Error detection or correction of the data by redundancy in hardware using active fault-masking, e.g. by switching out faulty elements or by switching in spare elements where processing functionality is redundant
    • G06F11/2023Failover techniques
    • G06F11/203Failover techniques using migration
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/44Arrangements for executing specific programs
    • G06F9/455Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
    • G06F9/45533Hypervisors; Virtual machine monitors
    • G06F9/45558Hypervisor-specific management and integration aspects
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/44Arrangements for executing specific programs
    • G06F9/455Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
    • G06F9/45533Hypervisors; Virtual machine monitors
    • G06F9/45558Hypervisor-specific management and integration aspects
    • G06F2009/4557Distribution of virtual machine instances; Migration and load balancing
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/44Arrangements for executing specific programs
    • G06F9/455Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
    • G06F9/45533Hypervisors; Virtual machine monitors
    • G06F9/45558Hypervisor-specific management and integration aspects
    • G06F2009/45591Monitoring or debugging support
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F9/00Arrangements for program control, e.g. control units
    • G06F9/06Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
    • G06F9/44Arrangements for executing specific programs
    • G06F9/455Emulation; Interpretation; Software simulation, e.g. virtualisation or emulation of application or operating system execution engines
    • G06F9/45533Hypervisors; Virtual machine monitors
    • G06F9/45558Hypervisor-specific management and integration aspects
    • G06F2009/45595Network integration; Enabling network access in virtual machine instances
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F2201/00Indexing scheme relating to error detection, to error correction, and to monitoring
    • G06F2201/81Threshold
    • GPHYSICS
    • G06COMPUTING; CALCULATING OR COUNTING
    • G06FELECTRIC DIGITAL DATA PROCESSING
    • G06F2201/00Indexing scheme relating to error detection, to error correction, and to monitoring
    • G06F2201/815Virtual

Landscapes

  • Engineering & Computer Science (AREA)
  • Theoretical Computer Science (AREA)
  • General Engineering & Computer Science (AREA)
  • Physics & Mathematics (AREA)
  • General Physics & Mathematics (AREA)
  • Software Systems (AREA)
  • Quality & Reliability (AREA)
  • Manufacturing & Machinery (AREA)
  • Automation & Control Theory (AREA)
  • Computer Hardware Design (AREA)
  • Hardware Redundancy (AREA)
  • Computer And Data Communications (AREA)

Description

本開示は、リアルタイム通信処理システム、およびリアルタイム通信処理方法に関する。
生産制御システムなどにおいては、特に通信のリアルタイム性が求められる。従来、イーサネット(登録商標)またはIP(インターネットプロトコル)などの標準的な通信技術を用いて、リアルタイム通信を行う方法が構築されている。
非特許文献1に記載の技術では、リアルタイム性を実現するために、送信局ごとに時間スロットを割り当てるなどによってパケット損失を防いでいる。また、非特許文献1に記載の技術では、例えば図4に示されるように、オープンな標準プロトコルを採用して、マルチベンダー機器によるネットワーク構成を可能としている。
出町公二,外3名,「リアルタイム・プラント・ネットワーク・システム Vnet/IP」,横河技報,Vol.49,No.2,2005年
プラントなどを制御するために構成するネットワークシステムにおいて、汎用製品を用いて、当該ネットワークシステムに属する機器を実現したいという要求がある。特に、リアルタイム性を確保しつつ、当該ネットワークシステムに属する機器に汎用製品を組み込むことにより、機器の低コスト化および供給の安定化を期待することができる。例えば、リアルタイム通信を行う通信処理装置としてコンピュータを用い、当該コンピュータ上で稼働するプログラムを制御するために、Linux(登録商標)などよりも汎用性の高いWindows(登録商標)などの汎用OS(オペレーティングシステム)を用いることが考えられる。
しかしながら、上述した通信処理装置に対して、同時並行的に稼働する複数のタスクに対する計算資源の割当てを行う汎用OSのスケジューラをそのまま適用すると、以下の問題が発生する。例えば、プラント制御のための処理を行うアプリケーション部と、当該アプリケーション部からの通信要求をリアルタイムに処理するリアルタイム通信部とを備える通信処理装置では、従来の汎用OSのスケジューラは、計算資源を適切に割り当てることができない場合がある。具体的には、汎用OSのスケジューラを用いた通信処理装置では、リアルタイム性を確保するために、リアルタイム通信部のタスクの優先度がアプリケーション部のタスクの優先度よりも高く設定される。しかしながら、一般に、汎用OSのスケジューラは、優先度が高いタスクのCPU使用率が所定の閾値を超えると、当該タスクには計算資源を与えず、当該タスクの優先度よりも優先度が低いタスクに計算資源を割り当てるというロジックで稼働する。このため、リアルタイム通信部は、充分な計算資源を用いて、アプリケーション部からの通信要求を処理することができず、結果として、リアルタイム性が損なわれるという問題が発生する。
そこで、本開示は、汎用OSのスケジューラを用いつつ、生産制御システムに必要なリアルタイム性を確保することが可能なリアルタイム通信処理システム、およびリアルタイム通信処理方法を提供することを目的とする。
幾つかの実施形態に係るリアルタイム通信処理システムは、複数のコンピュータと、各コンピュータと通信可能な管理装置とを備え、前記複数のコンピュータのうち少なくとも一つのコンピュータ上で少なくとも一つの仮想マシンが稼働する、生産制御システムにおけるリアルタイム通信処理システムであって、前記少なくとも一つのコンピュータは、当該コンピュータにおいて、リアルタイム通信処理に関して不安定動作発生の可能性がある仮想マシンが存在する場合、その旨の通知を前記管理装置に送信し、前記管理装置は、前記通知を送信した前記コンピュータの仮想プロセッサに空きがある場合、前記不安定動作発生の可能性がある前記仮想マシンに対して、前記仮想プロセッサを割り当てることを、前記通知を送信した前記コンピュータに指示し、前記通知を送信した前記コンピュータの仮想プロセッサに空きがない場合、前記不安定動作発生の可能性がある前記仮想マシンに対して、ライブマイグレーション可能な仮想マシンのライブマイグレーションを実行することにより前記通知を送信した前記コンピュータ内に確保した仮想プロセッサを割り当てることを、前記通知を送信した前記コンピュータに指示する。
このように、仮想プロセッサに空きがない場合であっても、ライブマイグレーションにより捻出した仮想プロセッサを不安定動作発生の可能性がある仮想マシンに割り当てるので、生産制御システムに必要なリアルタイム性を確保することができる。
一実施形態において、前記管理装置は、前記ライブマイグレーション可能な仮想マシンとして、稼働優先度が低い仮想マシンを選択してもよい。
このように、ライブマイグレーション可能な仮想マシンとして稼働優先度が低い仮想マシンが選択されるので、生産制御システムへの影響を抑えつつ、リアルタイム性を確保することができる。
一実施形態において、前記管理装置は、前記少なくとも一つのコンピュータ上で稼働する前記仮想マシンに対する前記仮想プロセッサの割り当て状況に基づいて、前記仮想マシンのライブマイグレーション先を決定してもよい。
このように、仮想プロセッサの割り当て状況に基づいてライブマイグレーション先を決定することにより、ライブマイグレーションの実行による生産制御システムへの影響をより抑制することができる。
一実施形態において、前記管理装置は、前記複数のコンピュータの処理性能に基づいて、前記仮想マシンのライブマイグレーション先を決定してもよい。
このように、複数のコンピュータの処理性能に基づいてライブマイグレーション先を決定することにより、ライブマイグレーションの実行による生産制御システムへの影響をより抑制することができる。
一実施形態において、前記管理装置は、前記複数のコンピュータの仮想資源量に基づいて、前記仮想マシンのライブマイグレーション先を決定してもよい。
このように、複数のコンピュータの仮想資源量に基づいてライブマイグレーション先を決定することにより、ライブマイグレーションの実行による生産制御システムへの影響をより抑制することができる。
一実施形態において、前記少なくとも一つのコンピュータは、前記リアルタイム通信処理に関する診断指標に基づいて、前記仮想マシンに不安定動作発生の可能性があるか否かを判断してもよい。
幾つかの実施形態に係るリアルタイム通信処理方法は、生産制御システムにおけるリアルタイム通信処理方法であって、少なくとも一つのコンピュータが、当該コンピュータにおいてリアルタイム通信処理に関して不安定動作発生の可能性がある仮想マシンが存在する場合、その旨の通知を管理装置に送信するステップと、前記管理装置が、前記通知を送信した前記コンピュータの仮想プロセッサに空きがある場合、前記不安定動作発生の可能性がある前記仮想マシンに対して、前記仮想プロセッサを割り当てることを、前記通知を送信した前記コンピュータに指示するステップと、前記管理装置が、前記通知を送信した前記コンピュータの仮想プロセッサに空きがない場合、前記不安定動作発生の可能性がある前記仮想マシンに対して、ライブマイグレーション可能な仮想マシンのライブマイグレーションを実行することにより前記通知を送信した前記コンピュータ内に確保した仮想プロセッサを割り当てることを、前記通知を送信した前記コンピュータに指示するステップと、を含む。
このように、仮想プロセッサに空きがない場合であっても、ライブマイグレーションにより捻出した仮想プロセッサを不安定動作発生の可能性がある仮想マシンに割り当てるので、生産制御システムに必要なリアルタイム性を確保することができる。
本開示によれば、汎用OSのスケジューラを用いつつ、生産制御システムに必要なリアルタイム性を確保することが可能なリアルタイム通信処理システム、およびリアルタイム通信処理方法を提供することができる。
比較例に係る通信処理装置の構成を示す機能ブロック図である。 図1のリアルタイム通信部インタフェースの処理手順を示すフローチャートである。 図1のリアルタイム通信部の処理手順を示すフローチャートである。 本開示の一実施形態に係るリアルタイム通信処理システムの構成を示す機能ブロック図である。 図4の各物理PCの構成を詳細に示す機能ブロック図である。 稼働優先順位テーブルを説明する図である。 図4のリアルタイム通信処理システムの処理手順を示すフローチャートである。 図7のステップS140の処理内容を詳細に示すフローチャートである。
以下、本開示を実施するための形態について、図面を参照しながら説明する。各図において、同一符号は、同一または同等の構成要素を示す。
まず比較のために、図1を参照して、比較例に係る通信処理装置4の構成例を説明する。
図1に示すとおり、通信処理装置4は、ハードウェアであるコンピュータ(物理PC)11上で構成される。物理PC11は、物理プロセッサ111と、物理NIC112と、物理NIC IF113とを含む。また、物理PC11は、例えば半導体または磁気記録媒体などを用いて実現されるメモリなどの他の構成要素を含んでもよい。物理PC11は、物理NIC112を介して、制御ネットワーク20に接続される。なお、制御ネットワーク20は、生産制御システムを構成する機器間で通信を行うためのネットワークであり、制御ネットワーク20には、コントローラ21およびPC22などの機器が接続される。PC22は、例えば、制御ネットワーク20を介して、コントローラ21などと通信を行うことができる。コントローラ21は、複数のフィールド機器23が接続され、フィールド機器23をコントロールすることにより、プラントの制御を行う。フィールド機器23は、例えば、流量計、温度計、湿度計、もしくは圧力計などのセンサ、またはバルブ、ポンプ、もしくはアクチュエータなどの機器である。なお、PCは、「パーソナルコンピュータ」の略である。NICは、「ネットワークインタフェースカード」の略である。NICは、単に「ネットワークカード」と呼ばれる場合もある。また、「IF」は、「インタフェース」の略である。
物理プロセッサ111は、メモリにロードされたプログラムに含まれる命令を逐次フェッチして実行する。物理プロセッサとして、例えば物理CPUが挙げられ、当該物理CPUに含まれるコアの個数は任意である。なお、CPUは、「中央処理装置(Central Processing Unit)」の略である。また、物理PC11が複数の物理プロセッサ111を備えてもよい。なお、物理プロセッサ111のCPU時間は、後述するユーザ空間内の各機能に割り当てられる。
物理NIC112は、物理PC11に接続される制御ネットワーク20を介して、外部の機器と通信するためのインタフェース機能を有する。物理NIC112は、汎用NICであってよい。
物理NIC IF113は、物理PC11上のプログラムなどと物理NIC112との間のインタフェースを提供する。
物理PC11上では、汎用OS19が稼働する。汎用OS19は、ユーザ空間14と、カーネル空間16とを有する。OSは、「オペレーティングシステム」の略である。汎用OS19を用いて通信処理装置4を構成することにより、通信処理装置4を低コスト化し、かつ安定的に供給することが可能となる。汎用OS19としては、例えばマイクロソフト社(Microsoft Corporation,米国)のPC用OSであるWindows(登録商標)系のOSが挙げられる。
カーネル空間16には、汎用OSスケジューラ161と、リアルタイム通信要求共有メモリ162とが存在する。また、カーネル空間16には、ユーザ空間14内で稼働するタスク間で共有する情報がある場合に適宜用いられる共有メモリが存在してもよい。
汎用OSスケジューラ161は、ユーザ空間14内において同時並列的に稼働する各機能(タスク、プログラム)の優先度に従って、適宜、計算資源を割当て、各機能の稼働を管理する。ここで、計算資源は、典型的にはCPU時間(CPU資源)であるが、CPU時間以外のものを含んでもよい。計算資源は、例えば、割り当てられるメモリまたは入出力処理手段などを含む。汎用OSスケジューラ161は、リアルタイムスケジューラではない。なお、同図では1つのユーザ空間14のみを示しているが、汎用OSスケジューラ161は、複数のユーザ空間を管理してもよい。
リアルタイム通信要求共有メモリ162は、ユーザ空間14内で稼働するすべてのタスクからアクセス可能なメモリである。後述するリアルタイム通信要求処理共有ライブラリ142が、アプリケーション部141-1、141-2、・・・からの通信要求などを一時的に記憶するバッファは、このリアルタイム通信要求共有メモリ162内に設けられる。なお、リアルタイム通信要求共有メモリ162は、ユーザ空間14の外に設けられており、アプリケーション部141-1、141-2、・・・のメモリ空間内の所定の場所にマッピングされる。これにより、アプリケーション部141-1、141-2、・・・はリアルタイム通信要求共有メモリ162にアクセスすることができる。
ユーザ空間14には、アプリケーション部141-1、141-2、・・・(以下、「アプリケーション部141」と略記する場合がある。)と、リアルタイム通信要求処理共有ライブラリ142と、リアルタイム通信API共有ライブラリ143と、リアルタイム通信部191とが存在する。APIは、「アプリケーションプログラミングインタフェース」の略である。アプリケーション部141、リアルタイム通信要求処理共有ライブラリ142、リアルタイム通信API共有ライブラリ143、およびリアルタイム通信部191は、プログラムおよびメモリを用いて実現可能である。プログラムは、汎用OSスケジューラ161によって適宜割り当てられる物理プロセッサ111によって実行される。また、メモリは、例えば半導体または磁気記録媒体などを用いて実現される。なお、ユーザ空間14で実行される機能は、必ずしもメモリを利用しない場合もある。また、情報を記憶するのみであって、処理を実行しない機能は、プログラムを利用する必要はない。
アプリケーション部141は、例えばプラントおよび機器の制御のための処理を行う。アプリケーション部141は、例えば、プラントの測定データの表示およびプラントに対する操作が行えるHMI(ヒューマンマシンインタフェエース)、プラントを制御するコントローラの制御プログラムが作成されるENG(エンジニアリングサーバ)、ゲートウェイ、並びにプラントの制御を行うコントローラなどのアプリケーションに関するソフトウェアを稼働させる。複数のアプリケーション部141が同時並行的に稼働してもよい。アプリケーション部141は、通信要求を、複数のアプリケーション部141によって共有されるリアルタイム通信要求共有メモリ162に一旦格納する。その後、アプリケーション部141は、リアルタイム通信要求共有メモリ162から取り出した通信要求をリアルタイム通信部191に渡す。アプリケーション部141がリアルタイム通信部191に対して行う通信要求は、論理的な通信路の確立もしくは解放、またはフレーム(パケットとも呼ぶ。データ送受信の論理的な単位である。)の送信もしくは受信などである。なお、ユーザ空間14内で稼働するアプリケーションソフトウェアの数は任意である。
アプリケーション部141には、リアルタイム通信要求処理共有ライブラリ142およびリアルタイム通信API共有ライブラリ143が有するライブラリ関数の機能が組み込まれている。リアルタイム通信要求処理共有ライブラリ142と、リアルタイム通信API共有ライブラリ143との機能は、アプリケーションロジックに適宜連係される。
リアルタイム通信要求処理共有ライブラリ142は、アプリケーション部141に静的にリンクされていてもよく、独立したタスクとして稼働してもよい。リアルタイム通信要求処理共有ライブラリ142は、リアルタイム通信要求受付ロジックと、リアルタイム通信送信ロジックと、リアルタイム通信受信ロジックとの機能を備える。
リアルタイム通信要求受付ロジックは、アプリケーション部141の各々のアプリケーションロジックから、リアルタイム通信API共有ライブラリ143を経由して届く通信要求を受け付ける。当該リアルタイム通信要求受付ロジックは、受け付けた要求を集約し、送信要求の優先度に従って、要求(例えば送信要求)に付随する送信フレームなどをバッファに書き込む。これにより、各アプリケーション部141からの通信要求をその優先度で整理した上で、リアルタイム通信部191に要求することができる。当該バッファは、リアルタイム通信要求共有メモリ162内に存在する。リアルタイム通信要求受付ロジックは、送信フレームをリアルタイム通信要求共有メモリ162内のバッファに格納した場合には、後述するリアルタイム通信送信ロジックにその旨を通知する。
リアルタイム通信送信ロジックは、リアルタイム通信要求受付ロジックからの通知を受けると、リアルタイム通信要求共有メモリ内のバッファから送信フレームを取り出し、リアルタイム通信部191に渡す。具体的には、当該リアルタイム通信送信ロジックは、リアルタイム通信部191内のリアルタイム通信部インタフェース192に含まれる要求バッファ197に送信フレームを書き込むことによって、送信を行う。
リアルタイム通信受信ロジックは、リアルタイム通信部191に含まれるリアルタイム通信通知部193から受信通知を受けると、外部から受信されたフレームを受け取り、リアルタイム通信要求共有メモリ162内のバッファに書き込む。また、当該リアルタイム通信受信ロジックは、リアルタイム通信要求受付ロジックにフレームを受信した旨を通知する。リアルタイム通信要求受付ロジックは、リアルタイム通信受信ロジックからの通知に基づいて、リアルタイム通信要求共有メモリ162内のバッファから受信フレームを取り出し、受信要求を発行していたアプリケーション部141にその受信フレームを返す。
リアルタイム通信API共有ライブラリ143は、アプリケーション部141がリアルタイム通信を行うためのAPIを含む共有ライブラリである。アプリケーション部141は、リアルタイム通信API共有ライブラリ143の機能を静的にリンクさせてもよく、実行時に、リアルタイム通信API共有ライブラリ143の機能を動的にリンクさせてもよい。
リアルタイム通信部191は、アプリケーション部141からの通信要求に基づいて、リアルタイムにデータの送受信を行う。リアルタイム通信部191が行う処理の性質上、コントローラ21またはPC22と、フレームの送受信などのタイミングを合わせる必要があり、リアルタイム性が要求される。ここで、「リアルタイム性」とは、リアルタイム通信部191がコントローラ21またはPC22に対して行った通信要求が所定時間内に完結すること、あるいは所定時間内に通信要求が完了しない場合であっても、当該所定時間内にリアルタイム通信部191にレスポンスが戻ることを意味する。レスポンスとしては、例えばエラーなどの通知を含む。「所定時間」は、適用分野によって異なるが、例えば、数ミリ秒から数百ミリ秒までといった範囲内の時間である。なお、リアルタイム通信部191のタスクの優先度は、アプリケーション部141のタスクの優先度よりも高く設定される。以下、リアルタイム通信部191を詳細に説明する。
リアルタイム通信部191は、リアルタイム通信部インタフェース192と、リアルタイム通信通知部193と、送信バッファ194と、自己診断部195と、自己診断指標記憶部196とを含む。また、リアルタイム通信部インタフェース192は、要求バッファ197を含む。
要求バッファ197は、アプリケーション部141からの通信要求を少なくとも一時的に蓄積する。アプリケーション部141からの通信要求は、リアルタイム通信要求処理共有ライブラリ142およびリアルタイム通信API共有ライブラリ143を介して要求バッファ197に蓄積される。要求バッファ197に蓄積された通信要求は、リアルタイム通信部インタフェース192によって取り出され、送信バッファ194に格納される。なお、要求バッファ197は、基本的にFIFO(先入れ先出し)であるが、通信要求の優先度などに基づいて処理順序の追い越しが発生してもよい。
送信バッファ194は、リアルタイム通信部インタフェース192からの通信要求を少なくとも一時的に蓄積する。送信バッファ194に蓄積された通信要求は、順次送信される。なお、送信バッファ194は、基本的にFIFOであるが、通信要求の優先度などに基づいて処理順序の追い越しが発生してもよい。
リアルタイム通信部インタフェース192は、リアルタイム通信要求処理共有ライブラリ142およびリアルタイム通信API共有ライブラリ143を介して、アプリケーション部141からの通信要求を受け付けたり、当該通信要求に対する応答をアプリケーション部141に返したりする。具体的には、通信要求が送信要求である場合、リアルタイム通信部インタフェース192は、アプリケーション部141からの通信要求を要求バッファ197に一時的に蓄積し、当該通信要求を要求バッファ197から取り出し、送信バッファ194に格納することによって、送信処理を行う。また、リアルタイム通信部インタフェース192は、後述する自己診断部195から不安定動作発生の可能性がある旨の通知を受けた場合には、要求バッファ197から送信要求を取り出す際に指定時間の待ち(WAIT)を行う。つまり、リアルタイム通信部インタフェース192は、要求バッファ197に蓄積された送信要求が、送信バッファ194に過大に流入しないように制御する。したがって、要求バッファ197が大量に送信要求を受信しても、リアルタイム通信部インタフェース192は、その都度これらの送信要求を処理しない。これにより、リアルタイム通信部191に不安定動作発生の可能性があっても、リアルタイム通信部インタフェース192は、当該不安定動作発生の可能性を緩和させることが可能となる。なお、当該指定時間は予め定めておくことができる。「指定時間」は、適用分野によって異なるが、例えば、数ミリ秒から数百ミリ秒までといった範囲内の時間である。
自己診断部195は、リアルタイム通信部191の処理に関する診断指標を検知し、当該診断指標の値が所定の閾値を超えた場合、リアルタイム通信部191に不安定動作発生の可能性があると判断して、その旨をリアルタイム通信部インタフェース192に通知する。「診断指標」は、例えば、CPU使用率または処理応答時間である。なお、自己診断部195は、当該診断指標を検知するにあたり、自己診断指標記憶部196を参照する。
自己診断指標記憶部196は、上述した診断指標と、当該診断指標の閾値とのペアを、複数組記憶する。例えば、自己診断指標記憶部196は、リアルタイム通信部191のCPU使用率の閾値、処理応答時間(例えば送信フレームのリトライ回数)の閾値、またはその他の閾値を記憶する。なお、これらの閾値は、外部から設定することもできる。
リアルタイム通信通知部193は、リアルタイム通信要求処理共有ライブラリ142に対して通知を行う。具体的には、リアルタイム通信通知部193は、一定の周期の時間通知をリアルタイム通信要求処理共有ライブラリ142に対して行う。リアルタイム通信要求処理共有ライブラリ142内のリアルタイム通信送信要求処理ロジックは、時間通知ごとに起床し、フレームを送信する処理がタイムアウトしているか否かを確認する。フレームの送信処理のタイムアウトは、例えばリアルタイム通信部191が送信先の外部機器からの肯定応答が返送されないなどによって、リアルタイム通信要求処理共有ライブラリ142に対して受信通知を用いた送信完了通知を行わないまま予め定められた時間が経過した場合に発生する。リアルタイム通信通知部193が送信タイムアウトに関する時間通知を行うことにより、リアルタイム通信部インタフェース192に対してフレームの再送を指示することができる。また、リアルタイム通信通知部193は、外部機器から通信処理装置に向けて送信されたフレームを受信すると、リアルタイム通信要求処理共有ライブラリ142内のリアルタイム通信要求受付ロジックおよびリアルタイム通信受信処理ロジックに受信通知を行う。これにより、リアルタイム通信要求処理共有ライブラリ142内のリアルタイム通信受信処理ロジックは、受信したフレームを取り出すことができる。
次に、通信処理装置4の各機能の処理手順について説明する。図2は、リアルタイム通信部インタフェース192の動作手順を示すフローチャートである。
まず、ステップS11において、リアルタイム通信部インタフェース192は、自己診断部195から不安定動作発生の可能性がある旨の通知があったか否かを判断する。不安定動作発生の可能性がある旨の通知があった場合(ステップS11:YES)、ステップS12に進む。不安定動作発生の可能性がある旨の通知がなかった場合(ステップS11:NO)、ステップS13に進む。
ステップS12に進んだ場合、ステップS12において、リアルタイム通信部インタフェース192は、指定時間分のWAITを行う。このWAITにより、リアルタイム通信部インタフェース192は、ステップS14に移る前に当該指定時間だけ待つ。リアルタイム通信部インタフェース192がステップS12において待つ間、計算資源がリアルタイム通信部191内の他の処理およびアプリケーション部141の処理に割り当てられる。このため、WAITがない状態と比較して、リアルタイム通信部191の処理負荷が低減される。リアルタイム通信部インタフェース192が待ち始めてから当該指定時間が経過すると、再びリアルタイム通信部インタフェース192に計算資源が割り当てられ、ステップS14に進む。なお、上述した計算資源の割り当ては、汎用OSスケジューラ161が行う。
ステップS13に進んだ場合、ステップS13において、リアルタイム通信部インタフェース192は、指定時間を初期値にリセットする。ステップS13の処理が終了すると、ステップS14に進む。
次に、ステップS14において、リアルタイム通信部インタフェース192は、アプリケーション部141から要求された送信フレームがあるか否かを判断する。具体的には、リアルタイム通信部インタフェース192は、要求バッファ197を参照することにより、送信フレームがあるか否かを判断する。送信フレームがある場合(ステップS14:YES)、ステップS15に進む。送信フレームがない場合(ステップS14:NO)、ステップS17に進む。
ステップS15に進んだ場合、ステップS15において、リアルタイム通信部インタフェース192は、要求バッファ197から1つの送信フレームを取り出す。ただし、複数の送信フレームをまとめて取り出して送信できる場合、リアルタイム通信部インタフェース192は、予め定められた所定数以下の送信フレームを要求バッファ197から取り出す。なお、要求バッファ197内の送信フレームは、送信バッファへの転送が成功した後に適宜削除される。
次に、ステップS16において、リアルタイム通信部インタフェース192は、ステップS15で取り出した送信フレームを、送信バッファ194に格納する。なお、送信バッファ194に格納された送信フレームは、リアルタイム通信部191によって順次送信される。これについては、図3を参照して後述する。
次に、ステップS17において、リアルタイム通信部インタフェース192は、リアルタイム通信を終了するか否かを判断する。リアルタイム通信を終了するのは、例えば、通信処理装置4における上位の管理機能から終了を指示された場合、オペレータなどから終了コマンドが入力された場合、またはエラー事象などによる割込みを解析した結果として終了すべきと判断される場合などである。リアルタイム通信を終了させる場合(ステップS17:YES)、本処理が終了する。リアルタイム通信を終了させない場合(ステップS17:NO)、ステップS11に戻って、上述した処理を繰り返す。
図3は、リアルタイム通信部191の動作手順を示すフローチャートである。
まず、ステップS21において、リアルタイム通信部191は、送信バッファ194に送信フレームがあるか否かを判断する。送信フレームがある場合(ステップS21:YES)、ステップS22に進む。送信フレームがない場合(ステップS21:NO)、ステップS26に飛ぶ。
ステップS22に進んだ場合、ステップS22において、リアルタイム通信部191は、送信バッファ194から1つの送信フレームを取り出し、当該フレームを送信する。ただし、複数の送信フレームをまとめて取り出して送信できる場合、リアルタイム通信部191は、予め定められた所定数以下の送信フレームを送信バッファ194から取り出して、これらのフレームを送信する。
続いて、ステップS23において、リアルタイム通信部191は、ステップS22においてフレームを送信した相手(フレームの受信側)からの肯定応答(Ack,acknowledgement)が到着するのを所定時間待つ。
続いて、ステップS24において、リアルタイム通信部191は、肯定応答が到着したか否かを判断する。肯定応答が到着した場合(ステップS24:YES)、つまり、そのフレームが相手側で受信されたことが確認された場合、ステップS25に進む。肯定応答が到着しなかった場合(ステップS24:NO)、つまり、送信したフレームに対応する否定応答が到着した場合、または所定時間が経過してタイムアウトした場合、ステップS26に飛ぶ。
ステップS25に進んだ場合、ステップS25において、リアルタイム通信部191は、送信が成功したフレーム、つまり肯定応答が得られた送信フレームを、送信バッファ194から消去する。なお、一定の処理回数の間に肯定応答が到着しなかった場合、リアルタイム通信部191は、送信先が通信できない状況にあると判断してもよい。この場合、リアルタイム通信部191は、送信バッファ194から送信フレームを消去し、送信を失敗させてもよい。
続いて、ステップS26において、リアルタイム通信部191は、リアルタイム通信部191自身の処理(リアルタイム通信)を終了するか否かを判断する。リアルタイム通信部191の処理を終了する状況とは、図2のステップS17の処理について説明したとおりである。リアルタイム通信を終了させる場合(ステップS26:YES)には、本フローチャート全体の処理を終了する。リアルタイム通信を終了させない場合(ステップS26:NO)には、ステップS21に戻って、上述した処理を繰り返す。
このように、比較例に係る通信処理装置4では、不安定動作発生の可能性がある場合、リアルタイム通信部インタフェース192は、要求バッファ197から送信要求を取り出す際にWAITを行うことにより、要求バッファ197に蓄積された送信要求が送信バッファ194に過大に流入しないように制御する。しかしながら、このような制御を行う通信処理装置4では、以下に説明するように、本来処理したいデータ量を処理することができず、例えば単位時間あたりのデータ送信量などのアプリケーションの処理性能が低下するという問題がある。
一般に、通信処理装置における全体の処理負荷は、下記(1)式にて算出される。
全体の処理負荷=(プロセスが使用する各プロセッサの処理負荷の合計値)/(全プロセッサの最大負荷の合計値)・・・(1)
ここで、プロセッサの全数が2つであり、1つのプロセッサにおいて処理可能な最大負荷が100%であり、各プロセッサの処理負荷が70%と50%であり、汎用OSスケジューラがプロセスの処理を止める処理負荷の閾値が50%である場合を具体例として説明する。この場合、上記(1)式にて算出される全体の処理負荷は60%(=(70+50)/(100+100))となる。このため、全体の処理負荷(60%)は、処理負荷の閾値(50%)を超えるので、リアルタイム性を確保することができない。この対策として、比較例に係る通信処理装置4では、全体の処理負荷が処理負荷の閾値を超えないように、例えばWAITを行うことにより、各プロセッサの処理負荷を低減している。より具体的には、比較例に係る通信処理装置4において、WAITを行うことにより低減した後の各プロセッサの処理負荷をそれぞれ40%とする。すると、上記(1)式にて算出される全体の処理負荷は、40%(=(40+40)/(100+100))となり、処理負荷の閾値で(50%)より小さくなる。しかしながら、プロセスが実際に使用するプロセッサの処理負荷の合計値は、120%(=70%+50%)から80%(=40%+40%)に低下してしまう。このため、比較例に係る通信処理装置4では、本来処理したいデータ量を処理することができず、例えば単位時間あたりのデータ送信量などのアプリケーションの処理性能が低下するという問題が生じる。
この問題に対して、物理PC上で仮想マシンを稼働させて、仮想マシンの処理負荷が所定の閾値を超えた場合に、当該仮想マシンに仮想プロセッサを割り当てることにより、アプリケーションソフトウェアの処理性能を維持しつつ、リアルタイム性を確保するという対応が考えられる。上述した具体例において、仮想プロセッサを1つ追加すると、仮想マシン全体の処理負荷は、以下となる。
仮想マシン全体の処理負荷=(70+50)/(100+100+100)
=120/300
=40%
つまり、仮想マシンに仮想プロセッサを割り当てることにより、プロセスが使用するプロセッサの処理負荷の合計値は120%(=70%+50%)を維持した状態で、仮想マシン全体の処理負荷を相対的に40%に下げることができる。このため、アプリケーションの処理性能を維持した状態で、リアルタイム性を確保することが可能となる。しかしながら、全ての仮想プロセッサが割り当て済みのため、仮想プロセッサに空きがない場合には、リアルタイム性を確保することができないという問題が残る。
そこで、本開示では、汎用OSのスケジューラを用いつつ、生産制御システムに必要なリアルタイム性を確保することができるリアルタイム通信処理システム、およびリアルタイム通信処理方法について説明する。加えて、本開示では、仮想プロセッサに空きがない場合であっても、生産制御システムに必要なリアルタイム性を確保することができるリアルタイム通信処理システム、およびリアルタイム通信処理方法について説明する。
以下、図4および図5を参照して、本開示の一実施形態に係るリアルタイム通信処理システム1について説明する。
図4を参照して、各コンピュータ(物理PC)11-1、11-2、11-3・・・(以下、「物理PC11」と略記する場合がある。)は、それぞれ仮想化されている。図5も参照して、各物理PC11は仮想化部12を有し、物理PC11上ではホストOSが稼働する。また、複数の物理PC11のうち少なくとも一つの物理PCでは、上述したホストOS上で少なくとも一つの仮想マシンが稼働する。なお、ホストOSとしては、汎用OSを適用することができる。汎用OSとしては、例えばマイクロソフト社(Microsoft Corporation,米国)のPC用OSであるWindows(登録商標)系のOSが挙げられる。なお、物理PC11の数は、図4に示す例に限定されず、任意である。また、後述する不安定動作が発生する物理PC11上では、複数の仮想マシンが稼働してもよいが、ライブマイグレーション先の物理PC11上では、必ずしも複数の仮想マシンが稼働する必要はない。
図5を参照して、仮想化部12は、仮想化部スケジューラ121と仮想ハードウェア122とを含み、仮想化技術によって実現される複数の仮想マシンの動作を制御する。詳細は後述するが、仮想化部12は、管理装置(例えば、NMS(Network Management System))17(以下、「NMS17」と略記する場合がある。)の通信部172から受けたコマンドを実行することにより、仮想資源の変更を行う。「仮想資源の変更」には、例えば、仮想マシンへの仮想プロセッサ123の割り当てもしくは仮想マシンからの仮想プロセッサ123の削除、または仮想マシンの停止もしくは再開などが含まれる。ここで、仮想資源の変更は、仮想マシンの稼働中に行ってもよく、この場合、仮想マシン上で稼働するゲストOS13には、仮想マシンの稼働中に仮想資源の変更が反映される。
仮想化部スケジューラ121は、物理プロセッサ111と仮想プロセッサ123とを1対1に適宜対応付ける。したがって、仮想プロセッサ123に空きがあるとは、物理PC11に含まれる物理プロセッサ111に空きがあること、または仮想ハードウェア122に含まれる仮想プロセッサ123に空きがあることを意味する。一例として、仮想化部スケジューラ121は、物理CPUに含まれるコアと仮想CPUコアとを1対1に対応付ける。なお、物理CPUに含まれるコア数は、任意であり、複数であってもよい。
図4および図5を参照して、仮想ハードウェア122-1、122-2、122-3・・・(以下、「仮想ハードウェア122」と略記する場合がある。)は、仮想化部12によって実現される仮想的なコンピュータハードウェアである。仮想ハードウェア122は、仮想プロセッサ123と、仮想NIC124と、仮想NIC IF125とを有する。また、仮想ハードウェア122は、仮想メモリを有してもよい。
図5を参照して、仮想プロセッサ123は、仮想化部12によって実現される仮想的なプロセッサである。仮想化部12のタスクに対して、仮想化部スケジューラ121が物理プロセッサ111を適宜割り当てることで、仮想プロセッサ123に割り当てられたプログラムが稼働する。図4では、物理PC11-1上の仮想ハードウェア122-1の仮想プロセッサを「仮想プロセッサ123-1-1、123-1-2、123-1-3」と表記している。また、物理PC11-1が有する物理プロセッサを「物理プロセッサ111-1-1、111-1-2、111-1-3」と表記している。同様に、物理PC11-2上の仮想ハードウェア122-2の仮想プロセッサを「仮想プロセッサ123-2-1、123-2-2、123-2-3」と表記している。また、物理PC11-2が有する物理プロセッサを「物理プロセッサ111-2-1、111-2-2、111-2-3」と表記している。同様に、物理PC11-3上の仮想ハードウェア122-3の仮想プロセッサを「仮想プロセッサ123-3-1、123-3-2、123-3-3」と表記している。また、物理PC11-3が有する物理プロセッサを「物理プロセッサ111-3-1、111-3-2、111-3-3」と表記している。ただし、物理プロセッサの数および仮想プロセッサの数は、図4に示す例に限定されず、任意である。
図5を参照して、仮想NIC124は、仮想的なネットワークインタフェースカードである。つまり、ゲストOS13側からの仮想NIC124への通信要求は、物理NIC112に引き継がれる。
仮想NIC IF125は、ゲストOS13側から仮想NIC124にアクセスするための仮想的なインタフェースである。
ゲストOS13は、各物理PC11上の各仮想マシン上で稼働する。ゲストOS13の数は、1つに限られず、複数であってもよい。各ゲストOS13は、ユーザ空間14と、カーネル空間16とを有する。なお、ゲストOS13として、汎用OSを適用することができる。汎用OSとしては、例えばマイクロソフト社(Microsoft Corporation,米国)のPC用OSであるWindows(登録商標)系のOSが挙げられる。
カーネル空間16には、汎用OSスケジューラ161と、リアルタイム通信要求共有メモリ162とが存在する。また、カーネル空間16には、ユーザ空間14内で稼働するタスクの共有メモリが存在してもよい。なお、汎用OSスケジューラ161、リアルタイム通信要求共有メモリ162、および共有メモリは、比較例で説明した汎用OSスケジューラ161、リアルタイム通信要求共有メモリ162、および共有メモリと同様である。
ユーザ空間14には、アプリケーション部141-1、141-2、・・・(以下、「アプリケーション部141」と略記する場合がある。)と、リアルタイム通信要求処理共有ライブラリ142と、リアルタイム通信API共有ライブラリ143と、リアルタイム通信部151とが存在する。なお、アプリケーション部141、リアルタイム通信要求処理共有ライブラリ142、およびリアルタイム通信API共有ライブラリ143は、ゲストOS13内で稼働すること以外は、比較例で説明したアプリケーション部141、リアルタイム通信要求処理共有ライブラリ142、およびリアルタイム通信API共有ライブラリ143と同様である。
リアルタイム通信部151は、アプリケーション部141からの通信要求に基づいて、生産制御システムにおけるリアルタイム通信を行う。具体的には、リアルタイム通信部151は、アプリケーション部141から通信要求を受け、当該通信要求に基づいてデータの送受信を行う。リアルタイム通信部151が行う処理の性質上、コントローラ21またはPC22とフレームの送受信などのタイミングを合わせる必要があり、リアルタイム性が要求される。また、リアルタイム通信部151は、アプリケーション部141から独立したタスクとして稼働することが好ましい。これにより、リアルタイム通信部151が行う他機器への通信は、滞らず実行されるからである。また、リアルタイム通信部151は、各仮想マシンに対して、リアルタイム通信処理に関する診断指標を検知する。そして、リアルタイム通信部151は、当該診断指標の値が所定の閾値を超えた仮想マシンが存在する場合、当該仮想マシンに不安定動作発生の可能性があると判断する。換言すると、複数の物理PC11のうち少なくとも一つの物理PC(例えば物理PC11-1)は、リアルタイム通信処理に関する診断指標に基づいて、仮想マシンに不安定動作発生の可能性があるか否かを判断する。以下、本実施形態に係るリアルタイム通信部151を詳細に説明する。
リアルタイム通信部151は、リアルタイム通信部インタフェース152と、リアルタイム通信通知部153と、送信バッファ154と、自己診断部155と、自己診断指標記憶部156と、診断結果通知部157とを含む。また、リアルタイム通信部インタフェース152は、要求バッファ158を含む。なお、リアルタイム通信通知部153、送信バッファ154、および要求バッファ158は、それぞれ比較例で説明したリアルタイム通信通知部193、送信バッファ194、および要求バッファ197と同様である。
リアルタイム通信部インタフェース152は、リアルタイム通信要求処理共有ライブラリ142およびリアルタイム通信API共有ライブラリ143を介して、アプリケーション部141からの要求を受け付けたり、その要求に対する応答をアプリケーション部141に返したりする機能を有する。リアルタイム通信部インタフェース152は、受け取った通信要求がデータの送信要求である場合に、要求バッファ158から当該送信要求を取り出して送信処理を行う。
自己診断部155は、各仮想マシン上で稼働するリアルタイム通信部151のリアルタイム通信処理に関する診断指標を検知し、当該診断指標の値が所定の閾値を超えたか否かを判断する。また、自己診断部155は、当該診断指標の値が所定の閾値を超えた場合、当該診断指標の値を示したリアルタイム通信部151が稼働している仮想マシンにおいて、不安定動作発生の可能性があると判断する。また、自己診断部155は、当該仮想マシンに不安定動作発生の可能性がある旨を診断結果通知部157に通知する。なお、自己診断部155は、当該診断指標を検知するにあたり、自己診断指標記憶部156を参照することができる。自己診断指標記憶部156は、比較例で説明した自己診断指標記憶部196と同様である。
自己診断部155が検知する診断指標としては、次に説明する(1)CPU負荷(CPU使用率)または(2)応答性(応答時間)が挙げられるが、これらに限定されない。
(1)CPU負荷:自己診断部155は、リアルタイム通信部151のCPU使用率の値をゲストOS13から取得する。ゲストOS13は、プログラムがゲストOS13内のパフォーマンスデータを取得するためのインタフェースを設けており、そのパフォーマンスデータには、タスクごとのCPU使用率の値が含まれる。自己診断部155は、リアルタイム通信部151のCPU使用率が予め設定された所定の閾値を超えた場合に、不安定動作発生の可能性があると判断する。なお、自己診断部155は、他の診断指標に基づいて不安定動作発生の可能性を検出してもよい。例えば、自己診断部155が、ゲストOS13全体のCPU使用率および、当該ゲストOS13が稼働する仮想ハードウェア122に割り当てられる仮想プロセッサ123の数などの情報を取得してもよい。自己診断部155は、これらの値を複数組み合わせて判断した結果が所定の閾値(例えば、CPUのコア数が4つの場合はCPU使用率30%、CPUのコア数が8つの場合はCPU使用率15%など)を超えた場合に、不安定動作発生の可能性があると判断することができる。
(2)応答性:自己診断部155は、リアルタイム通信部151の応答性が低下した場合に、不安定動作発生の可能性があると判断する。具体的には、自己診断部155は、リアルタイム通信部151がフレームの送信を行ったときのリトライの発生回数を取得する。送信のリトライは、リアルタイム通信部が処理を待たされる場合に発生する。リトライが多発する場合には、通信のリアルタイム性が阻害されていると考えることができる。したがって、自己診断部155は、1個のフレームに対するリトライの発生回数が所定の閾値を超えた場合、あるいは所定時間内におけるトータルの送信リトライの発生回数が所定の閾値を超えた場合、不安定動作発生の可能性があると判断することができる。
図4および図5を参照して、診断結果通知部157は、自己診断部155から受けた通知を後述するNMS17の判断部171に通知する。ただし、自己診断部155は、診断結果通知部157を介さずに、上述した不安定動作発生の可能性をNMS17の判断部171に通知してもよい。
管理装置(例えば、NMS(Network Management System))17は、例えば制御ネットワーク20を介して、各物理PC11と通信可能である。NMS17は、判断部171と、通信部172とを有することができる。判断部171は、1つ又は複数の物理プロセッサを用いて実現することができる。通信部172は、1つ又は複数の通信インタフェースを用いて実現することができる。ただし、管理装置17は、NMSに限られず、判断部171及び通信部172を有する任意のコンピュータを用いて実現することができる。以下では、物理PC11-1上で稼働する仮想マシン126-1-1に不安定動作発生の可能性があり、物理PC11-1上で稼働する仮想マシン126-1-2を物理PC11-2にライブマイグレーションさせる場合を例に説明する。この場合、物理PC11-1の診断結果通知部157が、NMS17の判断部171に、仮想マシン126-1-1に不安定動作発生の可能性がある旨の通知を送信する。
NMS17の判断部171は、例えば制御ネットワーク20を介して、物理PC11-1の診断結果通知部157からの通知を受信した場合に、物理PC11-1の仮想プロセッサ123-1-1、123-1-2、123-1-3に空きがあるか否かを判断する。
判断部171は、物理PC11-1の仮想プロセッサ123-1-1、123-1-2、123-1-3に空きがある場合、不安定動作発生の可能性がある仮想マシン126-1-1に対して物理PC11-1の仮想プロセッサ(つまり、「空き」の仮想プロセッサ)を割り当てる旨の指示を通信部172に送信する。図5も参照して、通信部172は、例えば制御ネットワーク20を介して、判断部171からの指示に基づくコマンドを、物理PC11-1の仮想化部12に送信する。物理PC11-1の仮想化部12は、NMS17の通信部172から受信したコマンドを実行する。換言すると、NMS17は、物理PC11-1の仮想プロセッサに空きがある場合、不安定動作発生の可能性がある仮想マシン126-1-1に対して、仮想プロセッサを割り当てることを物理PC11-1に指示する。そして、物理PC11-1は、NMS17からの指示に基づいて、仮想マシン126-1-1に対して、仮想プロセッサを割り当てる。
一方、判断部171は、物理PC11-1の仮想プロセッサ123-1-1、123-1-2、123-1-3に空きがない場合、ライブマイグレーション可能な仮想マシン126-1-2にライブマイグレーションを実行する旨の指示を通信部172に送信する。また、判断部171は、仮想マシン126-1-1に対してライブマイグレーションによって物理PC11-1内に確保した仮想プロセッサ123-1-2を割り当てる旨の指示を通信部172に送信する。また、通信部172は、判断部171からの指示に基づくコマンドを物理PC11-1の仮想化部12に送信する。また、物理PC11-1の仮想化部12は、通信部172から受信したコマンドを実行する。換言すると、NMS17は、物理PC11-1の仮想プロセッサに空きがない場合、仮想マシン126-1-1に対して、ライブマイグレーション可能な仮想マシン126-1-2のライブマイグレーションを実行することにより物理PC11-1内に確保した仮想プロセッサ123-1-2を割り当てることを物理PC11-1に指示する。そして、物理PC11-1は、NMS17からの指示に基づいて、仮想マシン126-1-1に対して、ライブマイグレーションにより物理PC11-1内に確保した仮想プロセッサ123-1-2を割り当てる。「ライブマイグレーション」とは、ある物理PC上で稼働している仮想マシンの処理内容を保存した状態で、当該仮想マシンを別の物理PCに移行して、別の物理PC上で当該仮想マシンの処理内容を復元して、その処理を再開することを意味する。仮想マシンの動作は、ライブマイグレーションの実行中、数ミリ秒から数秒一時停止するが、その処理内容は失われない。
以下では、ライブマイグレーション対象となる仮想マシン126-1-2の選択方法、ライブマイグレーション先となる物理PC11-2の決定方法、およびライブマイグレーションの実行方法の一例を詳細に説明する。
最初に、ライブマイグレーション対象となる仮想マシン126-1-2の選択方法の一例を説明する。まず、NMS17の判断部171は、物理PC11-1上で稼働する仮想マシン126-1-1、126-1-2、126-1-3の情報を取得する。「仮想マシンの情報」には、仮想マシン126-1-1、126-1-2、126-1-3上で稼働するアプリケーションの種類、および仮想マシンIDなどの情報が含まれる。続いて、判断部171は、物理PC11-1上で稼働する仮想マシン126-1-1、126-1-2、126-1-3の中から、ライブマイグレーション可能な仮想マシン126-1-2をライブマイグレーションの対象として選択する。この際に、判断部171は、ライブマイグレーション可能な仮想マシン126-1-2として、稼働優先度が低い仮想マシンを選択してもよい。「稼働優先度が低い仮想マシン」とは、稼働優先度が所定値以下の仮想マシンを意味する。換言すると、稼働優先度が低い仮想マシンとは、物理PC11-1上で稼働する仮想マシン126-1-1、126-1-2、126-1-3のうち、生産制御システムに与える影響が小さい仮想マシンを意味する。したがって、生産制御システムへの影響を抑えつつ、リアルタイム性を確保することができる。
次に、ライブマイグレーション先となる物理PC11-2の決定方法の一例を説明する。まず、NMS17の通信部172は、各物理PC11-1、11-2、11-3と通信して、各物理PC11-1、11-2、11-3上で稼働する仮想マシンに対する仮想プロセッサの割り当て状況を受信する。続いて、通信部172は、受信した仮想プロセッサの割り当て状況を判断部171に通知する。続いて、判断部171は、物理PC11-1上で稼働する仮想マシン126-1-2に対する仮想プロセッサ123-1-2の割り当て状況と、物理PC11-1とは別の各物理PC11-2、11-3上で稼働する仮想マシンへの仮想プロセッサの割り当て状況とに基づいて、仮想マシン126-1-2のライブマイグレーション先の物理PC11-2を決定する。換言すると、NMS17は、複数の物理PC11のうち少なくとも一つの物理PC11上で稼働する仮想マシンに対する仮想プロセッサの割り当て状況に基づいて、仮想マシン126-1-2のライブマイグレーション先を決定する。
また、NMS17は、複数の物理PC11の処理性能に基づいて、ライブマイグレーション先の物理PC11-2を決定してもよい。「処理性能」として、物理PCのCPU性能またはメモリへのアクセス性能などが挙げられる。例えば、NMS17の判断部171は、ライブマイグレーション元となる物理PC11の処理性能と、ライブマイグレーション先の候補となる物理PCの処理性能とを比較して、これらの処理性能が類似、好ましくは同一である物理PC11をライブマイグレーション先に決定してもよい。
また、NMS17は、複数の物理PC11の仮想資源量に基づいて、ライブマイグレーション先となる物理PC11を決定してもよい。「仮想資源量」は、仮想プロセッサの使用率および仮想メモリの使用率などを含む。例えば、NMS17の判断部171はライブマイグレーション対象である仮想マシン126-1-2を稼働させるための十分な仮想資源量を有する物理PC11-2をライブマイグレーション先として決定してもよい。また、判断部171は、十分な仮想資源量を有する物理PC11が複数存在する場合には、複数の物理PC11のうち、ライブマイグレーション元となる物理PC11-1と処理性能が類似し、かつ空きの仮想資源量が多い物理PC11-2をライブマイグレーション先に決定してもよい。より好ましくは、判断部171は、複数の物理PC11のうち、物理PC11-1と処理性能が同一であり、かつ空きの仮想資源量が多い物理PC11-2をライブマイグレーション先に決定してもよい。
次に、ライブマイグレーショの実行方法の一例を説明する。判断部171は、上述した選択方法によって選択した仮想マシン126-1-2を、上述した決定方法によって決定した物理PC11-2にライブマイグレーションする旨の指示を通信部172に送信する。続いて、通信部172は、物理PC11-1の仮想化部12と、物理PC11-2の仮想化部12とに対して、仮想マシン126-1-2のライブマイグレーションを実行する旨のコマンドを送信する。続いて、物理PC11-1の仮想化部12は、これにより、仮想マシン126-1-2をライブマイグレーションさせることにより物理PC11-1内に確保した仮想プロセッサ123-1-2を仮想マシン126-1-1に割り当てる。このようにして、ライブマイグレーションの実行による生産制御システムへの影響をより抑制することができる。
ここで、上記選択方法を実行するにあたり、NMS17の判断部171は、図6に示す稼働優先順位テーブルを参照することができる。稼働優先順位テーブルは、「稼働優先順位」、「ライブマイグレーション可否」、および「仮想マシンID」に関する情報を含むことができる。なお、図6の「稼働アプリケーション」および「備考」の欄に記載の情報は、説明のために併記しているだけであり、実際の優先順位テーブルは、これらの情報を含まなくてもよい。なお、優先順位テーブルは、エンジニアリングサーバなどから予め設定されたものでもよく、NMS17内の記憶部などに予め格納されてもよいが、これに限定されない。以下、稼働優先順位テーブルを詳細に説明する。
「ライブマイグレーション可否」の欄に記載の情報は、仮想マシンをライブマイグレーションさせることが可能であるか否かを示す。例えば、WDT(Watch Dog Timer)が発生するなどの理由により、処理を一時停止することができない仮想マシン、またはアクセス権限などの理由により、特定の物理PC上でしか稼働することができない仮想マシンについては、ライブマイグレーションが「否」と設定される。
「仮想マシンID」の欄に記載の情報は、各仮想マシンの識別情報を示す。仮想マシンIDは、リアルタイム通信処理システムの全体で一意に設定される。なお、仮想マシンIDの欄に所定の記号が付されている場合、仮想マシン上で稼働しているアプリケーションの情報に基づいて、当該アプリケーションが稼働中の全ての仮想マシンがライブマイグレーション対象の候補となる。ただし、ライブマイグレーションが「否」である仮想マシン(仮想マシンID:VM1)上でI/Oモジュール予知保全アプリ(ライブマイグレーション可)が動作する場合などは、「ライブマイグレーション:否」の設定を優先する。
「稼働優先順位」の欄に記載の情報は、その番号が小さいほど仮想マシンを優先的に稼働させることを示し、予め設定される。例えば、データサーバのようにサーバ機能を有し、サーバ機能が停止すると生産制御システムに与える影響が大きいアプリケーションが稼働する仮想マシン(仮想マシンID:VM1)の稼働優先順位は高く設定される。図6では、仮想マシン(仮想マシンID:VM1)の稼働優先順位は、最も高く「1」に設定される。また、あるアプリケーションが1つの仮想マシン(仮想マシンID:VM2)上でのみ稼働している場合には、稼働優先順位は高く設定される。図6では、仮想マシン(仮想マシンID:VM2)の稼働優先順位は「2」に設定される。一方、2つの仮想マシン(仮想マシンID:VM3、VM4)上で同じアプリケーションが稼働している場合には、仮想マシン(仮想マシンID:VM4)の稼働優先順位は、仮想マシン(仮想マシンID:VM3)の稼働優先順位よりも低く設定される。図6では、仮想マシン(仮想マシンID:VM4)の稼働優先順位は「3」に設定され、仮想マシン(仮想マシンID:VM3)の稼働優先順位は「1」に設定される。これは、仮想マシン(仮想マシンID:VM4)が停止しても、仮想マシン(仮想マシンID:VM3)上で当該アプリケーションを稼働させることが可能であるからである。なお、HMIなどのクライアント機能が稼働している仮想マシンの稼働優先順位は、1つの仮想マシンが停止しても生産制御システムに与える影響は小さいので、低く設定される。また、仮想マシン上で稼働するアプリケーションの動作周期が長い場合には、稼働優先順位は低く設定される。例えば、データ収集アプリケーションのように、動作周期が1週間に1回の場合などがこれに該当する。また、仮想マシン(仮想マシンID:VM5、VM6)上で稼働するアプリケーションが大容量のデータを生成する場合には、当該アプリケーションは仮想資源に空きがある場合にのみ実行されるので、稼働優先順位は低く設定される。
なお、ライブマイグレーション可能な仮想マシンがない場合、NMS17の判断部171は、通信部172に対して、仮想マシン126-1-1を停止させる旨の指示を通信部172に送信する。次に、図5も参照して、通信部172は、判断部171からの指示に基づくコマンドを物理PC11-1の仮想化部12に送信する。次に、物理PC11-1の仮想化部12は、NMS17の通信部172から受信したコマンドを実行する。これによって、仮想マシン126-1-1の稼働が停止する。
次に、図7を参照して、本実施形態に係るリアルタイム通信処理システム1の処理手順について説明する。
まず、ステップS100において、物理PC11-1は、各仮想マシンについて、リアルタイム通信処理に関する診断指標を検知し、当該診断指標の値が所定の閾値を超えたか否かを判断する。当該診断指標の値が所定の閾値を超えた場合(ステップS100:YES)、ステップS110に進む。当該診断指標の値が所定の閾値を超えていない場合(ステップS100:NO)、ステップS160に進む。
図4および図5も参照して、例えば、ステップS100では、まず、各物理PC11の自己診断部155が、各仮想マシンについて、リアルタイム通信処理に関する診断指標を検知し、当該診断指標の値が所定の閾値を超えたか否かを判断する。次に、当該診断指標の値が所定の閾値を超えた場合、自己診断部155は、仮想マシン126-1-1に不安定動作発生の可能性があると判断して、その旨を診断結果通知部157に通知する。次に、診断結果通知部157は、自己診断部155から受けた通知をNMS17の判断部171に通知する。ただし、自己診断部155は、診断結果通知部157を介さずに、上述した不安定動作発生の可能性がある旨をNMS17の判断部171に通知してもよい。
ステップS100からステップS110に進んだ場合、ステップS110において、物理PC11-1は、リアルタイム通信処理に関して不安定動作発生の可能性がある仮想マシン126-1-1が存在する旨の通知をNMS17に送信する。
続いて、ステップS120において、NMS17は、ステップS110の通知を送信した物理PC11-1の仮想プロセッサに空きがあるか否かを判断する。仮想プロセッサに空きがある場合(ステップS120:YES)、ステップS130に進む。仮想プロセッサに空きがない場合(ステップS120:NO)、ステップS140に進む。
例えば、ステップS120では、以下の処理を行うことができる。図4を参照して、NMS17の判断部171は、物理PC11-1の仮想プロセッサに空きがあるか否かを判断する。この際、判断部171は、仮想ハードウェア122-1または物理PC11-1から情報を収集し、当該情報に基づいて上記判断を行ってもよい。
ステップS120からステップS130に進んだ場合、つまり、物理PC11-1に空きの仮想プロセッサがある場合、ステップS130において、NMS17は、不安定動作発生の可能性がある仮想マシン126-1-1に空きの仮想プロセッサを割り当てることを物理PC11-1に指示する。これにより、仮想マシン126-1-1に仮想プロセッサが割り当てられる。その後、ステップS160に進む。
例えば、ステップS130では、以下の処理を行うことができる。図4および図5を参照して、まず、NMS17の判断部171は、通信部172に対して、仮想マシン126-1-1に物理PC11-1の空きの仮想プロセッサを割り当てる旨を指示する。次に、通信部172は、判断部171からの指示に基づくコマンドを物理PC11-1の仮想化部12に送信する。次に、物理PC11-1の仮想化部12は、ステップS130に関して上述したコマンドを実行する。これにより、仮想マシン126-1-1に空きの仮想プロセッサが割り当てられる。なお、仮想化部12は、仮想マシン126-1-1における不安定動作発生の可能性が解消すると、仮想マシン126-1-1に割り当てられた仮想プロセッサを適宜解放する。
一方、ステップS120からステップS140に進んだ場合、つまり、物理PC11-1に空きの仮想プロセッサがない場合、ステップS140において、NMS17は、ステップS110の通知を送信した物理PC11-1上で稼働する仮想マシン126-1-1、126-1-2、126-1-3のうち稼働優先度が低く、かつライブマイグレーション可能な仮想マシン126-1-2のライブマイグレーションを実行する。
ここで、図8も参照して、ステップS140の処理を詳細に説明する。
ステップS140の処理が開始すると、ステップS141において、NMS17は、物理PC11-1上で稼働する仮想マシンの情報を取得する。
続いて、ステップS142において、NMS17は、物理PC11-1上で稼働する仮想マシン126-1-1、126-1-2、126-1-3のうち、稼働優先度が低く、かつライブマイグレーション可能な仮想マシン126-1-2をライブマイグレーション対象として選択する。ライブマイグレーション対象となる仮想マシン126-1-2の選択方法は、既述のとおりである。
続いて、ステップS143において、NMS17は、仮想マシン126-1-2のライブマイグレーション先となる物理PC11-2を決定する。ライブマイグレーション先となる物理PC11-2の決定方法は、既述のとおりである。
続いて、ステップS144において、NMS17は、物理PC11-1に対して、仮想マシン126-1-2を物理PC11-2にライブマイグレーションさせる旨を指示する。
続いて、ステップS145において、物理PC11-1は、仮想マシン126-1-2のライブマイグレーションを実行する。ライブマイグレーションの実行方法は、既述のとおりである。このようにして、物理PC11-1内に仮想プロセッサ123-1-2が確保され、ステップS140の処理が終了する。
図7に戻って、ステップS150において、物理PC11-1は、ステップS140のライブマイグレーションによって物理PC11-1内に確保した仮想プロセッサ123-1-2を仮想マシン126-1-1に割り当てる。その後、ステップS160に進む。なお、仮想プロセッサ123-1-2の割り当ては、ライブマイグレーションが終了した後に実行されてもよく、物理PC11-1の仮想化部12は、仮想マシン126-1-1における不安定動作発生の可能性が解消すると、仮想マシン126-1-1に割り当てられた仮想プロセッサ123-1-2を適宜解放してもよい。
続いて、ステップS160において、リアルタイム通信を実行して、本処理が終了する。ステップS160の処理は、比較例におけるステップS14~S17の処理と同様であるので、説明を省略する。なお、ステップS100~S150の処理自身の遅延により、ステップS160の処理が遅れ、リアルタイム通信のリアルタイム性が阻害される可能性がある場合は、ステップS100~S150の処理の完了を待たずに、ステップS160の処理を並行して実行してもよい。
以上、本実施形態によれば、次の作用効果が得られる。すなわち、本実施形態によれば、リアルタイム通信処理に関して不安定動作発生の可能性がある仮想マシンに仮想プロセッサを割り当てるので、リアルタイム性を確保することができる。また、仮想プロセッサに空きがなくても、ライブマイグレーションにより確保した仮想プロセッサを不安定動作発生の可能性がある仮想マシンに割り当てる。このため、仮想マシンを完全に停止させる場合に比べて、生産制御システムに必要なリアルタイム性を確保することができる。
以上、本開示を諸図面および実施形態に基づき説明したが、当業者であれば本開示に基づき種々の変形又は修正を行うことが容易であることに注意されたい。したがって、これらの変形又は修正は本開示の範囲に含まれることに留意されたい。例えば、各ステップ等に含まれる機能等は論理的に矛盾しないように再配置可能であり、複数のステップ等を1つに組み合わせたり、あるいは分割したりすることが可能である。
例えば、第1の変形例として、ライブマイグレーション可能な仮想マシンが存在しない場合、リアルタイム通信処理に関して不安定動作発生の可能性がある仮想マシンに対して、リアルタイム通信インタフェースがアプリケーション部からの通信要求を処理する時間間隔を調整してもよい。なお、時間間隔の調整は、比較例と同様に行えばよい。第1の変形例によれば、リアルタイム通信インタフェースがアプリケーション部からの通信要求を処理する時間間隔を調整することによって、仮想マシンにおける不安定動作発生の可能性を緩和することができる。
また、第2の変形例として、アプリケーション部から独立したタスクとして稼働し、当該アプリケーション部からの通信要求を受け付け、当該通信要求を当該タスク内の専用の記憶部に格納した後に、当該記憶部から取り出した通信要求をリアルタイム通信部に渡すアプリケーション代理部を、各物理PCが備えてもよい。これにより、アプリケーション部同士は、通信要求に干渉することがなくなるので、安全性が確保される。「干渉」とは、通信要求を無断で読み取ったり、書き換えたりすることを意味する。したがって、第2の変形例によれば、例えば送受信フレームの改ざんおよび覗き見などの懸念からアプリケーション部を保護することができる。
本開示によれば、汎用OSのスケジューラを用いつつ、生産制御システムに必要なリアルタイム性を確保することができるリアルタイム通信処理システム、およびリアルタイム通信処理方法を提供することができる。
1 リアルタイム通信処理システム
11 コンピュータ(物理PC)
11-1、11-2、11-3 コンピュータ(物理PC)
111 物理プロセッサ
111-1-1、111-1-2、111-1-3 物理プロセッサ
111-2-1、111-2-2、111-2-3 物理プロセッサ
111-3-1、111-3-2、111-3-3 物理プロセッサ
112 物理NIC
113 物理NIC IF
12 仮想化部
121 仮想化部スケジューラ
122 仮想ハードウェア
122-1、122-2、122-3 仮想ハードウェア
123 仮想プロセッサ
123-1-1、123-1-2、123-1-3 仮想プロセッサ
123-2-1、123-2-2、123-2-3 仮想プロセッサ
123-3-1、123-3-2、123-3-3 仮想プロセッサ
124 仮想NIC
125 仮想NIC IF
126 仮想マシン
126-1-1、126-1-2、126-1-3 仮想マシン
126-2-1、126-2-2 仮想マシン
126-3-1、126-3-2、126-3-3 仮想マシン
13 ゲストOS
14 ユーザ空間
141 アプリケーション部
141-1、141-2 アプリケーション部
142 リアルタイム通信要求処理共有ライブラリ
143 リアルタイム通信API共有ライブラリ
144 アプリケーション代理部
145-1、145-2 アプリケーション要求処理部
146 リアルタイム通信要求タスク内メモリ
151 リアルタイム通信部
152 リアルタイム通信部インタフェース
153 リアルタイム通信通知部
154 送信バッファ
155 自己診断部
156 自己診断指標記憶部
157 診断結果通知部
158 要求バッファ
16 カーネル空間
161 汎用OSスケジューラ
162 リアルタイム通信要求共有メモリ
163 共有メモリ
17 管理装置(NMS)
171 判断部
172 通信部
20 制御ネットワーク
21 コントローラ
22 PC
23 フィールド機器

Claims (7)

  1. 複数のコンピュータと、各コンピュータと通信可能な管理装置とを備え、前記複数のコンピュータのうち少なくとも一つのコンピュータ上で少なくとも一つの仮想マシンが稼働する、生産制御システムにおけるリアルタイム通信処理システムであって、
    前記少なくとも一つのコンピュータは、当該コンピュータにおいて、リアルタイム通信処理に関して不安定動作発生の可能性がある仮想マシンが存在すると、その旨の通知を前記管理装置に送信し、
    前記管理装置は、
    前記通知を送信した前記コンピュータの仮想プロセッサに空きがある場合、前記不安定動作発生の可能性がある前記仮想マシンに対して、前記仮想プロセッサを割り当てることを、前記通知を送信した前記コンピュータに指示し、
    前記通知を送信した前記コンピュータの仮想プロセッサに空きがない場合、前記不安定動作発生の可能性がある前記仮想マシンに対して、ライブマイグレーション可能な仮想マシンのライブマイグレーションを実行することにより前記通知を送信した前記コンピュータ内に確保した仮想プロセッサを割り当てることを、前記通知を送信した前記コンピュータに指示する、
    リアルタイム通信処理システム。
  2. 前記管理装置は、前記ライブマイグレーション可能な仮想マシンとして、稼働優先度が低い仮想マシンを選択する、請求項1に記載のリアルタイム通信処理システム。
  3. 前記管理装置は、前記少なくとも一つのコンピュータ上で稼働する前記仮想マシンに対する前記仮想プロセッサの割り当て状況に基づいて、前記仮想マシンのライブマイグレーション先を決定する、請求項1または2に記載のリアルタイム通信処理システム。
  4. 前記管理装置は、前記複数のコンピュータの処理性能に基づいて、前記仮想マシンのライブマイグレーション先を決定する、請求項1から3のいずれか一項に記載のリアルタイム通信処理システム。
  5. 前記管理装置は、前記複数のコンピュータの仮想資源量に基づいて、前記仮想マシンのライブマイグレーション先を決定する、請求項1から4のいずれか一項に記載のリアルタイム通信処理システム。
  6. 前記少なくとも一つのコンピュータは、前記リアルタイム通信処理に関する診断指標に基づいて、前記仮想マシンに不安定動作発生の可能性があるか否かを判断する、請求項1から5のいずれか一項に記載のリアルタイム通信処理システム。
  7. 生産制御システムにおけるリアルタイム通信処理方法であって、
    少なくとも一つのコンピュータが、当該コンピュータにおいてリアルタイム通信処理に関して不安定動作発生の可能性がある仮想マシンが存在すると、その旨の通知を管理装置に送信するステップと、
    前記管理装置が、前記通知を送信した前記コンピュータの仮想プロセッサに空きがある場合、前記不安定動作発生の可能性がある前記仮想マシンに対して、前記仮想プロセッサを割り当てることを、前記通知を送信した前記コンピュータに指示するステップと、
    前記管理装置が、前記通知を送信した前記コンピュータの仮想プロセッサに空きがない場合、前記不安定動作発生の可能性がある前記仮想マシンに対して、ライブマイグレーション可能な仮想マシンのライブマイグレーションを実行することにより前記通知を送信した前記コンピュータ内に確保した仮想プロセッサを割り当てることを、前記通知を送信した前記コンピュータに指示するステップと、
    を含むリアルタイム通信処理方法。
JP2019185258A 2019-10-08 2019-10-08 リアルタイム通信処理システム、およびリアルタイム通信処理方法 Active JP7010272B2 (ja)

Priority Applications (3)

Application Number Priority Date Filing Date Title
JP2019185258A JP7010272B2 (ja) 2019-10-08 2019-10-08 リアルタイム通信処理システム、およびリアルタイム通信処理方法
CN202011065461.9A CN112631714B (zh) 2019-10-08 2020-09-30 实时通信处理系统以及实时通信处理方法
US17/064,702 US11556434B2 (en) 2019-10-08 2020-10-07 Real-time communication processing system and real-time communication processing method

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2019185258A JP7010272B2 (ja) 2019-10-08 2019-10-08 リアルタイム通信処理システム、およびリアルタイム通信処理方法

Publications (2)

Publication Number Publication Date
JP2021060858A JP2021060858A (ja) 2021-04-15
JP7010272B2 true JP7010272B2 (ja) 2022-01-26

Family

ID=75274112

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2019185258A Active JP7010272B2 (ja) 2019-10-08 2019-10-08 リアルタイム通信処理システム、およびリアルタイム通信処理方法

Country Status (3)

Country Link
US (1) US11556434B2 (ja)
JP (1) JP7010272B2 (ja)
CN (1) CN112631714B (ja)

Families Citing this family (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US12219009B2 (en) * 2021-01-15 2025-02-04 Intel Corporation Virtual device portability

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2012208541A (ja) 2011-03-29 2012-10-25 Mitsubishi Electric Corp 仮想マシン管理装置、仮想マシン管理方法及び仮想マシン管理プログラム
JP2014006739A (ja) 2012-06-25 2014-01-16 Fujitsu Ltd プログラム、管理サーバおよび仮想マシン移動制御方法
JP2017010358A (ja) 2015-06-24 2017-01-12 富士通株式会社 制御方法、制御プログラム、及び情報処理装置
JP2017215884A (ja) 2016-06-02 2017-12-07 日本電信電話株式会社 仮想マシン配置装置およびリソース管理方法
JP2019079348A (ja) 2017-10-25 2019-05-23 横河電機株式会社 通信処理装置、プログラム、および通信処理方法

Family Cites Families (14)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP4542514B2 (ja) * 2006-02-13 2010-09-15 株式会社日立製作所 計算機の制御方法、プログラム及び仮想計算機システム
US8832682B2 (en) * 2008-03-28 2014-09-09 Vmware, Inc. Trace collection for a virtual machine
CN101488098B (zh) * 2009-02-13 2011-11-30 华中科技大学 基于虚拟计算技术的多核计算资源管理系统
WO2012066640A1 (ja) * 2010-11-16 2012-05-24 株式会社日立製作所 計算機システム、マイグレーション方法及び管理サーバ
CN102317917B (zh) * 2011-06-30 2013-09-11 华为技术有限公司 热点域虚拟机cpu调度方法及虚拟机系统
CN102819465B (zh) * 2012-06-29 2014-09-24 华中科技大学 一种虚拟化环境中故障恢复的方法
US9465669B2 (en) * 2013-08-13 2016-10-11 Vmware, Inc. NUMA scheduling using inter-vCPU memory access estimation
US9280385B2 (en) * 2013-12-19 2016-03-08 International Business Machines Corporation Optimally provisioning and merging shared resources to maximize resource availability
US10754702B2 (en) * 2015-08-18 2020-08-25 Telefonaktiebolaget Lm Ericsson (Publ) Technique for reconfiguring a virtual machine
US9880872B2 (en) * 2016-06-10 2018-01-30 GoogleLLC Post-copy based live virtual machines migration via speculative execution and pre-paging
US10346201B2 (en) * 2016-06-15 2019-07-09 International Business Machines Corporation Guided virtual machine migration
US10678603B2 (en) * 2016-09-01 2020-06-09 Microsoft Technology Licensing, Llc Resource oversubscription based on utilization patterns in computing systems
US10769007B2 (en) * 2018-06-08 2020-09-08 Microsoft Technology Licensing, Llc Computing node failure and health prediction for cloud-based data center
US10977068B2 (en) * 2018-10-15 2021-04-13 Microsoft Technology Licensing, Llc Minimizing impact of migrating virtual services

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2012208541A (ja) 2011-03-29 2012-10-25 Mitsubishi Electric Corp 仮想マシン管理装置、仮想マシン管理方法及び仮想マシン管理プログラム
JP2014006739A (ja) 2012-06-25 2014-01-16 Fujitsu Ltd プログラム、管理サーバおよび仮想マシン移動制御方法
JP2017010358A (ja) 2015-06-24 2017-01-12 富士通株式会社 制御方法、制御プログラム、及び情報処理装置
JP2017215884A (ja) 2016-06-02 2017-12-07 日本電信電話株式会社 仮想マシン配置装置およびリソース管理方法
JP2019079348A (ja) 2017-10-25 2019-05-23 横河電機株式会社 通信処理装置、プログラム、および通信処理方法

Also Published As

Publication number Publication date
US20210103504A1 (en) 2021-04-08
US11556434B2 (en) 2023-01-17
CN112631714A (zh) 2021-04-09
CN112631714B (zh) 2024-08-20
JP2021060858A (ja) 2021-04-15

Similar Documents

Publication Publication Date Title
EP2577450B1 (en) Virtual machine migration techniques
JP5180373B2 (ja) 仮想化環境における割り込みメッセージ終了のレイジー処理
US7484029B2 (en) Method, apparatus, and computer usable program code for migrating virtual adapters from source physical adapters to destination physical adapters
US9778997B2 (en) Server backup method and backup system using the method
JP5742387B2 (ja) 情報処理システム、及びi/oスイッチ装置
JP6072084B2 (ja) 仮想計算機システムおよび仮想計算機システムのデータ転送制御方法
CN112631713B (zh) 通信处理装置、通信处理方法及程序
KR102509988B1 (ko) 커넥션 기반 로드 밸런싱을 위한 저장 시스템 및 방법
US11556391B2 (en) CPU utilization for service level I/O scheduling
US8635632B2 (en) High performance and resource efficient communications between partitions in a logically partitioned system
US10862616B2 (en) Communication processing apparatus and communication processing method
US20140289728A1 (en) Apparatus, system, method, and storage medium
JP7010272B2 (ja) リアルタイム通信処理システム、およびリアルタイム通信処理方法
US12164505B2 (en) Two-phase commit using reserved log sequence values
WO2018173300A1 (ja) I/o制御方法およびi/o制御システム
JP5504651B2 (ja) 仮想マシンシステム、情報処理装置、リソース管理方法、プログラム及び記録媒体
JP6657910B2 (ja) 帯域設定方法、帯域設定プログラム、情報処理装置及び情報処理システム
JP7047906B2 (ja) 入出力処理割り当て制御装置、入出力処理割り当て制御システム、入出力処理割り当て制御方法、及び、入出力処理割り当て制御プログラム
US20230359533A1 (en) User Triggered Virtual Machine Cloning for Recovery/Availability/Scaling
US20230333894A1 (en) Dynamic allocation of stack memory space upon thread start in a distributed processing environment
JP2017004467A (ja) マイグレーション制御装置、マイグレーション制御方法及びマイグレーション制御プログラム

Legal Events

Date Code Title Description
A621 Written request for application examination

Free format text: JAPANESE INTERMEDIATE CODE: A621

Effective date: 20210203

A977 Report on retrieval

Free format text: JAPANESE INTERMEDIATE CODE: A971007

Effective date: 20211206

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: 20211214

A61 First payment of annual fees (during grant procedure)

Free format text: JAPANESE INTERMEDIATE CODE: A61

Effective date: 20211227

R150 Certificate of patent or registration of utility model

Ref document number: 7010272

Country of ref document: JP

Free format text: JAPANESE INTERMEDIATE CODE: R150