JPH0498551A - Data sweep-out system - Google Patents
Data sweep-out systemInfo
- Publication number
- JPH0498551A JPH0498551A JP2216280A JP21628090A JPH0498551A JP H0498551 A JPH0498551 A JP H0498551A JP 2216280 A JP2216280 A JP 2216280A JP 21628090 A JP21628090 A JP 21628090A JP H0498551 A JPH0498551 A JP H0498551A
- Authority
- JP
- Japan
- Prior art keywords
- data
- buffer
- memory buffer
- external storage
- section
- 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
Links
Landscapes
- Memory System Of A Hierarchy Structure (AREA)
Abstract
Description
【発明の詳細な説明】
〔産業上の利用分野〕
本発明はメモリ上のデータを外部記憶装置へ掃き出すデ
ータ掃き出し方式に関する。DETAILED DESCRIPTION OF THE INVENTION [Field of Industrial Application] The present invention relates to a data flushing method for flushing data on a memory to an external storage device.
不定なタイミングで発生するデータを処理するためのデ
ータ管理方式には、発生したデータを受は取るためのメ
モリ上のバッファと当該バッファが不足した場合に利用
する外部記憶装置上のバッファによって管理する方式が
従来がら利用されている。A data management method for processing data that occurs at irregular times uses a buffer in memory to receive and receive the generated data, and a buffer in an external storage device that is used when the buffer is insufficient. The method is traditionally used.
また、メモリバッファから外部記憶装置へデータを掃き
出す方式としては、メモリバッファ上のデータの内から
発生した古いデータを順々に外部記憶装置に掃き出し、
掃き出しが終了したメモリバッファを他の新しいデータ
が使用する方式が取られていた。Also, as a method for flushing data from the memory buffer to an external storage device, old data generated from among the data on the memory buffer is flushed out to the external storage device one by one.
A method was adopted in which the memory buffer that had been flushed out was used for other new data.
第3図は従来のメモリバッファの外部記憶装置上に存在
するデータの関係を示す。FIG. 3 shows the relationship of data existing on an external storage device of a conventional memory buffer.
従来方式では発生元毎に採番された一連番号は存在しな
い。図中の番号は説明便宜上つけられたもので、データ
発生部から到着した一連番号を示している。ここで、番
号1は先着順が一番早いデータであることを示し、番号
10は一番遅いデータであることを示す。また、先着順
が早い番号1から6までのデータが外部記憶装置に掃き
出されていることを示しているにれは、メモリバッファ
の使用個数がメモリバッファ上に存在する掃き出し起点
まで到達したために、以前メモリバッファ上に存在して
いた番号1から6までのデータが外部記憶装置に掃き出
されたことを示している。尚、外部記憶装置が一杯にな
り掃き出し不可になった場合は掃き出し起点以降のメモ
リバッファかデータ受信に使用される。In the conventional system, there is no serial number assigned to each generation source. The numbers in the figure are added for convenience of explanation and indicate the serial numbers arrived from the data generation section. Here, the number 1 indicates the earliest data on a first-come, first-served basis, and the number 10 indicates the latest data. Also, the data shown in numbers 1 to 6, which are first come, first served, are being flushed out to the external storage device. This is because the number of used memory buffers has reached the flushing starting point on the memory buffer. , indicates that the data numbers 1 to 6 that previously existed on the memory buffer have been flushed out to the external storage device. Note that if the external storage device is full and cannot be flushed out, the memory buffer after the flushing starting point is used for data reception.
このように、先着データが先に外部記憶装置に掃き出さ
れるために、データ処理部4かデータ処理を行う段階に
おいて、最初に処理するべきデータが外部記憶装置上に
存在するために外部記憶装置からの読み込み動作が必要
になる。In this way, since the first-arriving data is first flushed out to the external storage device, when the data processing unit 4 performs data processing, the data to be processed first exists on the external storage device, so the external storage device is A read operation is required.
上述したメモリバッファから古いデータを順々に外部記
憶装置に掃き出す従来の方式では、先着したデータを先
に処理する必要があるため以下のような問題がある。The conventional method of sequentially flushing old data from the memory buffer to an external storage device as described above has the following problems because it is necessary to process the data that arrives first.
(1)先着したデータが外部記憶装置に掃き出されてい
る確率が高くなるのて、その分、外部記憶装置からの読
み出しによるデータ処理遅延時間か大きくなる。(1) Since the probability that the first arriving data will be flushed out to the external storage device increases, the data processing delay time due to reading from the external storage device increases accordingly.
(2)大量のデータが発生し、メモリバッファと外部記
憶装置が一杯になると、先着したデータを処理するため
に外部記憶装置から読み出す必要があるが、読み出すた
めのメモリバッファも一杯で使用出来ないため、結局シ
ステムダウンしてしまつ。(2) When a large amount of data is generated and the memory buffer and external storage device become full, it is necessary to read the data from the external storage device in order to process the first arriving data, but the memory buffer for reading it is also full and cannot be used. As a result, the system ended up going down.
本発明は、情報処理装置におけるデータ掃き出し方式に
おいて、不規則にデータを発生し前記データに前記デー
タの発生元を示す情報を付加するデータ発生部と、予め
定めた大きさを単位とする複数のメモリバッファから構
成されるメモリバッファ部と、前記メモリバッファ部か
ら溢れた前記データを保持する外部記憶装置と、前記メ
モリバッファ部から前記未使用バッファを一個確保して
、前記バッファに前記データ発生部から発生するデータ
を受信し、前記受信したデータに前記データの発生元毎
に採番された一連番号を付加し前記データ処理部が処理
するまで前記メモリバッファ部に待たせるデータ受信部
と、前記メモリバッファの前記未使用バッファ数がシス
テムで定めた規定値になった時点で前記時点以降に受信
する前記データを前記外部記憶装置に掃き出す外部記憶
掃き出し部と、前記メモリバッファ部上の前記同一発生
元のデータを前記番号の若番順に処理するとともに前記
データの処理し終った前記メモリバッファを解放して前
記未使用バッファとし、前記外部記憶装置に掃き出され
た前記メモリバッファ部上の前記データに連続する老番
のデータについては前記未使用バッファに読み出し処理
するデータ処理部とを備えたことを特徴とする。The present invention relates to a data sweeping method in an information processing device, which includes a data generation unit that generates data irregularly and adds information indicating the generation source of the data to the data, and a plurality of data generation units each having a predetermined size as a unit. a memory buffer section composed of a memory buffer; an external storage device that holds the data overflowing from the memory buffer section; and one unused buffer secured from the memory buffer section, and the data generation section in the buffer. a data receiving unit that receives data generated from the data, adds a serial number assigned to each generation source of the data to the received data, and causes the memory buffer unit to wait until the data processing unit processes the data; an external storage purge section that purges the data received after the point in time to the external storage device when the number of unused buffers in the memory buffer reaches a specified value determined by the system; and the same occurrence on the memory buffer section. The original data is processed in the order of the smallest number, and the memory buffer in which the data has been processed is released as the unused buffer, and the data on the memory buffer section is flushed out to the external storage device. The present invention is characterized by comprising a data processing unit that reads data of successive older numbers into the unused buffer.
次に、本発明について図面を参照して説明する。 Next, the present invention will be explained with reference to the drawings.
第1図は本発明のデータ掃き出し方式の一実施例を示す
構成図である。FIG. 1 is a block diagram showing an embodiment of the data sweeping method of the present invention.
データ発生部1は、不規則にデータが発生するところで
あり、オンラインシステムを例に取れば端末装置や業務
プロクラムからメツセージを受信して当該メツセージを
処理する制御側にデータを送信する部分に相当する。The data generation unit 1 is a part where data is generated irregularly, and if we take an online system as an example, it corresponds to the part that receives messages from a terminal device or business program and sends the data to the control side that processes the messages. .
データ発生部1から発生するデータには、データ発生元
を示す情報が付加されている。この情報には端末装置か
ら発生したデータであれば端末装置名であり、業務ブロ
クラムから発生したデータであれば業務プロクラム名な
どが対応する。The data generated from the data generation section 1 is appended with information indicating the data generation source. This information corresponds to the terminal device name if the data is generated from a terminal device, and the business program name if the data is generated from a business program.
このようなデータがデータ発生部1から発生すると、デ
ータ受信部2はメモリバッファ部3からある大きさを単
位とする未使用バッファを一個確保して、そのバッファ
にデータ発生部1から発生するデータを受信し、さらに
受信したデータに発生元毎に採番された一連番号を付加
し、データ処理部4が処理するまで、メモリバッファ部
3に待たせる。When such data is generated from the data generating section 1, the data receiving section 2 secures one unused buffer of a certain size from the memory buffer section 3, and transfers the data generated from the data generating section 1 to that buffer. is received, a serial number assigned for each generation source is added to the received data, and the memory buffer section 3 is made to wait until the data processing section 4 processes it.
また、メモリバッファ部3で待たされたデータがデータ
処理部4の処理完了によって不要となると、このデータ
が使用していたメモリバッファは解放され、以降このメ
モリバッファは他のデータ発生部1から発生するデータ
を受信するために利用される。Furthermore, when the data that has been kept waiting in the memory buffer unit 3 is no longer needed due to the completion of processing by the data processing unit 4, the memory buffer used by this data is released, and from now on, this memory buffer is generated from other data generation units 1. It is used to receive data.
データ発生部1から発生するデータが多く、メモリバッ
ファの未使用バッファ数がシステムで定めたある規定値
になった場合、外部記憶掃き比し部5が起動され、それ
以降受信するデータは外部記憶装置6に掃き出される。When there is a large amount of data generated from the data generation section 1 and the number of unused buffers in the memory buffer reaches a certain specified value determined by the system, the external memory sweep comparison section 5 is activated, and the data received thereafter is stored in the external memory. It is swept out into the device 6.
これは、端末装置から発生したトランザクションや業務
プロクラムから発生した端末メツセージなどのように、
データ発生毎に処理の順序性が厳密に要求される場合に
、同一発生元て先着したデータを可能な限りメモリバッ
ファ上に存在させることによって、処理の遅れの原因と
なる外部記憶装置6からのデータの読み出し動作を不要
にするためである。This includes transactions generated from terminal devices and terminal messages generated from business programs.
When strict orderliness of processing is required for each data generation, by allowing the first arriving data from the same source to exist in the memory buffer as much as possible, data from the external storage device 6 that causes processing delays can be removed. This is to eliminate the need for a data read operation.
規定値以降の残されたメモリバッファは後続のデータ発
生部1から発生するデータを受信するための未使用バッ
ファがない場合に使用される。The remaining memory buffers after the specified value are used when there is no unused buffer for receiving data generated from the subsequent data generator 1.
以上の説明を、第2図を用いて説明する。第2図はメモ
リバッファの外部記憶装置上に存在するデータの関係を
示す。The above description will be explained using FIG. 2. FIG. 2 shows the relationship of data existing on the external storage device of the memory buffer.
第2図におけるA1からA7の情報はデータ発生元を示
すAと発生順序を示す1から7までの番号によってその
データの発生元毎の一連番号を示している。例えば、端
末名Aから発生した一連のデータが発生順に番号が取ら
れていると考えればよい。Information A1 to A7 in FIG. 2 indicates a serial number for each data source by A indicating the data source and numbers 1 to 7 indicating the order of generation. For example, it may be assumed that a series of data generated from terminal name A are numbered in the order of occurrence.
この図から判るように、同一発生元のデータで発生順が
遅いA4からA7のデータか外部記憶装置6に掃き出さ
れ、発生順が早いA1からA3のデータはメモリバッフ
ァ上に存在する。従って、データ処理部4がデータ処理
を行う場合外部記憶装置からの読み込み動作を伴わない
でメモリバッファ上に存在する発生順が早いA1からA
3のデータを即時に処理できることになる。As can be seen from this figure, data A4 to A7, which are from the same source and occur later in the order of occurrence, are flushed out to the external storage device 6, while data A1 to A3, which are earlier in the order of occurrence, exist on the memory buffer. Therefore, when the data processing unit 4 performs data processing, A1 to A1 existing in the memory buffer in the earliest order of occurrence without reading from the external storage device.
3 data can be processed immediately.
また、A1からA3のデータを処理している間に、外部
記憶装置上に存在するA4からA7のデータを未使用メ
モリバッファに読み込む処理を並行に行うことが出来る
。Further, while data A1 to A3 is being processed, data A4 to A7 existing on the external storage device can be read into an unused memory buffer in parallel.
さらに未使用バッファが存在しない場合でも、A1から
A3までのデータが処理完了された時点で、それらA1
からA3のために使用されていたメモリバッファが解放
されるので、外部記憶装置上に存在するA4からA7の
データを読み込むためのバッファとして使用できる6従
来方式のように、未使用バッファが存在しないなめにシ
ステムダウンするようなことはない。Furthermore, even if there are no unused buffers, once the data from A1 to A3 has been processed, those A1
Since the memory buffer used for A3 is released, it can be used as a buffer for reading data from A4 to A7 that exists on the external storage device.6Unlike in the conventional method, there is no unused buffer. There is no chance that the system will go down.
以上説明したように本発明によれば、処理の順序性を正
確に守らなければならない情報処理装置において、先着
したデータをメモリ上に存在するようにしたことにより
、外部記憶装置からの読み込み動作による処理遅延、〆
あるいは、読み込みメモリバッファの不足によるシステ
ムダウンを防止することが出来る。As explained above, according to the present invention, in an information processing device that must accurately maintain the order of processing, by making the data that arrives first exist in memory, it is possible to It is possible to prevent system downtime due to processing delays, closing, or lack of read memory buffer.
第1図は本発明のデータ掃き出し方式の一実施例を示す
構成図、第2図はメモリバッファの外部記憶装置上に存
在するデータの関係を示す図、第3図は従来のメモリバ
ッファの外部記憶装置上に存在するデータの関係を示す
図である。
1・・・データ発生部、2・・・データ受信部、3・・
・メモリバッファ部、
4・・・データ処理部、
5・・・外部記
憶掃き出し部、
・・外部記憶装置。FIG. 1 is a block diagram showing an embodiment of the data flushing method of the present invention, FIG. 2 is a diagram showing the relationship between data existing on an external storage device of a memory buffer, and FIG. FIG. 3 is a diagram showing the relationship between data existing on a storage device. 1...Data generating section, 2...Data receiving section, 3...
-Memory buffer unit, 4...Data processing unit, 5...External memory purging unit,...External storage device.
Claims (1)
規則にデータを発生し前記データに前記データの発生元
を示す情報を付加するデータ発生部と、予め定めた大き
さを単位とする複数のメモリバッファから構成されるメ
モリバッファ部と、前記メモリバッファ部から溢れた前
記データを保持する外部記憶装置と、前記メモリバッフ
ァ部から前記未使用バッファを一個確保して、前記バッ
ファに前記データ発生部から発生するデータを受信し、
前記受信したデータに前記データの発生元毎に採番され
た一連番号を付加し前記データ処理部が処理するまで前
記メモリバッファ部に待たせるデータ受信部と、前記メ
モリバッファの前記未使用バッファ数がシステムで定め
た規定値になった時点で前記時点以降に受信する前記デ
ータを前記外部記憶装置に掃き出す外部記憶掃き出し部
と、前記メモリバッファ部上の前記同一発生元のデータ
を前記番号の若番順に処理するとともに前記データの処
理し終った前記メモリバッファを解放して前記未使用バ
ッファとし、前記外部記憶装置に掃き出された前記メモ
リバッファ部上の前記データに連続する老番のデータに
ついては前記未使用バッファに読み出し処理するデータ
処理部とを備えたことを特徴とするデータ掃き出し方式
。A data flushing method in an information processing device consists of a data generation unit that randomly generates data and adds information indicating the source of the data to the data, and a plurality of memory buffers each having a predetermined size as a unit. a memory buffer section for storing data generated from the data generation section; an external storage device for holding the data overflowing from the memory buffer section; and one unused buffer secured from the memory buffer section to store the data generated from the data generation section in the buffer. receive and
a data receiving unit that adds a serial number assigned to each generation source of the data to the received data and causes the memory buffer unit to wait until the data processing unit processes the data; and the number of unused buffers in the memory buffer. an external storage purge section that purges the data received after the point in time to the external storage device when the data reaches a specified value determined by the system; At the same time, the memory buffer after the processing of the data is released and becomes the unused buffer, and the data with the highest number consecutive to the data on the memory buffer section is flushed out to the external storage device. The data flushing method is characterized by comprising a data processing unit that performs read processing on the unused buffer.
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
JP2216280A JPH0498551A (en) | 1990-08-16 | 1990-08-16 | Data sweep-out system |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
JP2216280A JPH0498551A (en) | 1990-08-16 | 1990-08-16 | Data sweep-out system |
Publications (1)
Publication Number | Publication Date |
---|---|
JPH0498551A true JPH0498551A (en) | 1992-03-31 |
Family
ID=16686062
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
JP2216280A Pending JPH0498551A (en) | 1990-08-16 | 1990-08-16 | Data sweep-out system |
Country Status (1)
Country | Link |
---|---|
JP (1) | JPH0498551A (en) |
Cited By (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
JP2008084206A (en) * | 2006-09-28 | 2008-04-10 | Fujitsu Ltd | Storage apparatus and data transfer method |
-
1990
- 1990-08-16 JP JP2216280A patent/JPH0498551A/en active Pending
Cited By (1)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
JP2008084206A (en) * | 2006-09-28 | 2008-04-10 | Fujitsu Ltd | Storage apparatus and data transfer method |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
EP0116047B1 (en) | Multiplexed first-in, first-out queues | |
EP0272834B1 (en) | Inter-processor communication protocol | |
US4686620A (en) | Database backup method | |
US4396983A (en) | Distributed data processing system having several local system and communication modules for use in such data processing system | |
CN106899516B (en) | A queue emptying method and related equipment | |
EP0118446A1 (en) | First-in, first-out (fifo) memory configuration for queue storage. | |
JPH06202912A (en) | Method and equipment for data processing | |
FR2558617A1 (en) | PROCESSOR SYSTEM COMPRISING A NUMBER OF POSTS INTERCONNECTED BY A COMMUNICATION NETWORK AND POST TO BE USED IN SUCH A PROCESSOR SYSTEM | |
KR0128274B1 (en) | Interface system and its operating method | |
JPH0786863B2 (en) | Processor access control device for multi-processor system | |
US7111289B2 (en) | Method for implementing dual link list structure to enable fast link-list pointer updates | |
EP0420236B1 (en) | Arrangement and method of controlling memory access requests in digital data processing system | |
JPH07183898A (en) | Method for recovering a predetermined order for an out-of-order cell flow in ATM switching technology | |
CN110457126A (en) | A kind of asynchronous invoking method and system | |
CN100365604C (en) | Interrupt control handling apparatus and method | |
WO2004046950A1 (en) | Mailbox interface between processors | |
US6170003B1 (en) | Apparatus and method for communicating messages between data processing nodes using remote reading of message queues | |
US3401380A (en) | Electrical systems for the reception, storage, processing and re-transmission of data | |
JPH0498551A (en) | Data sweep-out system | |
CN112306827A (en) | Log collection device, method and computer readable storage medium | |
WO1988002513A1 (en) | Method and device to execute two instruction sequences in an order determined in advance | |
CN115981854A (en) | Timer management method and device based on linked list | |
CN115098451A (en) | Data transmission method based on file | |
CN109246030B (en) | Method and system for realizing state machine in configuration editing process | |
JPH0528037A (en) | Buffer control system |