Distributed Processing System

• US 20150249588A1
• Filed: 08/20/2014
• Published: 09/03/2015
• Est. Priority Date: 02/28/2014
• Status: Active Grant

• Current Assignee: Tyco Fire & Security GmbH (Johnson Controls International plc)
• Original Assignee: Tyco Fire & Security GmbH (Johnson Controls International plc)
• Inventors: Hall, Stewart E., Rasband, Paul B., Leon, Gustavo, Trivelpiece, Craig
• Granted Patent: US 10,379,873 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: A61B 17/00 Surgical instruments, devices or methods, e.g. tourniquets A61B18/00 takes precedence; contraceptive devices, pessaries, or applicators therefor A61F6/00; eye surgery A61F9/007; ear surgery A61F11/00
• CPC Class Codes: G01S 13/765 with exchange of information between interrogator and responder
• CPC Class Codes: G01S 13/876 Combination of several spaced transponders or reflectors of known location for determining the position of a receiver G01S13/874 takes precedence
• CPC Class Codes: G01S 5/0236 Assistance data, e.g. base station almanac
• CPC Class Codes: G01S 5/0284 Relative positioning
• CPC Class Codes: G01S 5/0295 Proximity-based methods, e.g. position inferred from reception of particular signals
• CPC Class Codes: G06F 8/63 Image based installation; Cloning; Build to order
• CPC Class Codes: G06F 9/4416 Network booting; Remote initial program loading [RIPL]
• CPC Class Codes: G07C 9/27 with central registration
• CPC Class Codes: G08B 13/19608 Tracking movement of a target, e.g. by detecting an object predefined as a target, using target direction and or velocity to predict its new position
• CPC Class Codes: G08B 13/19613 Recognition of a predetermined image pattern or behaviour pattern indicating theft or intrusion
• CPC Class Codes: G08B 13/19634 Electrical details of the system, e.g. component blocks for carrying out specific functions
• CPC Class Codes: G08B 13/19671 Addition of non-video data, i.e. metadata, to video stream
• CPC Class Codes: G08B 13/19697 Arrangements wherein non-video detectors generate an alarm themselves
• CPC Class Codes: G08B 25/007 Details of data content structure of message packets; data protocols
• CPC Class Codes: G08B 25/009 Signalling of the alarm condition to a substation whose identity is signalled to a central station, e.g. relaying alarm signals in order to extend communication range
• CPC Class Codes: G08B 29/181 due to failing power supply
• CPC Class Codes: G08B 29/188 Data fusion; cooperative systems, e.g. voting among different detectors
• CPC Class Codes: G08B 7/062 indicating emergency exits
• CPC Class Codes: G08B 7/066 guiding along a path, e.g. evacuation path lighting strip
• CPC Class Codes: H04L 12/4625 : Single bridge functionality, e.g. connection of two networks over a single bridge
• CPC Class Codes: H04L 12/6418 : Hybrid transport
• CPC Class Codes: H04L 2101/672 : Short addresses
• CPC Class Codes: H04L 43/0805 : by checking availability
• CPC Class Codes: H04L 43/0876 : Network utilisation, e.g. volume of load or congestion level
• CPC Class Codes: H04L 61/106 : across networks, e.g. mapping telephone numbers to data network addresses
• CPC Class Codes: H04L 61/59 : using proxies for addressing
• CPC Class Codes: H04L 67/104 : Peer-to-peer [P2P] networks
• CPC Class Codes: H04L 67/1051 : Group master selection mechanisms
• CPC Class Codes: H04L 67/1093 : Some peer nodes performing special functions
• CPC Class Codes: H04L 67/12 : specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
• CPC Class Codes: H04L 67/34 : involving the movement of software or configuration parameters network booting or remote initial program loading [RIPL] G06F9/4416
• CPC Class Codes: H04L 9/004 : for fault attacks
• CPC Class Codes: H04N 23/65 : Control of camera operation in relation to power supply
• CPC Class Codes: H04N 5/76 : Television signal recording
• CPC Class Codes: H04W 16/26 : Cell enhancers or enhancement, e.g. for tunnels, building shadow
• CPC Class Codes: H04W 24/02 : Arrangements for optimising operational condition
• CPC Class Codes: H04W 4/38 : for collecting sensor information
• CPC Class Codes: H04W 8/26 : Network addressing or numbering for mobility support
• CPC Class Codes: H04W 84/18 : Self-organising networks, e.g. ad-hoc networks or sensor networks
• CPC Class Codes: H04W 88/04 : adapted for relaying to or from another terminal or user
• CPC Class Codes: H04W 92/02 : Inter-networking arrangements
• CPC Class Codes: Y04S 40/00 : Systems for electrical power generation, transmission, distribution or end-user application management characterised by the use of communication or information technologies, or communication or information technology specific aspects supporting them
• CPC Class Codes: Y04S 40/18 : Network protocols supporting networked applications, e.g. including control of end-device applications over a network
• CPC Class Codes: Y04S 40/20 : Information technology specific aspects, e.g. CAD, simulation, modelling, system security

