JPH06314207A - Data processor - Google Patents
Data processorInfo
- Publication number
- JPH06314207A JPH06314207A JP10455393A JP10455393A JPH06314207A JP H06314207 A JPH06314207 A JP H06314207A JP 10455393 A JP10455393 A JP 10455393A JP 10455393 A JP10455393 A JP 10455393A JP H06314207 A JPH06314207 A JP H06314207A
- Authority
- JP
- Japan
- Prior art keywords
- communication
- buffer
- data
- communication buffer
- program
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
- 239000000872 buffer Substances 0.000 claims abstract description 155
- 230000005540 biological transmission Effects 0.000 claims abstract description 39
- 230000008030 elimination Effects 0.000 abstract 2
- 238000003379 elimination reaction Methods 0.000 abstract 2
- 238000012217 deletion Methods 0.000 description 6
- 230000037430 deletion Effects 0.000 description 6
- 238000010586 diagram Methods 0.000 description 6
- 238000013500 data storage Methods 0.000 description 4
- 230000006378 damage Effects 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
Abstract
Description
【０００１】[0001]
【産業上の利用分野】本発明は多重プログラミング形の
コンピュータ装置に利用する。BACKGROUND OF THE INVENTION The present invention is used in a computer system of multiple programming type.
【０００２】本発明は、各プログラム対応のジョブ間通
信に利用する。本発明は、多重プログラミングシステム
のプログラム間で高速にデータの送受信を行うことがで
きるデータ処理装置に関する。The present invention is used for inter-job communication corresponding to each program. The present invention relates to a data processing device capable of transmitting and receiving data at high speed between programs of a multiple programming system.
【０００３】[0003]
【従来の技術】従来のジョブ間通信においては、通信で
使用するシステム共通領域に制限があり、そのため通信
バッファの数や大きさが限られ、そのため、バッファの
代わりにデータ格納領域としてファイルを使用してい
た。2. Description of the Related Art In conventional inter-job communication, the system common area used for communication is limited, which limits the number and size of communication buffers. Therefore, files are used as data storage areas instead of buffers. Was.
【０００４】また、通信バッファの不足で送信ができな
い場合には送信の要求はエラーとなり、また、実際に通
信を行う場合には、通信するプログラム同士で同じ通信
クラス名を持って、そのクラス名に対して送信や受信を
行っていた。Further, if transmission is not possible due to a lack of communication buffers, a transmission request will result in an error, and in the case of actual communication, the communicating programs will have the same communication class name, and the class name will be the same. Was being sent to and received from.
【０００５】さらに、送信プログラムは、送信データを
格納する領域を準備してその領域に送信データを格納
し、その領域を指定して送信を行い、送信時にはその領
域のデータを通信バッファに移送した後に送信し、一
方、受信プログラムでは送信データを格納する領域を準
備し、その領域を指定して受信を行い、受信時には指定
された領域に送信データを移送していた。Further, the transmission program prepares an area for storing the transmission data, stores the transmission data in the area, designates the area and transmits the data. At the time of transmission, the data in the area is transferred to the communication buffer. On the other hand, the reception program prepares an area for storing the transmission data, designates the area for reception, and transfers the transmission data to the designated area at the time of reception.
【０００６】[0006]
【発明が解決しようとする課題】このような従来のジョ
ブ間通信は、通信バッファの使用するシステム共通領域
に限りがあることから、システムにも通信バッファの数
に限りがあり、また、通信クラス単位には送信の数が制
限されていないため、あるプログラムが大量に送信を行
ったまま受信を行うことができるプログラムがなけれ
ば、通信バッファが不足しジョブ間通信ができない問題
があった。In such conventional inter-job communication, since the system common area used by the communication buffer is limited, the number of communication buffers is limited in the system, and the communication class is limited. Since the number of transmissions is not limited in the unit, there is a problem that communication between jobs cannot be performed because the communication buffer is insufficient unless there is a program that can receive while a certain program transmits a large amount.
【０００７】また、データの通信をする際に、送信デー
タがファイルに格納されるため、送信で一度、受信で一
度、合計二度のファイル入出力が行われ、性能的に問題
があり、また、通信するプログラム同士で同じ通信クラ
ス名による識別子を持ちそれによって通信が行われてい
るが、システムの動作中にその通信クラス名の追加およ
び削除を行うことができない問題があった。Further, since the transmission data is stored in the file when the data is communicated, the file input / output is performed twice, once for transmission and once for reception, which causes a problem in performance. , The communicating programs have the same identifier of the communication class name and communicate with each other, but there is a problem that the communication class name cannot be added or deleted during the operation of the system.
【０００８】本発明はこのような問題を解決するもの
で、互いに通信を行うプログラムの集合である通信グル
ープを作成し、その通信グループの中で通信バッファの
数を制限し、ある通信グループの通信が他の通信グルー
プの通信に影響を与えないようにし、また、その通信グ
ループはシステム動作中に、自由に追加または削除する
ことをできるようにするとともに、通信バッファの使用
するシステム共通領域も使用バッファ数に応じて動的に
拡張することによりバッファ数を増やしたりバッファの
サイズを大きくしてファイルを使用する必要を少なく
し、送信側のプログラム空間にある情報をバッファに移
送した後に受信側のプログラム空間に移送せずにプログ
ラムがバッファに直接アクセスできるようにして高速に
データ通信を行い、かつバッファアドレスを参照してプ
ログラムが直接にデータの書き込みをできるようにし
て、プログラム誤りによる制御情報の破壊を防ぐために
プログラムがデータを書き込むデータ部とバッファの制
御情報を格納する制御部とのシステム共通領域を分け、
プログラム誤りによる制御不正を生じることのないデー
タ処理装置を提供することを目的とする。The present invention solves such a problem by creating a communication group, which is a set of programs for communicating with each other, and limiting the number of communication buffers in the communication group, and communicating with a communication group. Does not affect the communication of other communication groups, and that communication group can be freely added or deleted while the system is operating, and the system common area used by the communication buffer is also used. By dynamically expanding according to the number of buffers, the number of buffers can be increased or the size of the buffers can be increased to reduce the need to use files. Allows programs to directly access the buffer without transferring to program space for faster data communication, Common to the system of the data section where the program writes data and the control section that stores the control information of the buffer to prevent the control information from being destroyed by a program error by allowing the program to directly write the data by referring to the buffer address Divide the area,
It is an object of the present invention to provide a data processing device that does not cause illegal control due to a program error.
【０００９】[0009]
【課題を解決するための手段】本発明は、中央処理装置
および記憶装置を備え、複数のジョブを並行的に実行す
る多重プログラミング形のデータ処理装置において、前
記中央処理装置に各プログラムにより制御される複数の
ジョブ実行手段の間の通信を行うジョブ間通信手段を備
え、前記記憶装置に、相互に通信を行う複数のジョブ実
行手段が一つの通信グループとして通信グループ毎に通
信グループエントリとして登録され、その通信グループ
エントリにはその複数のジョブ実行手段が相互に通信す
べきデータを一時蓄積する通信バッファプールが設定さ
れ、前記中央処理装置に、通信グループエントリの新た
な登録および既に登録された通信グループエントリの削
除を行う通信グループ登録削除手段が設けられたことを
特徴とする。SUMMARY OF THE INVENTION The present invention is a multiple programming type data processing apparatus comprising a central processing unit and a storage unit for executing a plurality of jobs in parallel, and the central processing unit is controlled by each program. A plurality of job execution means for performing communication between a plurality of job execution means, and a plurality of job execution means for performing mutual communication are registered in the storage device as a communication group for each communication group as a communication group entry. , A communication buffer pool in which the plurality of job executing means temporarily stores data to be communicated with each other is set in the communication group entry, and a new registration of the communication group entry and communication already registered in the central processing unit. A communication group registration deleting means for deleting a group entry is provided.
【００１０】本発明の第二は、前記データ処理装置にお
いて、前記通信グループエントリに、既に登録された通
信グループについてジョブ実行手段対応に通信識別名が
登録され、前記中央処理装置に、この通信識別名に新た
な通信識別名を加入し既に登録された通信識別名を削除
する通信識別名登録削除手段を備えたことを特徴とす
る。According to a second aspect of the present invention, in the data processing device, a communication identification name corresponding to a job executing means is registered in the communication group entry for the communication group already registered, and the communication identification name is registered in the central processing device. The communication identification name registration / deletion means for adding a new communication identification name to the name and deleting the already registered communication identification name is provided.
【００１１】本発明の第三は、前記データ処理装置にお
いて、前記通信グループエントリに、通信識別名対応に
通信データを格納し通信の媒体となる通信バッファが設
定され、前記中央処理装置に、この通信バッファの領域
を取得しおよび解放する通信バッファ取得解放手段を備
えたことを特徴とする。According to a third aspect of the present invention, in the data processing device, a communication buffer that stores communication data corresponding to a communication identifier and serves as a communication medium is set in the communication group entry, and the communication buffer is set in the central processing device. A communication buffer acquisition / release means for acquiring and releasing the area of the communication buffer is provided.
【００１２】本発明の第四は、前記データ処理装置にお
いて、前記通信バッファが、通信データの格納領域であ
るデータ部と、そのデータ部のアドレスを含む制御情報
の格納領域である制御部とを備えたことを特徴とする。According to a fourth aspect of the present invention, in the data processing device, the communication buffer includes a data section which is a storage area of communication data and a control section which is a storage area of control information including an address of the data section. It is characterized by having.
【００１３】本発明の第五は、前記データ処理装置にお
いて、送信側のジョブ実行手段から当該通信バッファに
通信内容を書込み、受信側のジョブ実行手段がその通信
バッファを受取るように制御する通信バッファ送信受信
手段を備えたことを特徴とする。In a fifth aspect of the present invention, in the data processing device, a communication buffer for writing communication contents from the job executing means on the transmitting side to the communication buffer and controlling the job executing means on the receiving side to receive the communication buffer. It is characterized in that a transmission / reception means is provided.
【００１４】本発明の第六は、前記データ処理装置にお
いて、前記中央処理装置に、通信グループの構成を表示
する情報を含む通信に必要な情報を参照するための通信
情報参照手段を備えたことを特徴とする。According to a sixth aspect of the present invention, in the data processing device, the central processing device is provided with communication information reference means for referring to information necessary for communication including information for displaying a configuration of a communication group. Is characterized by.
【００１５】[0015]
【作用】プログラム間でデータ通信を行うにあたって、
予めプログラムが動作する前に、通信を行うプログラム
群が属する通信グループを通信グループ登録削除手段に
よって登録し、通信を行う送信および受信のプログラム
が通信識別名登録削除手段によって、プログラムを識別
するための通信識別名を通信グループに登録し、ジョブ
間通信可能の状態にする。[Operation] When performing data communication between programs,
Before the program operates, the communication group to which the program group for communication belongs is registered by the communication group registration and deletion means, and the transmission and reception programs for communication identify the program by the communication identifier registration and deletion means. Register the communication identifier in the communication group and enable communication between jobs.
【００１６】次に、送信側のプログラムは通信バッファ
取得解放手段によって、通信バッファを取得し、通信バ
ッファにデータを格納した後、通信バッファ送信受信手
段により、受信側のプログラムに通信バッファを送信す
る。このとき受信側のプログラムが受信待ちを行ってい
る場合、通信バッファ送信受信手段は待ち合わせ解除の
イベント通知を行う。Next, the transmission side program acquires the communication buffer by the communication buffer acquisition / release means, stores the data in the communication buffer, and then transmits the communication buffer to the reception side program by the communication buffer transmission / reception means. . At this time, if the program on the receiving side is waiting for reception, the communication buffer transmission / reception means issues a queuing release event notification.
【００１７】一方、受信プログラムは、通信バッファ送
信受信手段によって、送信された通信バッファを取得
し、送信データを受け取る。データを受け取った後、通
信バッファが必要なくなれば、通信バッファ取得解放手
段により通信バッファを解放する。On the other hand, the receiving program acquires the transmitted communication buffer by the communication buffer transmitting / receiving means and receives the transmission data. If the communication buffer is no longer needed after receiving the data, the communication buffer is released by the communication buffer acquisition / release means.
【００１８】これにより、多重プログラミングシステム
におけるプログラム間でのデータの送受信を高速に行う
ことができる。Thus, it is possible to perform high-speed data transmission / reception between programs in the multiple programming system.
【００１９】[0019]
【実施例】次に、本発明実施例を図面に基づいて説明す
る。図１は本発明実施例の全体構成を示すブロック図、
図２は本発明実施例の要部の構成を示すブロック図、図
３は本発明実施例における通信バッファの構成を示すブ
ロック図である。Embodiments of the present invention will now be described with reference to the drawings. 1 is a block diagram showing the overall configuration of an embodiment of the present invention,
FIG. 2 is a block diagram showing a configuration of a main part of the embodiment of the present invention, and FIG. 3 is a block diagram showing a configuration of a communication buffer in the embodiment of the present invention.
【００２０】本発明実施例は、中央処理装置２０および
記憶装置２１を備え、複数のジョブを並行的に実行する
多重プログラミング形のデータ処理装置の中央処理装置
２０に各プログラムにより制御される複数のジョブ実行
手段の間の通信を行うジョブ間通信手段３を備え、記憶
装置２１に、相互に通信を行う複数のジョブ実行手段が
一つの通信グループとして通信グループ毎に通信グルー
プエントリ１５として登録され、その通信グループエン
トリ１５にはその複数のジョブ実行手段が相互に通信す
べきデータを一時蓄積する通信バッファプール１８が設
定され、中央処理装置２０のジョブ間通信手段３に、通
信グループエントリの新たな登録および既に登録された
通信グループエントリの削除を行う通信グループ登録削
除手段４が設けられる。The embodiment of the present invention comprises a central processing unit 20 and a storage unit 21, and a plurality of central processing units 20 of a multi-programming type data processing unit for executing a plurality of jobs in parallel are controlled by respective programs. An inter-job communication unit 3 for performing communication between job execution units is provided, and a plurality of job execution units for mutual communication are registered in the storage device 21 as a communication group for each communication group as a communication group entry 15. In the communication group entry 15, a communication buffer pool 18 for temporarily accumulating data to be mutually communicated by the plurality of job executing means is set, and a new communication group entry of the communication group entry is set in the inter-job communication means 3 of the central processing unit 20. Communication group registration deleting means 4 for performing registration and deleting already registered communication group entries is provided. That.
【００２１】また、通信グループエントリ１５に、既に
登録された通信グループについてジョブ実行手段対応に
通信識別名が登録され、中央処理装置３のジョブ間通信
手段３に、この通信識別名に新たな通信識別名を加入し
既に登録された通信識別名を削除する通信識別名登録削
除手段５を備え、前記通信グループエントリ１５に、通
信識別名対応に通信データを格納し通信の媒体となる通
信バッファ１９が設定され、中央処理装置２０のジョブ
間通信手段３に、この通信バッファ１９の領域を取得し
および解放する通信バッファ取得解放手段６を備え、通
信バッファ１９が、通信データの格納領域であるデータ
部Ｂ４と、そのデータ部のアドレスを含む制御情報の格
納領域である制御部Ｂ３とを備え、さらに、中央処理装
置２０のジョブ間通信手段３に、送信側のジョブ実行手
段から当該通信バッファ１９に通信内容を書込み、受信
側のジョブ実行手段がその通信バッファを受取るように
制御する通信バッファ送信受信手段７と、通信グループ
の構成を表示する情報を含む通信に必要な情報を参照す
るための通信情報参照手段８を備える。Further, in the communication group entry 15, the communication identification name corresponding to the job executing means is registered for the already registered communication group, and the inter-job communication means 3 of the central processing unit 3 makes a new communication with this communication identification name. The communication buffer 19 is provided with a communication identifier registration deleting means 5 for deleting an already registered communication identifier by adding an identifier to the communication group entry 15 and storing communication data corresponding to the communication identifier as a communication medium. Is set, the inter-job communication means 3 of the central processing unit 20 is provided with the communication buffer acquisition / release means 6 for acquiring and releasing the area of the communication buffer 19, and the communication buffer 19 is a data storage area. A part B4 and a control part B3, which is a storage area for control information including an address of the data part, are provided between the jobs of the central processing unit 20. Communication buffer transmission / reception means 7 for writing communication contents to the communication buffer 19 from the job execution means on the transmission side to the communication means 3, and control so that the job execution means on the reception side receives the communication buffer, and a communication group configuration The communication information reference means 8 is provided for referring to information necessary for communication including information for displaying.
【００２２】通信グループ登録削除手段４には、通信識
別名エントリを作成するオープン手段９と、通信識別名
エントリを消去するクローズ手段１０を含み、通信バッ
ファ取得解放手段６は、通信バッファ１９を通信バッフ
ァプール１８から取得する通信バッファ取得手段１１
と、通信バッファ１９を解放する通信バッファ解放手段
１２を含み、通信バッファ送信受信手段７には、通信バ
ッファ１９を受信プログラムに送信する通信バッファ送
信手段１３と、送信された通信バッファ１９を受信する
通信バッファ受信手段１４を含む。また、通信バッファ
１９は制御部Ｂ３とデータ部Ｂ４から構成され、プログ
ラムＢ１から通信バッファ取得解放手段６を通して取得
解放される。未使用の通信バッファ１９の集まりである
通信バッファプールＢ６は、制御部Ｂ３の集まりである
制御部プールＢ７と、データ部の長さ別に存在し、デー
タ部の集まりであるデータ部プールＢ８により構成さ
れ、データ部プールＢ８はシステム共通領域Ｂ９により
構成される。The communication group registration / deletion means 4 includes an opening means 9 for creating a communication identification name entry and a closing means 10 for deleting the communication identification name entry. The communication buffer acquisition / release means 6 communicates with the communication buffer 19. Communication buffer acquisition means 11 acquired from the buffer pool 18
And a communication buffer releasing means 12 for releasing the communication buffer 19, and the communication buffer transmitting / receiving means 7 receives the communication buffer transmitting means 13 for transmitting the communication buffer 19 to the receiving program and the transmitted communication buffer 19. The communication buffer receiving means 14 is included. The communication buffer 19 is composed of a control unit B3 and a data unit B4, and is acquired and released from the program B1 through the communication buffer acquisition / release means 6. A communication buffer pool B6, which is a collection of unused communication buffers 19, is composed of a control unit pool B7, which is a collection of control units B3, and a data unit pool B8, which is a collection of data units and exists for each length of data unit. The data part pool B8 is composed of the system common area B9.
【００２３】次に、このように構成された本発明実施例
の動作について説明する。Next, the operation of the embodiment of the present invention thus constructed will be described.
【００２４】プログラム１と、プログラム２との間でデ
ータ通信を行うとすると、まず通信を行うプログラムの
集合である通信グループエントリ１５を作成するため
に、通信グループ名を指定して通信グループ登録削除手
段４に制御を渡す。When data communication is performed between the program 1 and the program 2, first, in order to create a communication group entry 15 which is a set of programs for communication, a communication group name is designated to delete the communication group registration. Pass control to means 4.
【００２５】通信グループ登録削除手段４は、通信グル
ープエントリ１５を作成するとともに、通信バッファの
プールである通信バッファプール１８を作成する。The communication group registration deleting means 4 creates a communication group entry 15 and a communication buffer pool 18 which is a pool of communication buffers.
【００２６】次に、プログラム１から、通信識別名を通
信グループに登録するために、通信グループ名と通信識
別名を指定して通信識別名登録削除手段５のオープン手
段９に制御を渡す。オープン手段９では、通信グループ
エントリ１５の中に通信識別名の格納されたプログラム
１の通信識別名エントリ領域１６を作成し、プログラム
１からのジョブ間通信を利用できるようにする。Next, in order to register the communication identification name in the communication group, the program 1 designates the communication group name and the communication identification name and transfers control to the open means 9 of the communication identification name registration deleting means 5. The opening means 9 creates the communication identification name entry area 16 of the program 1 in which the communication identification name is stored in the communication group entry 15 so that the inter-job communication from the program 1 can be used.
【００２７】同じくプログラム２からもオープン手段９
に制御を渡し、通信識別名エントリ領域１７を作成して
プログラム２からのジョブ間通信を利用できるようにす
る。Similarly, the opening means 9 from the program 2
Control is passed to create a communication identification name entry area 17 so that the inter-job communication from the program 2 can be used.
【００２８】プログラム１を送信プログラムとすると、
通信バッファを確保するために通信バッファ取得解放手
段６の通信バッファ取得手段１１に制御を渡す。通信バ
ッファ取得手段１１では、通信バッファプール１８より
通信バッファ１９を取得してプログラム１の通信識別名
エントリ領域１６にリンクするとともに、プログラム１
に通信バッファ１９のアドレスを返却する。If program 1 is a transmission program,
Control is passed to the communication buffer acquisition means 11 of the communication buffer acquisition / release means 6 to secure the communication buffer. The communication buffer acquisition means 11 acquires the communication buffer 19 from the communication buffer pool 18 and links it to the communication identification name entry area 16 of the program 1, and at the same time, the program 1
The address of the communication buffer 19 is returned to.
【００２９】ここで、通信バッファプール１８に未使用
の通信バッファがなくなれば、動的にシステム共通領域
を確保して通信バッファプール１８を拡張し通信バッフ
ァを取得返却する。Here, when there is no unused communication buffer in the communication buffer pool 18, the system common area is dynamically secured, the communication buffer pool 18 is expanded, and the communication buffer is acquired and returned.
【００３０】また、通信バッファ１９には通信グループ
登録削除手段４により使用数の上限が決められているが
その上限に到達した場合には、通信バッファ取得の要求
をしたプログラムは、使用数が解放値の値に下がるまで
通信バッファの空きの通知を待つことができる。ここで
解放値は以下のように設定される。The upper limit of the number of uses of the communication buffer 19 is determined by the communication group registration deleting means 4 in the communication buffer 19, but when the upper limit is reached, the program requesting acquisition of the communication buffer releases the number of uses. You can wait for the notification of communication buffer empty until the value falls to the value. Here, the release value is set as follows.
【００３１】解放値 ＝ 上限値 × 解放割合 上限値と解放割合は通信グループ登録削除手段４により
設定される。通信バッファの空きは、通信バッファ解放
手段１２から通知される。Release value = upper limit value × release ratio The upper limit value and the release ratio are set by the communication group registration deleting means 4. The free space of the communication buffer is notified from the communication buffer releasing means 12.
【００３２】プログラム１は通信バッファ取得手段１１
から返却される通信バッファ１９のアドレスを利用して
送信データを格納する。データを格納した後、プログラ
ム１は受信プログラム２に対して通信バッファを送信す
るためにプログラム２の通信識別名と通信バッファ１９
を指定して通信バッファ送信受信手段７の通信バッファ
送信手段１３に制御を渡す。The program 1 is the communication buffer acquisition means 11
The transmission data is stored using the address of the communication buffer 19 returned from. After storing the data, the program 1 uses the communication identifier of the program 2 and the communication buffer 19 to send the communication buffer to the receiving program 2.
Is designated and the control is passed to the communication buffer transmitting means 13 of the communication buffer transmitting / receiving means 7.
【００３３】通信バッファ送信手段１３では、プログラ
ム１の通信識別名エントリ領域１６にリンクされている
指定された通信バッファ１９をプログラム２の通信識別
名エントリ領域１７にリンクし、プログラム２が送信の
イベント待ちを行っていれば、送信のイベントを通知す
る。In the communication buffer transmitting means 13, the designated communication buffer 19 linked to the communication identification name entry area 16 of the program 1 is linked to the communication identification name entry area 17 of the program 2 so that the program 2 sends an event. If it is waiting, it notifies the event of transmission.
【００３４】一方、受信プログラム２では、通信バッフ
ァ送信受信手段７の通信バッファ受信手段１４を呼び出
し、送信された通信バッファ１９のアドレスを取得す
る。ここで受信すべき通信バッファが存在しない場合、
送信のイベントを受取るためのセマフォを登録してお
き、プログラム２はそのセマフォでイベント待ちを行
う。On the other hand, in the receiving program 2, the communication buffer receiving means 14 of the communication buffer transmitting / receiving means 7 is called to obtain the transmitted address of the communication buffer 19. If there is no communication buffer to receive here,
A semaphore for receiving a transmission event is registered, and the program 2 waits for the event with the semaphore.
【００３５】プログラム２は、通信バッファ１９のアド
レスを取得した後、そのアドレスを利用して、送信デー
タを受け取る。After acquiring the address of the communication buffer 19, the program 2 uses the address to receive the transmission data.
【００３６】ここで、プログラム２は送信データを受け
取った後、再度、通信バッファ１９を通信バッファ送信
手段１３で他のプログラムに送信することも可能であ
る。通信バッファ１９が必要なくなれば、プログラム２
は通信バッファ取得解放手段６の通信バッファ解放手段
１２に制御を渡す。Here, after the program 2 receives the transmission data, it is possible to transmit the communication buffer 19 again to another program by the communication buffer transmitting means 13. If the communication buffer 19 is no longer needed, the program 2
Passes control to the communication buffer releasing means 12 of the communication buffer acquiring and releasing means 6.
【００３７】通信バッファ解放手段１２では、通信バッ
ファ１９をプログラム２の通信識別名エントリ領域１７
のリンクから外して、通信バッファプール１８に返却す
る。またそのとき、通信バッファの使用数が解放値を下
回った場合には、通信バッファ取得手段１１により通信
バッファ待ちを行っているプログラムに通信バッファ空
きの通知を行う。また拡張したシステム共通領域に使用
中の通信バッファがなければ、システム共通領域の解放
を行う。このような作業を繰り返しプログラム間でデー
タの通信を行う。In the communication buffer releasing means 12, the communication buffer 19 is stored in the communication identification name entry area 17 of the program 2.
And returns it to the communication buffer pool 18. At that time, if the number of used communication buffers is less than the release value, the communication buffer acquisition unit 11 notifies the program waiting for the communication buffers that the communication buffer is available. If there is no communication buffer in use in the extended system common area, the system common area is released. Such work is repeated to communicate data between programs.
【００３８】プログラムがデータの通信を終えるとき、
通信識別名登録削除手段５のクローズ手段１０に制御を
渡す。クローズ手段１０では、通信グループエントリに
作成されている通信識別名エントリ領域１６を消去す
る。またこのとき通信識別名エントリ領域１６に通信バ
ッファ１９が存在すれば、通信バッファ１９を通信バッ
ファプール１８に解放する。通信グループに通信するプ
ログラムが存在しなければ、通信グループ登録削除手段
４にて通信グループエントリ１５を削除する。また、通
信情報を参照したい場合、プログラムから通信情報参照
手段８に制御を渡す。When the program finishes communicating data,
Control is passed to the closing means 10 of the communication identifier registration deleting means 5. The closing means 10 erases the communication identification name entry area 16 created in the communication group entry. If the communication buffer 19 exists in the communication identifier entry area 16 at this time, the communication buffer 19 is released to the communication buffer pool 18. If there is no communication program in the communication group, the communication group entry deleting unit 4 deletes the communication group entry 15. Further, when it is desired to refer to the communication information, the control is passed from the program to the communication information reference means 8.
【００３９】通信情報参照手段８は、通信グループエン
トリ１５や、通信識別名エントリ領域１６を参照し、登
録されている通信グループ数、通信グループ名、通信グ
ループ中の通信識別名とその数、通信バッファ数などの
ジョブ間通信の情報を取得してプログラムに返却する。The communication information reference means 8 refers to the communication group entry 15 and the communication identification name entry area 16, and refers to the number of registered communication groups, the communication group name, the communication identification names in the communication groups and their numbers, and the communication. Acquire information about inter-job communication such as the number of buffers and return it to the program.
【００４０】図２に示すように、通信バッファ１９は制
御部Ｂ３とデータ部Ｂ４により構成されており、制御部
Ｂ３には、通信識別名エントリへのアドレス、データ部
の大きさ、データ部に格納されているデータの長さ、お
よびデータ部へのアドレスといった制御上必要な情報が
格納されている。As shown in FIG. 2, the communication buffer 19 is composed of a control unit B3 and a data unit B4. The control unit B3 has an address to the communication identification name entry, a size of the data unit, and a data unit. Information necessary for control such as the length of the stored data and the address to the data section is stored.
【００４１】通信バッファ１９は、通信バッファ取得解
放手段６にて、通信バッファプール１８の制御部プール
Ｂ７から未使用の制御部Ｂ３が取得され、またデータ部
の大きさ別に存在するデータ部プールＢ８から、指定さ
れた大きさのデータ部が取得される。その後、制御部Ｂ
３からデータ部Ｂ４へのリンクがつけられた後、制御部
Ｂ３とデータ部Ｂ４へのアドレスがプログラムＢ１に返
される。In the communication buffer 19, the unused control section B3 is acquired from the control section pool B7 of the communication buffer pool 18 by the communication buffer acquisition / release means 6, and the data section pool B8 exists according to the size of the data section. From, the data part of the specified size is acquired. After that, the control unit B
After the link from 3 to the data part B4 is provided, the addresses to the control part B3 and the data part B4 are returned to the program B1.
【００４２】ここで各制御部プールＢ７またはデータ部
プールＢ８に空きが存在しなければ、システム共通領域
Ｂ９を取得して制御部プールＢ７やデータ部プールＢ８
を拡張する。プログラムＢ１は返却されたデータ部Ｂ４
へのアドレスを参照してデータを書き込むことができ
る。If there is no free space in each control unit pool B7 or data unit pool B8, the system common area B9 is acquired and the control unit pool B7 or data unit pool B8 is acquired.
To extend. Program B1 is the returned data section B4
You can write data by referring to the address.
【００４３】通信バッファ１９の解放の際には、プログ
ラムから制御部Ｂ３を指定し、通信バッファ取得解放手
段６に制御を渡すと、制御部Ｂ３は制御部プールＢ７に
解放され、データ部Ｂ４はデータ部の長さに応じたデー
タ部プールＢ８に解放される。ここでシステム共通領域
Ｂ９上に、使用中の制御部およびデータ部が存在しなけ
れば、システム共通領域Ｂ９を解放する。When releasing the communication buffer 19, the control unit B3 is designated from the program and the control is passed to the communication buffer acquisition / release means 6, the control unit B3 is released to the control unit pool B7, and the data unit B4 is released. It is released to the data part pool B8 according to the length of the data part. If there is no control unit and data unit in use on the system common area B9, the system common area B9 is released.
【００４４】[0044]
【発明の効果】以上説明したように本発明によれば、次
の効果を得ることができる。 １）．複数のジョブが同時に動作する多重プログラミン
グシステムのプログラム間の通信を行うために、通信グ
ループとしのプログラム群を設けることにより、通信グ
ループに属しているプログラム同士が自由に通信するこ
とができ、通信グループに属さないプログラムからの通
信をプロテクトすることができる。 ２）．送信データを格納し通信の媒体となる通信バッフ
ァの取得や解放ができるとともに、通信バッファの使用
するシステム共通領域は、通信バッファ使用数に応じて
動的に拡張することができ、また、通信グループ内で通
信バッファの数の制限を設けて通信バッファの取り過ぎ
を防止し、プログラムによる通信バッファの取得ができ
ない場合には通信バッファの空きを待つことができる。 ３）．通信バッファの構造をデータの格納領域であるデ
ータ部と、そのデータ部のアドレスを持ちジョブ間通信
のための制御テーブルからのリンクを持つ制御部とに分
けることにより、プログラム誤りによる制御部の破壊を
防ぐことができ、ジョブ間通信における動作不正、ある
いは例外を防ぐことができる。 ４）．送信プログラムから通信バッファに直接書き込み
を行い、通信バッファを通信グループ内の任意の受信プ
ログラムに対して送信し、送信を受けた受信プログラム
は、送信の通知を受取った後、その通信バッファを受取
り、通信バッファを直接参照して、送信データを受取る
ことができるので、プログラム間のデータの送信受信を
高速に行うことができ、プログラムによるデータ格納の
ための領域準備をする必要がなくなる。 ５）．システム内の通信グループ情報や通信グループに
属しているプログラムの情報、通信バッファ使用情報な
どをプログラムより取得できるため、ジョブ間通信にお
ける通信状態の監視を行うとともに、負荷状態により通
信バッファの取得や送信を抑止して通信を効率的に行う
ことができる。As described above, according to the present invention, the following effects can be obtained. 1). By providing a program group as a communication group for communication between programs of a multiple programming system in which multiple jobs operate simultaneously, programs belonging to the communication group can freely communicate with each other. It is possible to protect communication from programs not belonging to. 2). A communication buffer that stores transmission data and serves as a communication medium can be acquired and released, and the system common area used by the communication buffer can be dynamically expanded according to the number of communication buffers used. It is possible to prevent the communication buffer from being overloaded by setting a limit on the number of communication buffers inside, and when the communication buffer cannot be acquired by the program, it is possible to wait for the communication buffer to be free. 3). Destruction of the control unit due to a program error by dividing the structure of the communication buffer into a data section that is a data storage area and a control section that has an address of the data section and a link from the control table for inter-job communication It is possible to prevent an illegal operation or exception in communication between jobs. 4). The sending program writes directly to the communication buffer, sends the communication buffer to any receiving program in the communication group, and the receiving program receiving the transmission receives the notification of the transmission and then receives the communication buffer. Since transmission data can be received by directly referring to the communication buffer, data transmission between programs can be performed at high speed, and there is no need to prepare an area for data storage by the program. 5). Since the communication group information in the system, the information of the programs that belong to the communication group, the communication buffer usage information, etc. can be obtained from the program, the communication status in the inter-job communication is monitored and the communication buffer is acquired or sent depending on the load status Can be suppressed and communication can be efficiently performed.
【図１】本発明実施例の全体構成を示すブロック図。FIG. 1 is a block diagram showing the overall configuration of an embodiment of the present invention.
【図２】本発明実施例の要部の構成を示すブロック図。FIG. 2 is a block diagram showing a configuration of a main part of an embodiment of the present invention.
【図３】本発明実施例における通信バッファの構成を示
すブロック図。FIG. 3 is a block diagram showing a configuration of a communication buffer in the embodiment of the present invention.
１、２、Ｂ１ プログラム ３ ジョブ間通信手段 ４ 通信グループ登録削除手段 ５ 通信識別名登録削除手段 ６ 通信バッファ取得解放手段 ７ 通信バッファ送信受信手段 ８ 通信情報参照手段 ９ オープン手段 １０ クローズ手段 １１ 通信バッファ取得手段 １２ 通信バッファ解放手段 １３ 通信バッファ送信手段 １４ 通信バッファ受信手段 １５ 通信グループエントリ １６、１７ 通信識別名エントリ領域 １８ 通信バッファプール １９ 通信バッファ ２０ 中央処理装置 ２１ 記憶装置 Ｂ３ 制御部 Ｂ４ データ部 Ｂ７ 制御部プール Ｂ８ データ部プール Ｂ９ システム共通領域 1, 2, B1 program 3 Inter-job communication means 4 Communication group registration deletion means 5 Communication identification name registration deletion means 6 Communication buffer acquisition / release means 7 Communication buffer transmission / reception means 8 Communication information reference means 9 Open means 10 Close means 11 Communication buffer Acquisition means 12 Communication buffer release means 13 Communication buffer transmission means 14 Communication buffer reception means 15 Communication group entry 16, 17 Communication identification name entry area 18 Communication buffer pool 19 Communication buffer 20 Central processing unit 21 Storage device B3 Control unit B4 Data unit B7 Control part pool B8 Data part pool B9 System common area
Claims (6)
数のジョブを並行的に実行する多重プログラミング形の
データ処理装置において、 前記中央処理装置に各プログラムにより制御される複数
のジョブ実行手段の間の通信を行うジョブ間通信手段を
備え、 前記記憶装置に、相互に通信を行う複数のジョブ実行手
段が一つの通信グループとして通信グループ毎に通信グ
ループエントリ（１５）として登録され、その通信グル
ープエントリにはその複数のジョブ実行手段が相互に通
信すべきデータを一時蓄積する通信バッファプール（１
８）が設定され、 前記中央処理装置に、通信グループエントリの新たな登
録および既に登録された通信グループエントリの削除を
行う通信グループ登録削除手段（４）が設けられたこと
を特徴とするデータ処理装置。1. A multi-programming type data processing apparatus comprising a central processing unit and a storage unit for executing a plurality of jobs in parallel, wherein a plurality of job executing means controlled by each program are provided in the central processing unit. A plurality of job executing means for communicating with each other is registered as a communication group entry (15) for each communication group in the storage device, and the communication group entry In the communication buffer pool (1) in which the plurality of job execution means temporarily store data to be communicated with each other.
8) is set, and the central processing unit is provided with communication group registration deleting means (4) for newly registering communication group entries and deleting already registered communication group entries. apparatus.
て、 前記通信グループエントリに、既に登録された通信グル
ープについてジョブ実行手段対応に通信識別名が登録さ
れ、 前記中央処理装置に、この通信識別名に新たな通信識別
名を加入し既に登録された通信識別名を削除する通信識
別名登録削除手段（５）を備えたことを特徴とするデー
タ処理装置。2. The data processing device according to claim 1, wherein a communication identification name is registered in the communication group entry for a job execution unit for a communication group already registered, and the communication identification name is registered in the central processing unit. A data processing device, comprising: a communication identification name registration deleting means (5) for adding a new communication identification name to and deleting an already registered communication identification name.
て、 前記通信グループエントリに、通信識別名対応に通信デ
ータを格納し通信の媒体となる通信バッファ（１９）が
設定され、 前記中央処理装置に、この通信バッファの領域を取得し
および解放する通信バッファ取得解放手段（６）を備え
たことを特徴とするデータ処理装置。3. The data processing device according to claim 2, wherein a communication buffer (19) that stores communication data corresponding to a communication identifier and serves as a communication medium is set in the communication group entry, and the central processing unit has the communication buffer. A data processing device comprising communication buffer acquisition / release means (6) for acquiring and releasing the area of the communication buffer.
て、 前記通信バッファが、通信データの格納領域であるデー
タ部と、そのデータ部のアドレスを含む制御情報の格納
領域である制御部とを備えたことを特徴とするデータ処
理装置。4. The data processing device according to claim 3, wherein the communication buffer includes a data section which is a storage area of communication data, and a control section which is a storage area of control information including an address of the data section. A data processing device characterized by the above.
て、 送信側のジョブ実行手段から当該通信バッファに通信内
容を書込み、受信側のジョブ実行手段がその通信バッフ
ァを受取るように制御する通信バッファ送信受信手段
（７）を備えたことを特徴とするデータ処理装置。5. The data processing apparatus according to claim 3, wherein communication contents are written from the job execution means on the transmission side to the communication buffer, and the job execution means on the reception side controls the communication buffer transmission so as to receive the communication buffer. A data processing device comprising a receiving means (7).
て、 前記中央処理装置に、通信グループの構成を表示する情
報を含む通信に必要な情報を参照するための通信情報参
照手段（８）を備えたことを特徴とするデータ処理装
置。6. The data processing device according to claim 1, wherein the central processing unit is provided with communication information reference means (8) for referring to information necessary for communication including information for displaying a configuration of a communication group. A data processing device characterized by the above.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP5104553A JP2541447B2 (en) | 1993-04-30 | 1993-04-30 | Data processing device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP5104553A JP2541447B2 (en) | 1993-04-30 | 1993-04-30 | Data processing device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JPH06314207A true JPH06314207A (en) | 1994-11-08 |
| JP2541447B2 JP2541447B2 (en) | 1996-10-09 |
Family
ID=14383666
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP5104553A Expired - Fee Related JP2541447B2 (en) | 1993-04-30 | 1993-04-30 | Data processing device |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP2541447B2 (en) |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JPH01236329A (en) * | 1988-03-17 | 1989-09-21 | Toshiba Corp | Information transmission system |
| JPH03257633A (en) * | 1990-03-08 | 1991-11-18 | Hitachi Ltd | Process control method |
-
1993
- 1993-04-30 JP JP5104553A patent/JP2541447B2/en not_active Expired - Fee Related
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JPH01236329A (en) * | 1988-03-17 | 1989-09-21 | Toshiba Corp | Information transmission system |
| JPH03257633A (en) * | 1990-03-08 | 1991-11-18 | Hitachi Ltd | Process control method |
Also Published As
| Publication number | Publication date |
|---|---|
| JP2541447B2 (en) | 1996-10-09 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| JP2977688B2 (en) | Multi-processing device, method, and processor used for the same | |
| CN100458757C (en) | Inter core communication method and apparatus for multi-core processor in embedded real-time operating system | |
| US5179715A (en) | Multiprocessor computer system with process execution allocated by process managers in a ring configuration | |
| US5924097A (en) | Balanced input/output task management for use in multiprocessor transaction processing system | |
| CN117806540A (en) | Storage device controller and method thereof | |
| US6477560B1 (en) | Method and apparatus for controlling resource | |
| JP2541447B2 (en) | Data processing device | |
| JPH05224956A (en) | Inter-process message communication method | |
| US7920489B1 (en) | Simultaneous receiving and transmitting of data over a network | |
| JPH09330243A (en) | Computer system | |
| JP5031538B2 (en) | Data distribution method, data distribution program, and parallel database system | |
| JPH048824B2 (en) | ||
| JPH06149693A (en) | Electronic mail driving type computer system and file operating method | |
| JPS63233436A (en) | Delay processing method and device | |
| JP3307331B2 (en) | Network file system data transfer method | |
| JP2019016377A (en) | Method for controlling semiconductor memory device | |
| JPS6272051A (en) | Multiple simultaneous processing controlling method in multiple processor system | |
| CN121579243A (en) | Methods and electronic devices for collaborative communication between the storage master process and the compression process. | |
| JPH02253457A (en) | Host computer | |
| JP2971119B2 (en) | High-speed data transfer method in multiple processor system | |
| Marill et al. | Network Data Handling System | |
| JPH0227452A (en) | Dynamic area control processing system for area for controlling line | |
| JP2004272349A (en) | Data processing system, control method for data processing system, external storage device, and control method for external storage device | |
| JP2735400B2 (en) | Asynchronous I/O control method | |
| JPH02302831A (en) | Data transfer control system |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| FPAY | Renewal fee payment (prs date is renewal date of database) |
Year of fee payment: 11 Free format text: PAYMENT UNTIL: 20070725 |
|
| FPAY | Renewal fee payment (prs date is renewal date of database) |
Year of fee payment: 12 Free format text: PAYMENT UNTIL: 20080725 |
|
| FPAY | Renewal fee payment (prs date is renewal date of database) |
Year of fee payment: 13 Free format text: PAYMENT UNTIL: 20090725 |
|
| FPAY | Renewal fee payment (prs date is renewal date of database) |
Free format text: PAYMENT UNTIL: 20100725 Year of fee payment: 14 |
|
| FPAY | Renewal fee payment (prs date is renewal date of database) |
Year of fee payment: 15 Free format text: PAYMENT UNTIL: 20110725 |
|
| LAPS | Cancellation because of no payment of annual fees |