JPH0352048A - Automatic resending processing system for message - Google Patents

Automatic resending processing system for message

Info

Publication number
JPH0352048A
JPH0352048A JP1188269A JP18826989A JPH0352048A JP H0352048 A JPH0352048 A JP H0352048A JP 1188269 A JP1188269 A JP 1188269A JP 18826989 A JP18826989 A JP 18826989A JP H0352048 A JPH0352048 A JP H0352048A
Authority
JP
Japan
Prior art keywords
space
message
request message
processing unit
transmission
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.)
Granted
Application number
JP1188269A
Other languages
Japanese (ja)
Other versions
JPH0827768B2 (en
Inventor
Kazuko Watanabe
和子 渡辺
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.)
Fujitsu Ltd
Original Assignee
Fujitsu Ltd
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 Fujitsu Ltd filed Critical Fujitsu Ltd
Priority to JP1188269A priority Critical patent/JPH0827768B2/en
Publication of JPH0352048A publication Critical patent/JPH0352048A/en
Publication of JPH0827768B2 publication Critical patent/JPH0827768B2/en
Anticipated expiration legal-status Critical
Expired - Lifetime legal-status Critical Current

Links

Landscapes

  • Computer And Data Communications (AREA)

Abstract

PURPOSE:To reduce the load for realizing a fault tolerant function upon a person who makes a message communication by providing a kernel with an automatic resending processing part, a return message monitoring processing part, and a loop detection processing part. CONSTITUTION:The automatic resending processing part 21 recognizes the occurrence of abnormality in a reception space 3 and resends a request message, sent previously from a transmission space 1, to the reception space 3. The return message monitoring processing part 22 selects only correct return message sent from the reception means 3 and sends them to the transmission space 1 when resending is performed. The loop detection processing part 23 detects a loop at the time of the resending operation. Consequently, the load for realizing the fault tolerant function upon the person who makes a message communication is reduced.

Description

