JPH05181732A - File updating system in distributed processing - Google Patents

File updating system in distributed processing

Info

Publication number
JPH05181732A
JPH05181732A JP3346050A JP34605091A JPH05181732A JP H05181732 A JPH05181732 A JP H05181732A JP 3346050 A JP3346050 A JP 3346050A JP 34605091 A JP34605091 A JP 34605091A JP H05181732 A JPH05181732 A JP H05181732A
Authority
JP
Japan
Prior art keywords
processing
file
update
counter
distributed
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
JP3346050A
Other languages
Japanese (ja)
Inventor
Masashi Akiyama
正史 秋山
Tsukasa Sasaki
司 佐々木
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.)
NEC Corp
NEC Solution Innovators Ltd
Original Assignee
NEC Corp
NEC Solution Innovators 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 NEC Corp, NEC Solution Innovators Ltd filed Critical NEC Corp
Priority to JP3346050A priority Critical patent/JPH05181732A/en
Publication of JPH05181732A publication Critical patent/JPH05181732A/en
Pending legal-status Critical Current

Links

Landscapes

  • Information Retrieval, Db Structures And Fs Structures Therefor (AREA)

Abstract

PURPOSE:To effectively utilize this file updating system for large data capacity, variable data capacity, or processing requesting extreme shortage of shared time and occupied time by judging a restoring position based upon information stored in an updating frequency counter and then executing restoring processing. CONSTITUTION:A terminal equipment program 1 and a central processing unit(CPU) program 2 are mutually cooperated to update a center file 4. In the file updating system for distributed processing, information is stored in the updating frequency counter in each generation of updating of the file 4, and at the time of restoring data due to the generation of a fault, a restoring position is judged by the information stored in the counter 7 and its restoring processing is executed. Thereby the file updating system can be effectively utilized for large capacity like file updating for distributed transaction processing and processing requesting the extreme shortage of shared time and occupied time.

Description

【発明の詳細な説明】Detailed Description of the Invention

【0001】[0001]

【産業上の利用分野】本発明は、端末機、中央処理装置
間での分散処理を行うコンピュータシステムに利用し、
殊に、分散トランザクション処理でのファイル更新を行
う分散処理におけるファイル更新方式に関する。
BACKGROUND OF THE INVENTION 1. Field of the Invention The present invention is used in a computer system for distributed processing between terminals and central processing units,
In particular, the present invention relates to a file update method in distributed processing for updating files in distributed transaction processing.

【0002】[0002]

【従来の技術】従来、端末機と中央処理装置間で処理を
分散してセンタファイルを更新する場合、図4に示すよ
うに、端末機プログラム1と中央処理装置プログラム2
との間の複数回にわたるデータ送受信3の最後にセンタ
ファイル4を一括更新している。あるいは図5に示すよ
うに、センタファイルの全部または一部を端末機プログ
ラム1に転送し、端末機プログラム1側で加工して中央
処理装置プログラム2に再転送するのが一般的である。
2. Description of the Related Art Conventionally, when processing is distributed between a terminal and a central processing unit to update a center file, as shown in FIG. 4, a terminal program 1 and a central processing unit program 2 are used.
The center file 4 is collectively updated at the end of a plurality of times of data transmission / reception 3 between and. Alternatively, as shown in FIG. 5, it is common to transfer all or part of the center file to the terminal program 1, process it on the terminal program 1 side, and retransfer to the central processing unit program 2.

【0003】これらは、障害発生時のデータ復旧処理が
簡単なことが特徴である。すなわち、図4に示す例で
は、最終的なデータ送受信3のタイミングでセンタファ
イルを一括更新しており、それ以前の障害発生において
はデータ復旧の必要がなく、一括更新時のみのデータ復
旧に対応すればよい。また、図5に示す例では、障害が
発生した場合、障害を引き起こしたデータは廃棄して再
処理すればよい。
These are characterized by a simple data recovery process when a failure occurs. That is, in the example shown in FIG. 4, the center file is collectively updated at the timing of the final data transmission / reception 3, and there is no need for data recovery in the event of a failure before that, and data recovery is possible only during collective update. do it. Further, in the example shown in FIG. 5, when a failure occurs, the data causing the failure may be discarded and reprocessed.

