Managing communication congestion for internet of things devices

• US 10,097,379 B2
• Filed: 12/23/2015
• Issued: 10/09/2018
• Est. Priority Date: 12/23/2015
• Status: Active Grant

• Current Assignee: Intel Corporation
• Original Assignee: Intel Corporation
• Inventors: Nolan, Keith, Nolan, Michael, Kelly, Mark
• Primary Examiner(s): Choi, Eunsook
• Application Number:
  US14/757,742
• Publication Number:
  US 20170187642A1
• Time in Patent Office: 1,021 Days
• Field of Search: None
• CPC Class Codes: H04L 12/66 Arrangements for connecting between networks having differing types of switching systems, e.g. gateways
• CPC Class Codes: H04L 47/263 Rate modification at the source after receiving feedback
• CPC Class Codes: H04L 47/32 by discarding or delaying data units, e.g. packets or frames
• 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/5682 Policies or rules for updating, deleting or replacing the stored data
• CPC Class Codes: H04W 4/70 Services for machine-to-machine communication [M2M] or machine type communication [MTC]
• CPC Class Codes: H04W 40/22 using selective relaying for reaching a BTS [Base Transceiver Station] or an access point

Abstract

A method and apparatus for managing communication congestion for internet of things (IoT) devices are provided. An exemplary apparatus includes an IoT device that includes a data transfer controller configured to create a sensor message and dispatch the sensor message to a pipeline processing application in a cloud. A data store is configured to store the sensor message in a cache if it cannot be sent due to communication issues. A data backlog transfer controller is configured to send the sensor message from the data store when the communications issues are not present.

Claims

1. An apparatus for managing communication congestion for internet of things (IoT) devices, comprising:

an IoT device, comprising;

a data transfer controller configured to create a sensor message and dispatch the sensor message at a predetermined rate to a pipeline processing application in a cloud;

a data store configured to store the sensor message in a cache if the sensor message cannot be sent due to a communication issue; and

a data backlog transfer controller configured to;

change the predetermined rate to a new rate in response to an indication from the pipeline processing application that the communication issue is present;

send the sensor message to the data store in response to the indication from the pipeline processing application that the communication issue is present; and

send the sensor message from the data store when the communication issue is not present.

2. The apparatus of claim 1, wherein the data backlog transfer controller is configured to send the sensor message from the cache using a first in-first out mode, a last in-first out mode, or a sampled mode.

3. The apparatus of claim 1, wherein the data backlog transfer controller is configured to accept control messages that change a mode for sending the sensor message.

4. The apparatus of claim 1, wherein the IoT device comprises an IoT gateway coupled to a plurality of IoT devices and wherein the IoT gateway is configured to send sensor messages from the plurality of IoT devices to the pipeline processing application.

5. The apparatus of claim 1, wherein the IoT device comprises an IoT gateway coupled to a plurality of sensors.

6. The apparatus of claim 1, comprising a backpressure monitor configured to accept backpressure alert messages, wherein the backpressure monitor is configured to adjust a rate of dispatch of sensor messages from the cache.

7. An internet of things (IoT) device for managing communication congestion, comprising:

a data transfer controller configured to create a sensor message and dispatch the sensor message at a predetermined rate to a pipeline processing application in a cloud;

a data store configured to store the sensor message in a cache if the sensor message cannot be sent due to a communication issue; and

a data backlog transfer controller configured to;

change the predetermined rate to a new rate in response to an indication from the pipeline processing application that the communication issue is present;

send the sensor message to the data store in response to the indication from the pipeline processing application that the communication issue is present; and

send the sensor message from the data store.

8. The IoT device of claim 7, wherein the data backlog transfer controller is configured to send the sensor message from the cache using a first in-first out mode, a last in-first out mode, or a sampled mode.

9. The IoT device of claim 7, wherein the data backlog transfer controller is configured to accept control messages that change a mode for sending the sensor message.

10. The IoT device of claim 7, comprising an IoT gateway coupled to a plurality of IoT devices and wherein the IoT gateway is configured to send sensor messages from the plurality of IoT devices to the pipeline processing application.

11. The IoT device of claim 7, comprising an IoT gateway coupled to a plurality of sensors.

12. The IoT device of claim 7, wherein the sensor message remains in a monitored directory if the sensor message is not successfully dispatched.