Self-adjusting data processing system

• US 10,644,961 B2
• Filed: 01/12/2018
• Issued: 05/05/2020
• Est. Priority Date: 01/12/2018
• Status: Active Grant

• Current Assignee: Intel Corporation
• Original Assignee: Intel Corporation
• Inventors: Nolan, Keith, Kelly, Mark, Nolan, Michael, Cheevers, Pat
• Primary Examiner(s): Nguyen, Anh Ngoc M
• Application Number:
  US15/870,684
• Publication Number:
  US 20190044818A1
• Time in Patent Office: 844 Days
• Field of Search: None
• CPC Class Codes: G06F 16/245 Query processing
• CPC Class Codes: H04L 12/2803 Home automation networks
• CPC Class Codes: H04L 41/0654 using network fault recovery ring fault isolation or reconfiguration in loop networks without recovery actions by a network management system H04L12/437
• CPC Class Codes: H04L 41/12 Discovery or management of network topologies
• CPC Class Codes: H04L 43/08 Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
• CPC Class Codes: H04L 43/0876 Network utilisation, e.g. volume of load or congestion level
• CPC Class Codes: H04W 8/005 Discovery of network devices, e.g. terminals
• 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

Abstract

A method and apparatus for self-adjusting networks including internet-of-things (IoT) devices is provided. An exemplary system includes a source discovery system configured to identify if a source sending a message is in a database, and, if not, add the source to the database and rank the source by link metrics of messages received from the source. A sink discovery system is configured to identify if a sink receiving a message is in a database, and, if not, add the sink to the database. The sink discovery system is configured to rank the sink by link metrics of messages responded to by the sink. A dynamic mapping system is configured to create a dynamic map of communications between a source and a sink, and implement a self-healing subsystem to restore a loss of communications between a source and a sink.

Claims

1. An apparatus for self-adjusting processing for internet of things (IoT) devices, comprising:

a processor; and

storage to store code, wherein the code, when executed, is to direct the processor to;

identify if a source sending a message is in a database, and, if not, add the source to the database;

rank the source by link metrics of messages received from the source;

identify if a sink receiving a message is in a database, and, if not, add the sink to the database;

rank the sink by link metrics of messages responded to by the sink;

create a dynamic map of communications between a source and a sink; and

implement self-healing to restore a loss of communications between a source and a sink.

2. The apparatus of claim 1, wherein the link metrics comprise packet delivery ratios, uptime, or latency, or any combinations thereof.

3. The apparatus of claim 1, wherein the storage is to store code, wherein the code, when executed, is to direct the processor to detect a lack of communications from an end node within a window of time.

4. The apparatus of claim 3, wherein the storage is to store code, wherein the code, when executed, is to direct the processor to determine a window of time during which a transmission from a source is expected.

5. The apparatus of claim 1, wherein the storage is to store code, wherein the code, when executed, is to direct the processor to signal when an expected communication from a source is not received within a window of time.

6. The apparatus of claim 1, wherein the storage is to store code, wherein the code, when executed, is to direct the processor to send a trace message in a reoccurring window of time.

7. The apparatus of claim 1, comprising a fog node communicatively coupled to a plurality of internet-of-things devices.

8. A non-transitory, computer readable medium comprising code that, when executed, directs a processor to:

identify if a source sending a message is in a database, and, if not, add the source to the database; and

rank the source by link metrics of messages received from the source.

9. The non-transitory, computer readable medium of claim 8, comprising code that, when executed, directs the processor to:

identify if a sink receiving a message is in a database, and, if not, add the sink to the database; and

rank the sink by link metrics of messages responded to by the sink.

10. The non-transitory, computer readable medium of claim 9, comprising code that, when executed, directs the processor to:

create a dynamic map of communications between a source and a sink; and

implement self-healing to restore a loss of communications between a source and a sink.

11. The non-transitory, computer readable medium of claim 8, wherein the link metrics comprise packet delivery ratios, uptime, or latency, or any combinations thereof.

12. The non-transitory, computer readable medium of claim 8, comprising code that, when executed, directs the processor to detect a lack of communications from an end node within a window of time.

13. The non-transitory, computer readable medium of claim 12, comprising code that, when executed, directs the processor to determine a window of time during which a transmission from a source is expected.

14. The non-transitory, computer readable medium of claim 8, comprising code that, when executed, directs the processor to signal when an expected communication from a source is not received within a window of time.

15. The non-transitory, computer readable medium of claim 8, comprising code that, when executed, directs the processor to send a trace message in a reoccurring window of time.

16. The non-transitory, computer readable medium of claim 8, comprising code that, when executed, directs the processor to:

rank a path from a source to a sink; and

create a dynamic source to sink mapping.

17. The non-transitory, computer readable medium of claim 16, comprising code that, when executed, directs the processor to:

detect an absence of a message from a device; and

activate a self-healing technique.

18. The non-transitory, computer readable medium of claim 16, comprising code that, when executed, directs the processor to:

send a trace message to device; and

track the path from the source to the sink.

19. The non-transitory, computer readable medium of claim 16, comprising code that, when executed, directs the processor to:

discover a source based, at least in part, on messages sent from the source; and

add the source to a database.

20. The non-transitory, computer readable medium of claim 16, comprising code that, when executed, directs the processor to:

discover a sink based, at least in part, on messages sent from the sink; and

add the sink to a database.

21. A method for self-adjusting processing for internet of things (IoT) devices, comprising:

identifying if a source sending a message is in a database, and, if not, add the source to the database;

ranking the source by link metrics of messages received from the source;

identifying if a sink receiving a message is in a database, and, if not, add the sink to the database;

ranking the sink by link metrics of messages responded to by the sink;

creating a dynamic map of communications between a source and a sink; and

restoring a loss of communications between a source and a sink.

22. The method of claim 21, comprising detecting a lack of communications from an end node within a window of time.

23. The method of claim 22, comprising determining a window of time during which a transmission from a source is expected.

24. The method of claim 21, comprising signaling when an expected communication from a source is not received within a window of time.

25. The method of claim 21, comprising sending a trace message in a reoccurring window of time.