US 5,335,324 AGranted

Distributed processing system and method for job execution using a plurality of processors and including identification of replicated data

AssigneeHitachi, Ltd.

InventorsMasayuki Orimo, Kinji Mori, Yasuo Suzuki, Minoru Koizumi, Katsumi Kawano, Kozo Nakai, Hirokazu Kasashima

Life of this patent

Estimating the term…

Loading patent…

Abstract

A distributed processing method and system including a plurality of processors connected via a transmission path, in which a function is provided to an arbitrary processor to receive information and data passing through the transmission path and to obtain the received data based on information indicating input/output relationships between modules corresponding to the association of processing between the modules. When required, necessary portions of the obtained information and logging results are extracted, so that not only the time series data log but also the information or data log can be collected corresponding to the flow of a sequence of processing by establishing a display or print-out module. Furthermore, when data is received from an external device, the system generates a message having information indicating the order of the data and the content code representing content of the data and sends the message to the transmission path. A processor receives messages from the transmission path, and stores the data in accordance with each content code in an order which facilitates trouble shooting of the system.

Claims13

Dependent claims

A distributed processing method in a system including a plurality of processors connected via a transmission path for processing data carried in messages by transmission of successive messages through the system, each transmission of a message through the system representing an event of processing by the system, comprising the steps of:

(a) sending from an originating processor to said transmission path a first message containing data, a first content code indicating the content of the data and an event number for identifying an event of processing of the data in the system;
(b) receiving in a first receiving processor said first message as it flows through the transmission path and processing the data in said first message;
(c) sending to said transmission path from said first receiving processor a second message containing a result of processing the data in said first message, a second content code and the same event number as contained in said first message;
(d) receiving in a second receiving processor said second message as it flows through the transmission path and processing the data in said second message;
(e) sending to said transmission path from said second receiving processor a third message containing a result of processing the data in said second message, a third content code and the same event number as contained in said second message;
(f) repeating steps (a) through (e) a predetermined number of times so as to place plural first, second and third messages on said transmission path;
(g) receiving in an analyzing processor from said transmission path at least said plural second and third messages and identifying a processing flow in a processing sequence within the system on the basis of the content codes and event numbers contained in said messages;
(h) receiving in at least one processor plural messages from said transmission path;
and
(i) respectively comparing in said one receiving processor the content code and the event number of a received message with the content code and event number of a previously received message to detect replicated messages having the same content code and event number.

7 more elements

A distributed processing method in a distributed processing system having a plurality of processors connected via a transmission path for processing data carried in messages by transmission of successive messages through the system, each transmission of a message through the system representing an event of processing by the system, comprising the steps of:

sending to said transmission path from a sending processor messages containing data, an event number identifying an event of processing of the data by the system and a content code indicating the content of the data;
receiving in a plurality of receiving processors messages flowing on the transmission path and processing in said receiving processors the data contained in the received messages;
sending to said transmission path from said receiving processors messages containing a result of processing of data contained in a received message, a content code which is different from the content code in the received message and an event number which is the same as the event number in the received message;
and
respectively comparing in a receiving processor the content code and the event number of a received message with the content code and the event number of a previously received message to detect replicated messages having the same content code and event number.

2 more elements

A distributed processing system, including a plurality of processors connected via a transmission path for processing data carried in messages by transmission of successive messages through the system, each transmission of a message through the system representing an event of processing by the system, comprising:

means for sending from an originating processor to said transmission path a first message containing data, a first content code indicating the content of the data and an event number for identifying an event of processing of the data in the system;
means for receiving in a first receiving processor said first message as it flows through the transmission path and processing the data in said first message;
means for sending to said transmission path from said first receiving processor a second message containing a result of processing the data in said first message, a second content code and the same event number as contained in said first message;
means for receiving in a second receiving processor said second message as it flows through the transmission path and processing the data in said second message;
means for sending to said transmission path from said second receiving processor a third message containing a result of processing the data in said second message, a third content code and the same event number as contained in said second message;
means in an analyzing processor for receiving from said transmission path plural second and third messages and identifying a processing flow in a processing sequence within the system on the basis of the content codes and event numbers contained in said messages;
means for receiving in at least one processor plural messages from said transmission path;
and
means for respectively comparing in said one receiving processor the content code and the event number of a received message with the content code and event number of a previously received message to detect replicated messages having the same content code and event number.

6 more elements

A distributed processing system having a plurality of processors connected via a transmission path for processing data carried in messages by transmission of successive messages through the system, each transmission of a message through the system representing an event of processing by the system, comprising:

means for sending to said transmission path from a sending processor messages containing data, an event number identifying an event of processing of the data by the system and a content code indicating the content of the data;
means for receiving in a plurality of receiving processors messages flowing on the transmission path and processing in said receiving processors the data contained in the received messages;
means for sending to said transmission path from said receiving processors messages containing a result of processing of data contained in a received message, a content code which is different from the content code in the received message and an event number which is the same as the event number in the received message;
and
means for respectively comparing in a receiving processor the content code and the event number of a received message with the content code and the event number of a previously received message to detect replicated messages having the same content code and event number.

2 more elements

sending to said transmission path from a sending processor messages containing data, an event number identifying an event of processing of the data by said system and a content code indicating the content of the data;
receiving in a plurality of receiving processors messages flowing on the transmission path and processing in said receiving processors the data contained in the received messages;
sending to said transmission path from said receiving processors messages containing a result of processing of data contained in a received message, a content code which is different from the content code in the received message and an event number which is the same as the event number in the received message;
storing in a structure table information representing a configuration of a program performed by the system including data identifying application programs at each respective processor and input/output relationships between said application programs at each processor as identified by content codes included in messages received from and sent to said transmission path by said processors;
and
identifying the processing within a processor sequence of said system of a plurality of messages received from said transmission path on the basis of the content codes and event numbers included in the messages and said information stored in said structure table.

3 more elements

Dependencies are inferred from the claim text.

Facts

Application: 07/760,349Filed 16 Sep 1991 · continuation
Priority: JP 61-765224 Apr 1986
Granted: 2 Aug 1994
Term ends: Not estimatedThe source records don’t support an estimate.

Classification7 codes

G06F 11/22
Error detection; Error correction; Monitoring: detection or location of defective computer hardware by testing during standby operation or during…
G06F 11/0724
Within a central processing unit [CPU]: in a multiprocessor or a multi-core unit
G06F 11/0763
Error or fault detection not based on redundancy: by bit configuration check, e.g. of formats or tags
G06F 11/14
Responding to the occurrence of a fault, e.g. fault tolerance: error detection or correction of the data by redundancy in operations

Family

Serial895,375Parent of this continuation-in-part · filed 11 Aug 1986
Serial940,495Parent of this continuation-in-part · filed 10 Dec 1986
Serial35,026Parent of this continuation · filed 6 Apr 1987
US 4,797,885 AParent of this continuation-in-part
US 4,803,683 AParent of this continuation-in-part
US 5,335,324 AThis patent

From the US filing history. Foreign family members aren’t listed.