【0004】[0004]

【発明が解決しようとする課題】しかしながら、従来の
分散処理におけるファイル更新方式にあって、図4に示
す例では、1回目、2回目の送信データはメモリ中に蓄
積しなければならず、データ容量が大きい場合、またデ
ータ容量が可変の場合に効果的な処理ができないという
欠点がある。
However, in the file updating method in the conventional distributed processing, in the example shown in FIG. 4, the first and second transmission data must be accumulated in the memory. There is a drawback that effective processing cannot be performed when the capacity is large or when the data capacity is variable.

【0005】図5に示す例では、センタファイルのデー
タを長時間、排他的に使用しているためデータの共有化
時間、占有時間の極小化が要求されるトランザクション
処理での利用に困難を伴うという欠点がある。
In the example shown in FIG. 5, since the data in the center file is exclusively used for a long time, it is difficult to use it in a transaction process which requires minimization of data sharing time and occupation time. There is a drawback.

【0006】本発明は、このような課題を解決するもの
であり、分散トランザクション処理におけるファイル更
新のように、データ容量が大きい場合、またデータ容量
が可変の場合、およびデータの共有化時間、占有時間の
極小化が要求される処理での効果的な利用ができる分散
処理におけるファイル更新方式を提供することを目的と
する。
The present invention solves such a problem, and when the data capacity is large, such as file update in distributed transaction processing, or when the data capacity is variable, and the sharing time and occupation of the data. An object of the present invention is to provide a file updating method in distributed processing that can be effectively used in processing that requires minimum time.

【0007】[0007]

【課題を解決するための手段】この目的を達成するため
に、本発明は、端末機プログラムと中央処理装置プログ
ラムとが相互に連携してセンタファイルを更新する分散
処理におけるファイル更新方式において、センタファイ
ル更新の発生毎に更新回数カウンタに情報を収納し、こ
の後、障害が発生してデータ復旧を行う場合に、更新回
数カウンタに収納した情報により復旧箇所を判断して復
旧処理を行うことを特徴とするものである。
In order to achieve this object, the present invention provides a file updating method in distributed processing in which a terminal program and a central processing unit program cooperate with each other to update a center file. Whenever a file update occurs, information is stored in the update count counter, and after that, when a failure occurs and data recovery is performed, it is possible to judge the recovery location from the information stored in the update count counter and perform recovery processing. It is a feature.

【0008】さらに、更新回数カウンタは端末機ID、
処理一連番号および更新回数カウンタが連続して設けら
れることを特徴とするものである。
Further, the update counter is a terminal ID,
It is characterized in that a processing serial number and an update counter are continuously provided.

【0009】また、記載の処理および構成がコンピュー
タシステムの分散トランザクション処理におけるファイ
ル更新に適用されることを特徴とするものである。
Further, the above-described processing and configuration are applied to file updating in distributed transaction processing of a computer system.

【0010】[0010]

【実施例】以下、本発明の分散処理におけるファイル更
新方式の実施例について図面をもとに説明する。
DETAILED DESCRIPTION OF THE PREFERRED EMBODIMENTS An embodiment of a file updating system in distributed processing according to the present invention will be described below with reference to the drawings.

【0011】図1は、実施例が適用される分散トランザ
クション処理を示している。
FIG. 1 shows distributed transaction processing to which the embodiment is applied.

【0012】ここでは、例として端末機と中央処理装置
の各プログラム間で3回のデータ送受信を行い、それぞ
れセンタファイルを更新することにより処理が完結する
ようになっている。
Here, as an example, data is transmitted and received three times between the programs of the terminal and the central processing unit, and the processing is completed by updating the center file respectively.

