Managing communication congestion for internet of things devices
First Claim
Patent Images
1. An apparatus for managing communication congestion for internet of things (IoT) devices, comprising:
- a pipeline processing application executed by a processor, the pipeline processing application comprising backpressure detection to identify communication issues in a cloud through congestion, wherein the pipeline processing application is configured to;
send a tracer message to a component in the cloud at a first time period;
store a response from the component in a storage device at a second time period;
calculate a difference between the first time period and the second time period, tt;
calculate a third time period indicating time to process the tracer message, tp;
wherein the pipeline processing application performs backpressure detection by calculating a throughput congestion level of the cloud based on;
a sliding time window with averages for tt and tp values for tracer messages transmitted to a plurality of components in the cloud; and
an all-time average for tt and tp values; and
generate backpressure alert messages;
an IoT device, comprising;
a data transfer controller configured to dispatch messages to the pipeline processing application in the cloud; and
a backpressure monitor configured to accept the backpressure alert messages and adjust a dispatch of messages from the data transfer controller.
1 Assignment
0 Petitions
Accused Products
Abstract
A method and apparatus for managing network congestion for internet-of-things (IoT) devices is provided. An exemplary method includes sending out tracer messages to a plurality of cloud components. Response messages are monitored from the plurality of cloud components. Response messages received are stored in a storage system. The response messages are queried to determine conditions in the cloud. An alert message is created to report network conditions to an IoT device.
28 Citations
20 Claims
-
1. An apparatus for managing communication congestion for internet of things (IoT) devices, comprising:
-
a pipeline processing application executed by a processor, the pipeline processing application comprising backpressure detection to identify communication issues in a cloud through congestion, wherein the pipeline processing application is configured to; send a tracer message to a component in the cloud at a first time period; store a response from the component in a storage device at a second time period; calculate a difference between the first time period and the second time period, tt; calculate a third time period indicating time to process the tracer message, tp; wherein the pipeline processing application performs backpressure detection by calculating a throughput congestion level of the cloud based on; a sliding time window with averages for tt and tp values for tracer messages transmitted to a plurality of components in the cloud; and an all-time average for tt and tp values; and generate backpressure alert messages; an IoT device, comprising; a data transfer controller configured to dispatch messages to the pipeline processing application in the cloud; and a backpressure monitor configured to accept the backpressure alert messages and adjust a dispatch of messages from the data transfer controller. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A method for measuring backpressure in a computing cloud, comprising:
-
sending, by a pipeline processing application executed by a processor, tracer messages to a plurality of components in a cloud the pipeline processing application comprising backpressure detection to identify communication issues in the cloud through congestion; monitoring, by the pipeline processing application, for response messages from the plurality of components; storing received response messages in a storage system; querying the response messages to determine network conditions in the cloud; calculating a buffer congestion level of the computing cloud based on an amount of free disk space, a message rate, a size of messages, a number of seconds required to fill a buffer, or any combinations thereof, wherein the buffer congestion level is calculated by; calculating the number of seconds, n, required to fill a buffer using the following equation; - View Dependent Claims (9, 10, 11, 12, 13, 14, 15, 16, 17, 18)
-
-
19. A non-transitory, computer readable medium comprising code to direct a processor to:
-
send out tracer messages to a plurality of components in a cloud by a backpressure detection mechanism, the backpressure detection mechanism to identify communication issues in the cloud through congestion; monitor for response messages from the plurality of components; store received response messages in a storage system; query the response messages to determine network conditions in the cloud; calculate a congestion level, c, as a number between 0 and 1, wherein a lower value for c represents a slower transfer of data in the cloud, wherein c is set as a lower value of a throughput congestion level, tc, or a buffer congestion level, bc; calculate tc for a component as a ratio of a current time for a response divided by a baseline time for the response from the component; create an alert message to report the congestion level to an internet of things (IoT) device coupled to the cloud; and communicate the alert message to the IoT device. - View Dependent Claims (20)
-
Specification