Abstract

Described is a system that includes a queue cluster including first network devices that cooperate to communicate with end nodes of a network and to store information from the end nodes in memory, a processing cluster comprising second network devices that cooperate to perform one or more tasks on the information from the queue cluster, and a database cluster including third network devices that cooperate to provide storage for use by the processing cluster, with the queue cluster, the processing cluster, and the database cluster being part of a local network that is connectable to an external network, the local network including a wireless mesh network and for the one or more tasks, a network device among the second network devices is selected as a leader responsible for task execution.

Claims

1. A system comprising:

a queue cluster comprising first network devices that cooperate to communicate with end nodes of a network and to store information from the end nodes in memory;

a processing cluster comprising second network devices that cooperate to perform one or more tasks on the information from the queue cluster; and

a database cluster comprising third network devices that cooperate to provide storage for use by the processing cluster;

with the queue cluster, the processing cluster, and the database cluster being part of a local network that is connectable to an external network, the local network comprising a wireless mesh network and for the one or more tasks, a network device among the second network devices is selected as a leader responsible for task execution.

2. The system of claim 1, wherein the first network devices, the second network devices, and the third network devices all include at least some devices in common.

3. The system of claim 1, wherein at least some of the functions of the networked devices are redundant in each of the queue cluster, the processing cluster, and the database cluster.

4. The system of claim 1, wherein the leader is a first leader and the processing cluster is configured to select a second leader in response to an event associated with the first leader.

5. The system of claim 4, wherein the event comprises failure of the first leader.

6. The system of claim 1, wherein the processing cluster comprises one or more worker routines distributed across one or more second network devices, the one or more worker routines comprising a set of rules for acting upon received data.

7. The system of claim 6, wherein the processing cluster is configured to determine when the one or more worker routines are overloaded and, in response, to launch one or more additional worker routines.

8. A computer program product tangibly stored on one or more computer-readable hardware storage devices, the computer program product comprising instructions to:

cause first network devices to cooperate to form a queue cluster to communicate with end nodes of a network and to store information from the end nodes in memory;

cause second network devices to cooperate to form a processing cluster to perform one or more tasks on the information from the queue cluster; and

cause third network devices to cooperate to form a database cluster to provide storage for use by the processing cluster;

wherein the queue cluster, the processing cluster, and the database cluster are part of a local network that is connectable to an external network, the local network comprising a wireless mesh network; and

wherein, for each of the one or more tasks, a network device among the second network devices is selected as a leader responsible for task execution.

9. The computer program product of claim 8, wherein the first network devices, the second network devices, and the third network devices all include at least some devices in common.

10. The computer program product of claim 8, wherein at least some of the functions of the networked devices are redundant in each of the queue cluster, the processing cluster, and the database cluster.

11. The computer program product of claim 8, wherein the leader is a first leader and the processing cluster is configured to select a second leader in response to an event associated with the first leader.

12. The computer program product of claim 11, wherein the event comprises failure of the first leader.

13. The computer program product of claim 8, wherein the processing cluster comprises one or more worker routines distributed across one or more second network devices, the one or more worker routines comprising a set of rules for acting upon received data.

14. The computer program product of claim 13, wherein the processing cluster is configured to determine when the one or more worker routines are overloaded and, in response, to launch one or more additional worker routines,

15. A method comprising:

forming a queue cluster comprising first network devices, the queue cluster communicating with end nodes of a network and to store information from the end nodes in memory;

forming a processing cluster comprising second network devices, the processing cluster performing one or more tasks on the information from the queue cluster; and

forming a database cluster comprising third network devices, the database cluster providing storage for use by the processing cluster;

wherein the queue cluster, the processing cluster, and the database cluster are part of a local network that is connectable to an external network, the local network comprising a wireless mesh network; and

wherein, for each of the one or more tasks, a network device among the second network devices is selected as a leader responsible for task execution.