【0013】図1において、1は端末機プログラム、2
は中央処理装置プログラム、3はデータ送受信の動作を
示す。4はセンタファイル、6は排他利用フラグ、7は
更新回数カウンタ、8は処理一連番号カウンタ、9は障
害フラグである。
In FIG. 1, 1 is a terminal program, 2
Is a central processing unit program, and 3 is a data transmission / reception operation. Reference numeral 4 is a center file, 6 is an exclusive use flag, 7 is an update counter, 8 is a processing serial number counter, and 9 is a failure flag.

【0014】次に、この構成の動作について説明する。Next, the operation of this configuration will be described.

【0015】図2は更新回数カウンタ7の内容を示して
いる。また、図3は中央処理装置プログラム2で実行さ
れる復旧処理手順を示している。
FIG. 2 shows the contents of the update counter 7. Further, FIG. 3 shows a recovery processing procedure executed by the central processing unit program 2.

【0016】図1において、端末機からトランザクショ
ン処理が要求されると、端末機プログラム1は処理一連
番号カウンタ8から処理一連番号を採番し、データとと
もに中央処理装置プログラム2に送信する。
In FIG. 1, when a transaction processing is requested from the terminal, the terminal program 1 assigns a processing serial number from the processing serial number counter 8 and sends it to the central processing unit program 2 together with the data.

【0017】中央処理装置プログラム2ではステップa
において排他利用フラグ6をオンにしてトランザクショ
ンで利用するデータを占有し、データをセンタファイル
4に書き込む。また、端末機ID10、処理一連番号1
に端末機プログラム1からのデータをセットし、更新回
数カウンタ7に1をセットする。図2に示すように、更
新回数カウンタ7は端末機、処理一連番号ごとに、セン
タファイルの更新回数が判断できるようになっている。
その後ここまでの処理を確定する。
In the central processing unit program 2, step a
In step 1, the exclusive use flag 6 is turned on to occupy the data used in the transaction, and the data is written to the center file 4. Also, terminal ID10, processing serial number 1
The data from the terminal program 1 is set in, and the update counter 7 is set to 1. As shown in FIG. 2, the update count counter 7 can determine the update count of the center file for each terminal and processing serial number.
After that, the processing up to this point is confirmed.

【0018】これを受けた端末機プログラム1では、さ
らに2回目のデータを中央処理装置プログラム2に送信
する。中央処理装置プログラム2ではステップbにおい
て前回同様センタファイルにデータを書き込んだ後、更
新回数カウンタ7に2をセットし、処理を確定する。
In response to this, the terminal program 1 transmits the second data to the central processing unit program 2. In the central processing unit program 2, after writing the data to the center file in step b as in the previous time, the update number counter 7 is set to 2 and the processing is confirmed.

【0019】同様にしてステップcで3回目のデータを
センタファイルに書き込んだ後に更新回数カウンタ7に
2をセットし、排他利用フラグをオフにし、処理を確定
する。このようにしてトランザクション処理を行う。
Similarly, after writing the third data in the center file in step c, the update counter 7 is set to 2, the exclusive use flag is turned off, and the processing is confirmed. Transaction processing is performed in this manner.

【0020】次に、障害が発生し、トランザクション処
理が異常終了した場合のデータ復旧について説明する。
Next, data recovery when a failure occurs and transaction processing ends abnormally will be described.

【0021】図3において、端末機プログラム1から中
央処理装置プログラム2に対し、復旧処理の要求が判断
される(ステップ(図中、Sと記載する)100)。こ
のS100で、復旧処理の要求がないNoの場合、処理
終了となる。また、復旧処理の要求があるYesの場
合、先ず、処理一連番号カウンタ8と処理一連番号1を
比較する(ステップ101)。ここで処理一連番号カウ
ンタ8のほうが大きいNoの場合、センタファイルの更
新が一度も発生していない判断できるので復旧処理を終
了する(ステップ102)。
In FIG. 3, a request for restoration processing is judged from the terminal program 1 to the central processing unit program 2 (step (denoted by S in the figure) 100). In S100, if the request for the recovery process is No, the process ends. If the request for recovery processing is Yes, the process serial number counter 8 and the process serial number 1 are first compared (step 101). If the processing sequence number counter 8 has a larger No, it can be determined that the center file has not been updated at all, so the recovery processing ends (step 102).