【発明の詳細な説明】 〔概 要〕 オペレーティングシステムのカーネルによるメッセージ
の自動再送処理方式に関し, メッセージ通信を行う者へのフォールトトレラント機能
実現のための負担を軽くすることを目的とし, 送信空間から受信空間への要求メッセージの送信及び前
記受信空間から前記送信空間への返信メッセージの送信
をカーネルを介して行うと共に,前記受信空間に異常が
発生した場合に前記要求メッセージが前記受信空間に再
送信されるデータ処理装置において,自動再送処理部と
.返信メッセージ監視処理部と.ループ検出処理部とを
前記カーネルに設け.前記自動再送処理部が前記受信空
間における前記異常の発生を認緻して前記送信空間から
先に送信された前記要求メッセージについて前記受信空
間への前記再送信を行い,前記返信メッセージ監視処理
部が前記再送信が行われた場合に前記受信空間から送信
された前記返信メッセージのうち正しいものを選択して
これを前記送信空間に送信し.前記ループ検出処理部が
前記再送信の際に前記ループの検出を行うように構或す
る.〔産業上の利用分野〕 本発明はメッセージの自動再送処理方式に関し,更に詳
しくは.オペレーティングシステムのカ−ネルによるメ
ッセージの自動再送処理方式に関する. データ処理システムにおけるデータの送受信は5メッセ
ージの形で行われる.そこで,このメッセージの送受信
については,フォールトトレラント(FT)機能,即ち
,システムに異常が発生してもネットワークに対してサ
ービスを停止することなく提供し続ける機能が実現され
ている.〔従来の技術〕 第4図は従来技術説明図であり,従来のメッセージの再
送処理について示している. 第4図において,1は送信空間.2はカーネル,3は受
信空間.31は受信空間3のうちの現用空間.32は受
信空間3のうちの待機空間である.処理プログラム又は
プロセスの如き送信側,即ち送信空間1が処理を要求す
るメッセージ(要求メッセージ)をオペレーティングシ
ステムのカーネル(核)2を介して,他の処理プログラ
ム又はプロセスの如き受信側,I!jち,受信空間3の
うちの現在活動中の空間(現用空間31)に送信する(
図中■). この後,メッセージの処理中に現用空間3lにクラッシ
ュの如き異常が発生した場合(図中■),現用空間31
を監視しているカーネル2がクラッシュの発生を送信空
間lに通知し,送信空間1がこれを受信する(図中■)
.また,クラッシュの発生により,Ijl用空間31が
,これと対(2重化)とされた受信空間3である待機空
間32に切り替わり,活動する(図中■). クラッシュの発生を知った送信空間1は,要求メッセー
ジをカーネル2を介して.現在活動している受信空間で
ある待機空間32に再送信する(図中■). 待機空間32は,要求メッセージを受信し.処理を完了
すると共に,送信空間lに対してカーネル2を介して返
信メッセージを送信し(図中■),送信空間1はこれを
受信する(図中■).以上のように,現用空間31にお
けるクラッシュに対してのフォールトトレラント機能が
主として送信空間1によって実現されている.また.現
用空間31におけるクラッシュの原因が入力依存バグ等
の如く受信側の処理プログラム中のバグに在る場合には
,待機空間32においても同一のクラッシュが発生し,
正常に処理できない.この結果,クランシェないし要求
メッセージの再送信が纏り返される(無限)ループが発
生する可能性がある.そこで,再送信前にループ検出処
理を行い(図中O).ループ回数が所定の値を越えた場
合に適当な処理を行ってループを解消している. 従って,前記ループに対するフォールトトレラント機能
が送信空間lによって実現されている.(発明が解決し
ようとする[111) 前述の従来技術によれば,クラッシュに基づく受信空間
の切り替えとクラッシェ通知とを認識して要求メッセー
ジを再送信する処理(図中■)は.送信空間1が行わな
ければならない.一方.再送信された要求メッセージの
内容については,これを使用する側,即ち受信側(受信
空間3)で管理しなければならない.従って,受信側は
2度目以降に受信した要求メッセージの内容が最初のも
のと同一か否かをチェックする機能を持たなければなら
ない.また.前述の如くループが発生する可能性がある
ので,これに対するループ検出を送信空間1が行う必要
がある. このように従来.メッセージの送受信についてのフォー
ルトトレラント機能は,メッセージ通信を行う者.即ち
送信空間l及び受信空間3(処理プログラム又はプロセ
ス)によって実現されるものであった.即ち.メッセー
ジ通信を行う者,特に送信空間lから見た場合,フォー
ルトトレラント化のための要求メッセージの再送信が自
動的に行われるような構或とはなっていない.このため
,メッセージ通信を行う者にとって.フォールトトレラ
ント機能実現のための負担が大きいという問題があった
. 本発明は,メッセージ通信を行う者へのフォールトトレ
ラント機能実現のための負担を軽くしたメッセージの自
動再送処理方式を提供することを目的とする. 〔課題を解決するための手段〕 第1図は本発明の原理構戒図であり.本発明によるデー
タ処理装置を示している. 第1図において,1は送信空間,2はカーネル,3は受
信空間,21は自動再送処理部.22は返信メッセージ
監視処理部,23はループ検出処理部,31は受信空間
3のうちの現用空間,32は受信空間3のうちの待機空
間である. 送信空間lは,カーネル2を介して,受信空間3へ要求
メッセージ(処理を要求するメッセージ)を送信する. 受信空間3は.要求メッセージを受信した場合に当績要
求メッセージで要求された処理を行う.そして,処理を
完了したら.受信空間3は,力一ネル2を介して,送信
空間1へ要求メッセージに対する返信メッセージを送信
する.これにより,処理の完了が通知される.受信空間
3は,クラッシュ等の異常の発生に備えて2重化されて
おり.現在活動中の空間である現用空間3lと待機中の
空間である待機空間32とからなる.受信空間3の現用
空間3lに異常が発生した場合には.受信空間3が現用
空間31から待機空間32に切り替えられた後に.受信
空間3である待機空間32に要求メッセージが再送信さ
れ.要求された処理を完遂させることができる. カーネル2は,前述の要求メッセージ及び返信メッセー
ジの送信等のメッセージ通信についてのサービスを行う
と共に,要求メッセージの自動再送処理を行う.このた
めに.自動再送処理部21.返信メッセージ監視処理部
22及びループ検出処理部23がカーネル2中に設けら
れる.自動再送処理部2lは,受信空間3の現用空間3
lにクラッシェ等の異常が発生したこと,及びこれによ
り前述の如き空間の切り替えがあったことを認識する.
そして,当該異常の発生より先に,送信空間lから受信
空間3へ送信された要求メッセージについて,受信空間
3の待機空間(現用空間とされている)32へ再送信す
る. 返信メッセージ監視処理部22は.返信メッセージの監
視を行う.そして,要求メッセージの再送信が行われた
場合には,受信空間3(現用空間3l及び/又は待機空
間32)から送信された返信メッセージのうち正しいも
の,Wiち,最も近い時刻に再送信した要求メッセージ
に対する返信メッセージのみを選択し,これを送信空間
1に送信する. ループ検出処理部23は.要求メッセージの再送信の際
に.受信空間3でのクラッシュ等の異常の発生ないし要
求メッセージの再送信が繰り返されるループの検出を行
う. 〔作 用〕 カーネル2は,送信空間lが受信空間3の現用空間31
を宛先として送信した要求メッセージを受取り,これを
現用空間31へ送る.この時.自動再送処理部2lは,
要求メッセージを複写して保存する. 現用空間31においてクラッシュ等の異常が発生しない
場合,現用空間31は要求された処理を完了したら要求
メッセージに対する返信メッセージを送信空間1を宛先
として送信する.これを受け取ったカーネル2の返信メ
ッセージ監視処理部22は,当咳返信メッセージが正し
いものであることを認識し,これを送信空間1に送る.
現用空間31においてクラッシュ等の異常が発生した場
合,現用空間3lから待機空間32への切り替えが行わ
れる. 自動再送処理部21は.異常の発生及び空間の切り替え
があったことを認識すると,保存している要求メッセー
ジを待機空間32に対して送る.従って,要求メッセー
ジの同一性を保ちつつ,かつ送信空間lに何の負担も与
えることなく.要求メッセージを再送信できる. この再送信の際.ループ検出処理部23が,ループの検
出を行うと共に.ループの解消等の必要な処理を行う.
このようにカーネル2の自動再送処理部21が再送信を
行うのに伴ってカーネル2のルーブ検出処理部23がル
ープ検出を行うので9ループ検出を確実に行うと共に,
送信空間1への負担を無くすことができる. 再送信が行われた後,受信空間3においてクラッシェ等
の異常が発生しなければ,要求された処理の完了に伴っ
て受信空間3(現用空間31及び/又は待機空間32)
から,再送信された要求メッセージに対する返信メッセ
ージが送信される.一方,クラッシェ等の異常の発生の
タイミングによっては,クラッシェ前の要求メッセージ
に対する返信メッセージが送信されるような場合がある
.このような場合において.返信メッセージ監視処理部
22は,最も近い時刻に再送信された要求メッセージに
対する返信メッセージを選択し,これを送信空間1に送
信する.従って送信空間1はlつの要求メッセージに対
する返信メッセージを1つだけ受信することになるので
,受信空間3の異常について全く意識する必要がない. このように.カーネル2によって,フォールトトレラン
ト化のための要求メッセージの再送信及びその際の要求
メッセージの同一性の保障が行われるので.送信空間1
及び受信空間3の負担を小さくできる. 〔実施例〕 第2図は実施例説明図であり,データ処理装Iを示して
いる. 第2図において,11は自動再送付き要求メッセージ送
信処理部(要求メッセージ送信処理部),12は返信メ
ッセージ受信処理部,24は複写領域,33は返信メッ
セージ送信処理部である.送信空間1及び受信空間3は
.メッセージベースシステムである図示のデータ処理装
置において.メッセージ通信を行う者であり,例えば処
理プログラム,プロセス.中央処理装置,端末等である
.メッセージ通信の送信側である送信空間1は1要求メ
ッセージ送信処理部11及び返信メッセージ受信処理部
l2を備える. 要求メッセージ送信処理部l1は,ユーザの指定に応じ
て,要求メッセージを自動再送(要求)付き,又は自動
再送付きでないものとしたうえで,その送信処理を行う
.前者は.カーネル2に対して.要求メッセージについ
ての自動再送処理を依頼するためのものである.従って
,受信空間3の現用空間31にクラフシェが発生した場
合でも(ループ回数が少なければ),返信メッセージを
受け取ることができる.一方,後者は要求メッセージの
みを送信するものである.従って前記クラッシュ発生の
場合には.受信空間3に対する当該処理要求は中止され
る. 返信メンセージ受信処理部12は.要求メッセージの自
動再送処理が行われた場合でも,返信メッセージ監視処
理部22によって選択された正しい1つの返信メッセー
ジのみを受信する.また自動再送付きでない要求メッセ
ージが送信された場合には,返信メッセージ受信処理部
12は.クラッシュが発生した時にはクラッシュ通知を
受取る.これにより,通信メッセージを待つ状態が解か
れる. メッセージ通信の受信側である受信空間3は,現用空間
31にクラッシュが発生しても直ちに待機空間32によ
って活動を続行できるように2重化される.従って待機
空間32は現用空間3lと同一の論理構戒であり,返信
メッセージ送信処理部33は待機空間32と同様に現用
空間31にも存在する.現用空間3lと待機空間32と
の切り替えは.カーネル2又はオペレーティングシステ
ムによって行われる. 返信メッセージ送信処理部33は.当該空間における処
理に従って.返信メッセージを送信する.カーネル2は
.オペレーティングシステムの核又はスーパバイザであ
る. 自動再送処理部2lは.要求メッセージ送信処理部1l
から送信された要求メッセージを受取り,これを受信空
間3に送る.この時.この要求メッセージが自動再送付
きか否かを識別し,自動再送付きである場合に当該要求
メッセージをカーネル2内の複写領域24に複写し保存
する.そして.当該要求メッセージに何回目の送信であ
るかを示す再送回数を付加したうえで.これを受信空間
3に送る.最初の送信の時は再送回数一〇とされる.な
お,要求メッセージが自動再送付きでない場合には.前
記複写及び再送回数の付加は行われない.また,自動再
送処理部21は,受信空間3(現用空間31)でクラフ
シエが発生した場合,複写領域24から要求メッセージ
を取り出し,これを受信空間3(待機空間32)へ再送
信する.この時.再送回数を+1だけカウントアップし
て,これを要求メッセージに付加する. この再送信の際に.これに先立ってループ検出処理部2
3がループ検出を行う.即ち.再送回数が2以上であれ
ばループが構威されている可能性がある.そこで.ルー
プ検出処理部23は,再送回数即ちループ回数とみなし
,これが予め定めた値を越えているか否かを調べ,越え
ている場合にはループを解消するための処理を行う.返
信メッセージ監視処理部22は.返信メッセージ送信処
理部33から送信された返信メッセージを受取り,これ
を返信メッセージ受信処理部12へ送る.この時.この
返信メッセージが前述の如く正しいものか否かが調べら
れる.このために,要求メッセージ内の再送回数と返信
メッセージ内の再送回数とを照合する.返信メッセージ
送信処理部33が返信メッセージに再送回数(その返信
メッセージの対応する要求メッセージに付加されていた
再送回数)を付加したうえで.これを送信する.返信メ
ッセージ監視処理部22は.このようにして得られる2
つの再送回数が一致した場合には,当該返信メッセージ
は正しい(最も近い時刻に再送信した要求メッセージに
対するもの)と判断して,これを送信空間1へ送る.再
送回数が不一致の場合には,当該返信メッセージの送信
空間1への送信は行わない. 第3図は.メッセージ自動再送処理フローである. ■ 自動再送処理部21が.送信空間1からの要求メッ
セージを受取り,自動再送付きかを調べる.■ 自動再
送処理部21が,自動再送付きの場合に当該要求メッセ
ージを複写領域24に複写する.自動再送付きでない場
合には,複写を行わない.■ 自動再送処理部21が,
再送付き要求時に再送回数を付加した要求メッセージを
現用空間31に送信する. ■ 返信メッセージ監視処理部22が,受信空間3(待
機空間32)からのクラッシエ通知を受信し,自動再送
処理部21及びループ検出処理部23に通知する.即ち
,前記自動再送付きの場合,クラッシュ通知が送信空間
1に送られることはない.前記自動再送付きでない場合
,後述の処理[相]が行われる. ■ ループ検出処理部23が.ループ検出処理を行い.
再送回数が所定の値を越えていないかを調べる. ■ 所定の値を越えていない場合,この旨の通知を受け
た自動再送処理部21が.再送回数を+1だけカウント
アップする.そしてこの後.処理■即ち,要求メッセー
ジの再送信が行われる.所定の値を越えている場合.後
述の処理■が行われる.また.ループ回敗オーバのエラ
ーメッセージを送信空間1は受信する. ■ 返信メッセージ監視処理部22が.受信空間3から
の返信メッセージを受信する. ■ 返信メッセージ監視処理部22が,返信メッセージ
について再送回数が一致するかを調べる.一致しない場
合,以下の処理■及び[株]を行うことなく処理を終了
し.返信メッセージの受信を待つ. ■ 一致する場合.再送信の必要がなくなったので.複
写頌域24が返信メッセージ監視処理部22により解放
される. なお.処理■において再送回数が所定の値を越えている
場合にも,それ以上の再送信は行われないので,複写領
域24が解放される. ■ 返信メッセージ監視処理部22が返信メッセージを
受信し,これを宛先である送信空間1へ送信する. なお,要求メッセージが自動再送付きでない場合,クラ
ッシュ通知を受信した時はクラッシュ通知メッセージの
受信処理を行い.返信メッセージを受信した時は当該返
信メッセージの受信処理が行われる. 〔発明の効果〕 以上説明したように,本発明によれば.メッセージの自
動再送処理において5受信空間に異常が発生した場合に
これを送信空間に意識させることなくカーネルにより要
求メッセージの自動再送信を行うので.メッセージ通信
のフォールトトレラント機能を容易に実現でき,また,
このための負担がメッセージ通信を行う送信空間及び受
信空間にかからないようにすることができる.
[Detailed Description of the Invention] [Summary] Regarding the automatic message retransmission processing method by the kernel of the operating system, the purpose of this invention is to reduce the burden on those who communicate messages by realizing a fault-tolerant function. Sending a request message to the receiving space and sending a reply message from the receiving space to the sending space via a kernel, and retransmitting the request message to the receiving space when an abnormality occurs in the receiving space. In the data processing device that is used, an automatic retransmission processing unit and. Reply message monitoring processing unit. A loop detection processing unit is provided in the kernel. The automatic retransmission processing unit verifies the occurrence of the abnormality in the reception space and retransmits the request message that was previously transmitted from the transmission space to the reception space, and the reply message monitoring processing unit When the retransmission is performed, a correct one is selected from among the reply messages transmitted from the reception space and transmitted to the transmission space. The loop detection processing unit is configured to detect the loop during the retransmission. [Industrial Application Field] The present invention relates to an automatic message retransmission processing method. This paper concerns the automatic message retransmission processing method by the operating system kernel. Data is sent and received in the data processing system in the form of five messages. Therefore, a fault tolerant (FT) function has been implemented for sending and receiving messages, that is, a function that continues to provide service to the network without stopping even if an abnormality occurs in the system. [Prior Art] Figure 4 is an explanatory diagram of the prior art and shows the conventional message retransmission process. In Fig. 4, 1 is the transmission space. 2 is the kernel and 3 is the reception space. 31 is a working space of the reception space 3. 32 is a standby space in the reception space 3. A sending side, such as a processing program or process, ie, a sending space 1, sends a message requesting processing (request message) to a receiving side, such as another processing program or process, via the kernel 2 of the operating system. j In particular, it is transmitted to the currently active space (working space 31) among the receiving spaces 3 (
(■ in the figure). After this, if an abnormality such as a crash occurs in the current space 3l during message processing (■ in the figure), the current space 31
Kernel 2, which is monitoring
.. Furthermore, due to the occurrence of a crash, the Ijl space 31 switches to the standby space 32, which is the receiving space 3 paired with it (duplexed), and becomes active (■ in the figure). Sending space 1, which learned of the occurrence of the crash, sends a request message via kernel 2. It is retransmitted to the standby space 32, which is the currently active receiving space (■ in the figure). The standby space 32 receives the request message. Upon completion of the process, a reply message is sent to sending space l via kernel 2 (■ in the figure), and sending space 1 receives this (■ in the figure). As described above, the fault-tolerant function against crashes in the working space 31 is mainly realized by the transmitting space 1. Also. If the cause of a crash in the active space 31 is a bug in the processing program on the receiving side, such as an input-dependent bug, the same crash will occur in the standby space 32,
It cannot be processed normally. As a result, an (infinite) loop may occur where the request message is repeatedly retransmitted or clanked. Therefore, loop detection processing is performed before retransmission (O in the figure). When the number of loops exceeds a predetermined value, appropriate processing is performed to eliminate the loop. Therefore, a fault-tolerant function for the loop is realized by the transmission space l. (Object to be Solved by the Invention [111]) According to the prior art described above, the process (■ in the figure) of retransmitting a request message by recognizing reception space switching based on a crash and crash notification is as follows. Transmission space 1 must do this. on the other hand. The content of the retransmitted request message must be managed by the side that uses it, that is, the receiving side (receiving space 3). Therefore, the receiving side must have a function to check whether the contents of the request message received from the second time onwards are the same as the first one. Also. As mentioned above, there is a possibility that a loop may occur, so it is necessary for the transmission space 1 to detect this loop. Conventionally, like this. Fault-tolerant functions for sending and receiving messages are provided by those who communicate messages. That is, it was realized by a transmission space 1 and a reception space 3 (processing program or process). That is. From the perspective of those who communicate messages, especially from the transmission space l, there is no structure in which request messages are automatically retransmitted for fault tolerance. Therefore, for those who communicate messages. There was a problem in that the burden of implementing fault-tolerant functionality was large. The purpose of the present invention is to provide an automatic message retransmission processing method that reduces the burden on those who communicate messages to realize a fault-tolerant function. [Means for solving the problem] Figure 1 is a diagram showing the principle structure of the present invention. 1 shows a data processing device according to the present invention. In FIG. 1, 1 is a transmission space, 2 is a kernel, 3 is a reception space, and 21 is an automatic retransmission processing unit. 22 is a reply message monitoring processing section, 23 is a loop detection processing section, 31 is a working space in the receiving space 3, and 32 is a standby space in the receiving space 3. The sending space l sends a request message (a message requesting processing) to the receiving space 3 via the kernel 2. The reception space 3 is. When a request message is received, perform the processing requested by the score request message. And once the process is complete. The receiving space 3 transmits a reply message to the request message to the transmitting space 1 via the power channel 2. This will notify you that the process has completed. The receiving space 3 is duplicated in case an abnormality such as a crash occurs. It consists of a working space 3l, which is currently active, and a standby space 32, which is waiting. If an abnormality occurs in the working space 3l of the receiving space 3. After the reception space 3 is switched from the working space 31 to the standby space 32. The request message is retransmitted to the waiting space 32, which is the receiving space 3. The requested process can be completed. Kernel 2 performs message communication services such as sending the above-mentioned request messages and reply messages, and also performs automatic retransmission processing of request messages. For this. Automatic retransmission processing unit 21. A reply message monitoring processing section 22 and a loop detection processing section 23 are provided in the kernel 2. The automatic retransmission processing unit 2l is a working space 3 of the receiving space 3.
Recognize that an abnormality such as a crash has occurred in l, and that this has caused the space to switch as described above.
Then, the request message sent from the sending space 1 to the receiving space 3 before the occurrence of the abnormality is retransmitted to the standby space 32 of the receiving space 3 (which is considered to be the working space). The reply message monitoring processing unit 22. Monitor reply messages. When the request message is retransmitted, the correct reply message sent from receiving space 3 (working space 3l and/or standby space 32), Wi, and retransmitted at the closest time. Select only the reply message to the request message and send it to transmission space 1. The loop detection processing section 23. When retransmitting a request message. Detects the occurrence of an abnormality such as a crash in the reception space 3, or a loop in which request messages are repeatedly retransmitted. [Operation] Kernel 2 is configured such that the transmission space l is the working space 31 of the reception space 3.
It receives the request message sent with the destination as the destination and sends it to the working space 31. At this time. The automatic retransmission processing unit 2l is
Copy and save the request message. If no abnormality such as a crash occurs in the working space 31, the working space 31 completes the requested processing and then sends a reply message to the request message with the sending space 1 as the destination. The reply message monitoring processing unit 22 of the kernel 2 that receives this recognizes that the cough reply message is correct and sends it to the transmission space 1.
When an abnormality such as a crash occurs in the active space 31, the active space 3l is switched to the standby space 32. The automatic retransmission processing unit 21. When it recognizes that an abnormality has occurred and the space has been switched, it sends the stored request message to the standby space 32. Therefore, the identity of the request message is maintained, and no burden is placed on the transmission space. You can resend the request message. During this retransmission. The loop detection processing unit 23 detects loops. Perform necessary processing such as eliminating loops.
In this way, as the automatic retransmission processing section 21 of the kernel 2 performs retransmission, the rube detection processing section 23 of the kernel 2 performs loop detection, so that nine loops are detected reliably, and
The burden on the transmission space 1 can be eliminated. After retransmission, if no abnormalities such as crashes occur in the receiving space 3, the receiving space 3 (working space 31 and/or standby space 32)
A reply message to the retransmitted request message is sent from On the other hand, depending on the timing of an abnormality such as a crash, a reply message may be sent to the request message before the crash. In such cases. The reply message monitoring processing unit 22 selects a reply message to the request message retransmitted at the closest time, and transmits it to the transmission space 1. Therefore, since the sending space 1 receives only one reply message for one request message, there is no need to be aware of any abnormalities in the receiving space 3. in this way. Kernel 2 retransmits the request message for fault tolerance and guarantees the identity of the request message at that time. Transmission space 1
And the burden on the receiving space 3 can be reduced. [Embodiment] Figure 2 is an explanatory diagram of an embodiment, and shows data processing device I. In FIG. 2, 11 is a request message transmission processing section with automatic retransmission (request message transmission processing section), 12 is a reply message reception processing section, 24 is a copy area, and 33 is a reply message transmission processing section. Transmission space 1 and reception space 3 are . In the illustrated data processing device which is a message-based system. A person who communicates messages, such as a processing program or process. Central processing units, terminals, etc. The transmission space 1, which is the transmission side of message communication, includes a 1-request message transmission processing section 11 and a reply message reception processing section 12. The request message transmission processing unit l1 sends the request message with or without automatic retransmission (request) according to the user's specifications, and then performs transmission processing. The former is. For kernel 2. This is used to request automatic retransmission processing for request messages. Therefore, even if Kraftshe occurs in the working space 31 of the receiving space 3 (if the number of loops is small), a reply message can be received. On the other hand, the latter sends only request messages. Therefore, in the case of the above crash. The processing request for reception space 3 is canceled. The reply message reception processing section 12. Even if automatic retransmission processing of the request message is performed, only one correct reply message selected by the reply message monitoring processing section 22 is received. In addition, if a request message without automatic resending is sent, the reply message reception processing unit 12. Receive crash notifications when a crash occurs. This releases the state of waiting for a communication message. The receiving space 3, which is the receiving side of message communication, is redundant so that even if a crash occurs in the working space 31, the standby space 32 can immediately continue its activities. Therefore, the standby space 32 has the same logical structure as the current space 3l, and the reply message transmission processing section 33 exists in the current space 31 as well as the standby space 32. Switching between the working space 3l and the standby space 32 is as follows. This is done by the kernel 2 or operating system. The reply message transmission processing section 33. According to the processing in the space. Send a reply message. Kernel 2 is. It is the core or supervisor of the operating system. The automatic retransmission processing unit 2l. Request message transmission processing unit 1l
Receives the request message sent from and sends it to reception space 3. At this time. It is determined whether this request message includes automatic retransmission or not, and if automatic retransmission is included, the request message is copied and stored in the copy area 24 in the kernel 2. and. After adding the number of retransmissions indicating the number of times the request message has been sent. Send this to reception space 3. For the first transmission, the number of retransmissions is 10. In addition, if the request message does not have automatic resending. The above-mentioned copying and retransmission counts are not added. Furthermore, when a clafsier occurs in the reception space 3 (active space 31), the automatic retransmission processing unit 21 extracts the request message from the copy area 24 and retransmits it to the reception space 3 (standby space 32). At this time. Count up the number of retransmissions by +1 and add this to the request message. During this retransmission. Prior to this, loop detection processing section 2
3 performs loop detection. That is. If the number of retransmissions is 2 or more, a loop may be occurring. Therefore. The loop detection processing unit 23 regards the number of retransmissions, that is, the number of loops, and checks whether this exceeds a predetermined value, and if it does, performs processing to eliminate the loop. The reply message monitoring processing unit 22. It receives the reply message sent from the reply message transmission processing section 33 and sends it to the reply message reception processing section 12. At this time. It is checked whether this reply message is correct as described above. For this purpose, the number of retransmissions in the request message is compared with the number of retransmissions in the reply message. The reply message transmission processing unit 33 adds the number of retransmissions (the number of retransmissions added to the request message to which the reply message corresponds) to the reply message. Send this. The reply message monitoring processing unit 22. 2 obtained in this way
If the two retransmission counts match, the reply message is judged to be correct (for the request message retransmitted at the closest time) and sent to transmission space 1. If the number of retransmissions does not match, the reply message is not sent to transmission space 1. Figure 3 is. This is the message automatic retransmission processing flow. ■ The automatic retransmission processing unit 21. Receive the request message from sending space 1 and check whether automatic retransmission is enabled. ■ The automatic retransmission processing unit 21 copies the request message to the copy area 24 when automatic retransmission is included. Copying is not performed unless automatic retransmission is enabled. ■ The automatic retransmission processing unit 21
When making a request with retransmission, a request message with the number of retransmissions added is sent to the working space 31. ■ The reply message monitoring processing section 22 receives the Crassier notification from the reception space 3 (standby space 32), and notifies the automatic retransmission processing section 21 and the loop detection processing section 23. That is, in the case with automatic retransmission, no crash notification is sent to transmission space 1. If the above-mentioned automatic retransmission is not included, the processing [phase] described below is performed. ■ The loop detection processing section 23. Perform loop detection processing.
Check whether the number of retransmissions exceeds a specified value. ■ If the predetermined value is not exceeded, the automatic retransmission processing unit 21 receives this notification. Count up the number of retransmissions by +1. And after this. Process ■, that is, the request message is retransmitted. If it exceeds the specified value. The process ■ described below is performed. Also. Transmission space 1 receives an error message indicating that the loop has failed. ■ The reply message monitoring processing unit 22. Receive the reply message from reception space 3. ■ The reply message monitoring processing unit 22 checks whether the number of retransmissions of the reply messages matches. If they do not match, terminate the process without performing the following process ■ and [Stock]. Wait for the reply message to be received. ■ If they match. There is no longer a need for retransmission. The copy area 24 is released by the reply message monitoring processing section 22. In addition. Even if the number of retransmissions exceeds a predetermined value in process (2), no further retransmissions are performed and the copy area 24 is released. ■ The reply message monitoring processing unit 22 receives the reply message and transmits it to the destination transmission space 1. Furthermore, if the request message does not have automatic resending, when a crash notification is received, the crash notification message reception process is performed. When a reply message is received, the reception process for the reply message is performed. [Effects of the Invention] As explained above, according to the present invention. When an abnormality occurs in the 5 receiving space during automatic message retransmission processing, the request message is automatically retransmitted by the kernel without making the sending space aware of this. Fault-tolerant functions for message communication can be easily realized, and
This burden can be avoided on the sending space and receiving space for message communication.

【図面の簡単な説明】[Brief explanation of drawings]

第1図は本発明の原理構戒図. 第2図は実施例説明図, 第3図はメッセージ自動再送処理フロー第4図は従来技
術説明図. 1は送信空間,2はカーネル.3は受信空間.21は自
動再送処理部,22は返信メッセージ監視処理部,23
はループ検出処理部,31は受信空間3のうちの現用空
間. 32は受信空間3のう ちの待機空間である.
Figure 1 shows the principle structure of the present invention. Fig. 2 is an explanatory diagram of an embodiment, and Fig. 3 is a message automatic retransmission processing flow. Fig. 4 is an explanatory diagram of a conventional technique. 1 is the transmission space, 2 is the kernel. 3 is the receiving space. 21 is an automatic retransmission processing section, 22 is a reply message monitoring processing section, 23
3 is a loop detection processing unit, and 31 is a working space in the receiving space 3. 32 is a standby space in the reception space 3.

Claims (1)

【特許請求の範囲】 送信空間(1)から受信空間(3)への要求メッセージ
の送信及び前記受信空間(3)から前記送信空間(1)
への前記要求メッセージに対する返信メッセージの送信
をカーネル(2)を介して行うと共に、前記受信空間(
3)に異常が発生した場合に前記要求メッセージが前記
受信空間(3)に再送信されるデータ処理装置において
、 前記要求メッセージの前記再送信を行う自動再送処理部
(21)と、 前記返信メッセージの監視を行う返信メッセージ監視処
理部(22)と、 前記異常の発生ないし前記再送信が繰り返されるループ
の検出を行うループ検出処理部(23)とを前記カーネ
ル(2)に設け、 前記自動再送処理部(21)が前記受信空間(3)にお
ける前記異常の発生を認識して前記送信空間(1)から
先に送信された前記要求メッセージについて前記受信空
間(3)への前記再送信を行い、前記返信メッセージ監
視処理部(22)が前記再送信が行われた場合に前記受
信空間(3)から送信された前記返信メッセージのうち
正しいものを選択してこれを前記送信空間(1)に送信
し、 前記ループ検出処理部(23)が前記再送信の際に前記
ループの検出を行う ことを特徴とするメッセージの自動再送処理方式。
[Claims] Transmission of a request message from the transmission space (1) to the reception space (3) and from the reception space (3) to the transmission space (1)
A reply message to the request message is sent to the receiving space (2) via the kernel (2).
3) in a data processing device that retransmits the request message to the reception space (3) when an abnormality occurs, comprising: an automatic retransmission processing unit (21) that retransmits the request message; and an automatic retransmission processing unit (21) that retransmits the request message; The kernel (2) is provided with a reply message monitoring processing unit (22) that monitors the automatic retransmission, and a loop detection processing unit (23) that detects the occurrence of the abnormality or a loop in which the retransmission is repeated. A processing unit (21) recognizes the occurrence of the abnormality in the reception space (3) and retransmits the request message that was previously transmitted from the transmission space (1) to the reception space (3). , the reply message monitoring processing unit (22) selects a correct reply message from among the reply messages sent from the reception space (3) when the retransmission is performed, and sends it to the transmission space (1). An automatic message retransmission processing method, characterized in that the loop detection processing unit (23) detects the loop at the time of the retransmission.
JP1188269A 1989-07-20 1989-07-20 Data processing device Expired - Lifetime JPH0827768B2 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP1188269A JPH0827768B2 (en) 1989-07-20 1989-07-20 Data processing device

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP1188269A JPH0827768B2 (en) 1989-07-20 1989-07-20 Data processing device

Publications (2)

Publication Number Publication Date
JPH0352048A true JPH0352048A (en) 1991-03-06
JPH0827768B2 JPH0827768B2 (en) 1996-03-21

Family

ID=16220716

Family Applications (1)

Application Number Title Priority Date Filing Date
JP1188269A Expired - Lifetime JPH0827768B2 (en) 1989-07-20 1989-07-20 Data processing device

Country Status (1)

Country Link
JP (1) JPH0827768B2 (en)

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US7815560B2 (en) 2005-09-26 2010-10-19 Hitachi Koki Co., Ltd. Centrifuge having pivotally supported door

Cited By (1)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US7815560B2 (en) 2005-09-26 2010-10-19 Hitachi Koki Co., Ltd. Centrifuge having pivotally supported door

Also Published As

Publication number Publication date
JPH0827768B2 (en) 1996-03-21

Similar Documents

Publication Publication Date Title
US20040001449A1 (en) System and method for supporting automatic protection switching between multiple node pairs using common agent architecture
US6868067B2 (en) Hybrid agent-oriented object model to provide software fault tolerance between distributed processor nodes
JPH04217136A (en) Communication systems that guarantee data integrity
JPH10136053A (en) Data retransmission method in confirmation type information transfer
KR20030048503A (en) Communication system and method for data synchronization of duplexing server
JPH0827768B2 (en) Data processing device
JP6182779B1 (en) Transfer device, transfer method, and program
CN100456771C (en) Communication device and interaction method among modules therein
JP2756733B2 (en) Information processing device
JP3990742B2 (en) Message processing system
JP2757847B2 (en) Double reception avoidance method in basic procedure
Shima et al. Fault-tolerant causal delivery in group communication
JPH03117242A (en) Retrial method for data transmission
KR930006033B1 (en) Method for transceiving messages between processors in electronic switching system
JP2001297016A (en) Instruction execution system
JPH05265989A (en) Multiprocessor system
JP2605507B2 (en) Data restoration method
JP3084383B2 (en) Ring communication path failure processing method
JPH02310755A (en) Health check system
JPH1013417A (en) Configuration definition information update method
JPS61244149A (en) Data transmission system
JPS63266549A (en) Automatic system switching method
JPH08149153A (en) Virtual buffer control system in relay computer
JPS58221523A (en) Fault monitoring system of data transmission
JPH0816532A (en) Message communication processing method

Legal Events

Date Code Title Description
FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20080321

Year of fee payment: 12

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20090321

Year of fee payment: 13

FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20100321

Year of fee payment: 14

EXPY Cancellation because of completion of term
FPAY Renewal fee payment (event date is renewal date of database)

Free format text: PAYMENT UNTIL: 20100321

Year of fee payment: 14