US5335324A
Expired / Lapsed
US
⏱️ 0.0 years remaining
Distributed processing system and method for job execution using a plurality of processors and including identification of replicated data
Assignee: Hitachi Ltd
•
Filing: 1991-09-16
•
Granted: 1994-08-02
•
Expires: 2011-09-16
Abstract
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.
Inventors
- 👤 Masayuki Orimo
- 👤 Kinji Mori
- 👤 Yasuo Suzuki
- 👤 Minoru Koizumi
- 👤 Katsumi Kawano
- 👤 Kozo Nakai
- 👤 Hirokazu Kasashima
Bibliographic Details
Application Number
—
Jurisdiction
US
Data Source
google_patents
Last Synchronized
2026-10-29 03:54
CPC Classifications
G; G06; G06F; G06F11/00; G06F11/22; G06F11/07; G06F11/0703; G06F11/0706; G06F11/0721; G06F11/0724; G06F11/0751; G06F11/0763; G06F11/14; G06F11/16; G06F11/18; G06F11/182; G06F11/26; G06F11/27
Claims Analysis
Total Claims: 18
Claim 1
Independent Claim
348 words
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.
Claim 2
Dependent Claim
348 words
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.
Claim 3
Dependent Claim
210 words
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.
Claim 4
Dependent Claim
210 words
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.
Claim 5
Dependent Claim
47 words
A distributed processing method according to claim 2, further comprising the step of sending to said transmission path from a receiving processor, which detects a replicated message, a message containing an indication of detection of a replicated message and the event number contained in the replicated message.
Claim 6
Dependent Claim
34 words
A distributed processing method according to claim 3, further comprising the step of inhibiting in a receiving processor a processing of data in a received message which has been detected as a replicated message.
Claim 7
Dependent Claim
53 words
A distributed processing method according to claim 3, wherein each receiving processor collects for a predetermined period of time detected replicated messages having the same event number and, at the end of said predetermined period of time, selects one of the collected messages based on majority decision logic and processes the selected message.
Claim 8
Dependent Claim
322 words
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.
Claim 9
Dependent Claim
322 words
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.
Claim 10
Dependent Claim
210 words
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.
Claim 11
Dependent Claim
210 words
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.
Claim 12
Dependent Claim
46 words
A distributed processing system according to claim 7, further comprising means for sending to said transmission path from a receiving processor, which detects a replicated message, a message containing an indication of detection of a replicated message and the event number contained in the replicated message.
Claim 13
Dependent Claim
33 words
A distributed processing system according to claim 8, further comprising means for inhibiting in a receiving processor a processing of data in a received message which has been detected as a replicated message.
Claim 14
Dependent Claim
56 words
A distributed processing system according to claim 8, wherein each receiving processor includes means for collecting for a predetermined period of time detected replicated messages having the same event number and, at the end of said predetermined period of time, selects one of the collected messages based on majority decision logic and processes the selected message.
Claim 15
Dependent Claim
264 words
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 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.
Claim 16
Dependent Claim
264 words
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 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.
Claim 17
Dependent Claim
66 words
A distributed processing method according to claim 11, wherein said structure table includes a respective table for each processor, each respective table including an area for storing a processor number and an area for storing input content codes and output content codes for the respective application programs of the processor, and buffer storage in which data of received messages is stored for the respective content codes.
Claim 18
Dependent Claim
46 words
A distributed processing method according to claim 12, wherein each respective table further includes upper stream program pointers and lower stream program pointers indicating locations of an input data information program and an output data information program, respectively, for respective content codes within the structure table.
References Cited (Backward Citations)
USPTO Annuity & Maintenance Windows
| Annuity Stage | Window Opens | Payment Deadline | Surcharge Period Until | Estimated Fee | Status |
|---|---|---|---|---|---|
| 3.5 Years (Year 4) | 1997-08-01 | 1998-01-31 | 1998-08-02 | $2000.00 | Window Closed / Lapsed |
| 7.5 Years (Year 8) | 2001-08-01 | 2002-01-31 | 2002-08-02 | $3760.00 | Window Closed / Lapsed |
| 11.5 Years (Year 12) | 2005-08-01 | 2006-01-31 | 2006-08-02 | $7700.00 | Window Closed / Lapsed |