【0022】次に、処理一連番号カウンタ8と処理一連
番号1が合致したとする場合には、更新回数カウンタ7
の内容にしたがう(ステップ103,104,10
5)。
Next, when it is assumed that the processing serial number counter 8 and the processing serial number 1 match, the update number counter 7
(Steps 103, 104, 10
5).

【0023】ステップ103で更新回数カウンタ7が1
のYesの場合はステップaの処理が終了しているの
で、ステップaの処理を無効にする(ステップ10
4)。この後、更新回数カウンタ7を3にし、処理一連
番号マイナス1にする処理を行う(ステップ105)。
In step 103, the update counter 7 is set to 1
If Yes, the process of step a has been completed, so the process of step a is invalidated (step 10
4). After that, the update number counter 7 is set to 3 and the processing serial number is decreased to 1 (step 105).

【0024】ステップ103でNoの場合、更新回数カ
ウンタ7の2が判断される(ステップ106)。ここで
2であるYesの場合ステップaとbの処理が終了して
いるので、ステップaとbの処理を無効にする(ステッ
プ107)。続いて、更新回数カウンタ7を3にし、処
理一連番号マイナス1にする処理を行う(ステップ10
8)。ステップ106でNoの場合、更新回数カウンタ
7が3であり、センタファイルの更新は完結していると
判断できるので復旧処理を終了する(ステップ10
9)。
When the result in step 103 is No, the update counter 7 is judged to be 2 (step 106). If the answer is 2 here, the processing in steps a and b has been completed, so the processing in steps a and b is invalidated (step 107). Then, the update number counter 7 is set to 3 and the processing serial number is decreased to 1 (step 10).
8). In the case of No in step 106, the update counter 7 is 3, and it can be determined that the update of the center file has been completed, so the recovery process is terminated (step 10).
9).

【0025】[0025]

【発明の効果】以上の説明から明らかなように、本発明
の分散処理におけるファイル更新方式は、センタファイ
ル更新の発生毎に更新回数カウンタに情報を収納し、こ
の後、障害が発生してデータ復旧を行う場合に、更新回
数カウンタに収納した情報により復旧箇所を判断して復
旧処理を行うようにしているので、分散トランザクショ
ン処理におけるファイル更新のようにデータ容量が大き
い場合、またデータ容量が可変の場合、およびデータの
共有化時間、占有時間の極小化が要求される処理での効
果的な利用ができるという効果を有する。
As is apparent from the above description, in the file updating method in the distributed processing of the present invention, information is stored in the update counter every time a center file is updated, and thereafter, a failure occurs and data is lost. When performing restoration, the restoration location is determined based on the information stored in the update counter, and restoration processing is performed. Therefore, when the data volume is large, such as when updating files in distributed transaction processing, the data volume can be changed. In the case of, and the effect that it can be effectively used in the processing that requires the minimum sharing time and occupation time of data.

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

【図1】本発明の分散処理におけるファイル更新方式の
実施例における端末機および中央処理装置のプログラム
処理を示す図である。
FIG. 1 is a diagram showing program processing of a terminal unit and a central processing unit in an embodiment of a file updating method in distributed processing of the present invention.

【図2】図1における更新回数カウンタの内容を示す図
である。
FIG. 2 is a diagram showing the contents of an update counter in FIG.

【図3】図2における中央処理装置プログラムで実行さ
れる復旧処理手順を示すフローチャートである。
3 is a flowchart showing a recovery processing procedure executed by the central processing unit program in FIG.

【図4】従来例の説明に供され、端末機および中央処理
装置のプログラム処理を示す図である。
FIG. 4 is a diagram illustrating a program process of a terminal unit and a central processing unit, which is used for explaining a conventional example.

【図5】従来例の説明に供され、他の端末機および中央
処理装置のプログラム処理を示す図である。
FIG. 5 is a diagram illustrating a program process of another terminal device and a central processing unit, which is used for explaining a conventional example.

【符号の説明】[Explanation of symbols]

1 端末機プログラム 2 中央処理装置プログラム 3 データ送受信の動作経路 4 センタファイル 6 排他利用フラグ 7 更新回数カウンタ 8 処理一連番号カウンタ 9 障害フラグ 10 端末機ID 1 Terminal Program 2 Central Processing Unit Program 3 Data Transmission / Reception Operation Path 4 Center File 6 Exclusive Use Flag 7 Update Counter 8 Processing Serial Number Counter 9 Failure Flag 10 Terminal ID

Claims (3)

【特許請求の範囲】[Claims] 【請求項1】端末機プログラムと中央処理装置プログラ
ムとが相互に連携してセンタファイルを更新する分散処
理におけるファイル更新方式において、 センタファイル更新の発生毎に更新回数カウンタに情報
を収納し、この後、障害が発生してデータ復旧を行う場
合に、前記更新回数カウンタに収納した情報により復旧
箇所を判断して復旧処理を行うことを特徴とする分散処
理におけるファイル更新方式。
1. In a file updating method in a distributed process in which a terminal program and a central processing unit program cooperate with each other to update a center file, information is stored in an update counter every time a center file is updated. After that, when a failure occurs and data recovery is performed, the recovery processing is performed by determining the recovery location based on the information stored in the update counter, and the file update method in distributed processing.
【請求項2】更新回数カウンタは端末機ID、処理一連
番号および更新回数カウンタが連続して設けられること
を特徴とする請求項1記載の分散処理におけるファイル
更新方式。
2. The file updating method in the distributed processing according to claim 1, wherein the update number counter is provided with a terminal ID, a processing serial number and an update number counter in succession.
【請求項3】請求項1または2記載の処理および構成が
コンピュータシステムの分散トランザクション処理にお
けるファイル更新に適用されることを特徴とする分散処
理におけるファイル更新方式。
3. A file updating method in distributed processing, wherein the processing and configuration according to claim 1 or 2 is applied to file updating in distributed transaction processing of a computer system.
JP3346050A 1991-12-27 1991-12-27 File updating system in distributed processing Pending JPH05181732A (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP3346050A JPH05181732A (en) 1991-12-27 1991-12-27 File updating system in distributed processing

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP3346050A JPH05181732A (en) 1991-12-27 1991-12-27 File updating system in distributed processing

Publications (1)

Publication Number Publication Date
JPH05181732A true JPH05181732A (en) 1993-07-23

Family

ID=18380801

Family Applications (1)

Application Number Title Priority Date Filing Date
JP3346050A Pending JPH05181732A (en) 1991-12-27 1991-12-27 File updating system in distributed processing

Country Status (1)

Country Link
JP (1) JPH05181732A (en)

Similar Documents

Publication Publication Date Title
JPH04284548A (en) Data base exclusive controlling system
CN112667270A (en) Method for updating speech processing resources, computer equipment and storage device
JPH05181732A (en) File updating system in distributed processing
JPS623361A (en) Status report system
JP2001109642A (en) Cluster system and data copying method thereof
JPH02171846A (en) Transaction processing system
CN114363221A (en) Heartbeat detection method based on micro-service system, storage medium, electronic device and system
JP2645065B2 (en) Information download system
CN113282570B (en) Block link point allocation method, computer device and storage medium
JP2652989B2 (en) File transfer device
JP2973724B2 (en) Interrupt control method
JP3043265B2 (en) Timer control method
CN117112139A (en) Cluster capacity reduction method, device, equipment and computer readable storage medium
CN113468195A (en) Server data cache updating method and system and main database server
KR20020063365A (en) Real time memory management method of multi processor system
EP0877330A2 (en) Circuit verification process for semiconductor devices
CN111858642A (en) Data set update method, related device and readable storage medium
JP2021149293A (en) Information processing device, method, and program
JPS61151746A (en) Processing method of data error
JPH0926943A (en) Data communication method and device
JPH0396040A (en) Data transfer system in data processing unit
JPS63208924A (en) Multiplexed volume control method
JPS61100036A (en) Duplicated system data reception processing system
JPH0581207A (en) Data sharing method
JPH02280264A (en) Message block control system