Efficient data processing in a mesh network of computing devices

Patent metadata

Field	Value
Publication number	US-11363094-B2
Application number	US-202016933892-A
Country	US
Kind code	B2
Filing date	Jul 20, 2020
Priority date	Jul 20, 2020
Publication date	Jun 14, 2022
Grant date	Jun 14, 2022

Abstract

In an approach for efficient data processing in a mesh network of computing devices, a processor receives data to be processed in the mesh network. A processor distributes a set of computational units to a set of computing devices in the mesh network. A processor creates a computational plan to construct a computational pipeline of the set of computational units. The computational plan considers cost and performance trade-offs by considering limitation of hardware resources, processing speed, accuracy and application requirements. A processor executes the computational plan by sending data to assigned computational units.

First claim

What is claimed is:

1. A computer-implemented method comprising:
receiving, by one or more processors, data to be processed in a mesh network including a set of computing devices;
distributing, by one or more processors, a set of computational units to the set of computing devices in the mesh network;
creating, by one or more processors, a computational plan to construct a computational pipeline of the set of computational units wherein the computational plan considers cost and performance trade-offs by considering limitation of hardware resources, processing speed, accuracy and application requirements;
responsive to detecting a device change in the mesh network, adjusting the computational plan based on the device change;
responsive to identifying a characterization change of the data, adjusting the computational plan to include the characterization change; and
executing, by one or more processors, the computational plan by sending data to assigned computational units.

2. The computer-implemented method of claim 1 , wherein the set of computational units are executables selected from a group consisting of data processing algorithms and a common framework.

3. The computer-implemented method of claim 1 , wherein distributing the set of computational units comprises:
broadcasting the set of computational units to the set of computing devices; and
responsive to receiving a selected computation unit by an accepting device in the set of computing devices, self-assigning the selected computation unit.

4. The computer-implemented method of claim 3 , wherein self-assigning the selected computation unit comprises broadcasting an acceptance of the selected computational unit.

5. The computer-implemented method of claim 1 , wherein the data is a video feed.

6. The computer-implemented method of claim 5 , wherein the mesh network includes devices selected from a group consisting of video feed device without an integrated computing capability, computing device without an integrated camera, and hybrid device with both camera and computing capability.

7. A computer program product comprising:
one or more computer readable storage media, and program instructions collectively stored on the one or more computer readable storage media, the program instructions comprising:
program instructions to receive data to be processed in a mesh network including a set of computing devices;
program instructions to distribute a set of computational units to the set of computing devices in the mesh network;
program instructions to create a computational plan to construct a computational pipeline of the set of computational units wherein the computational plan considers cost and performance trade-offs by considering limitation of hardware resources, processing speed, accuracy and application requirements;
program instructions to, responsive to detecting a device change in the mesh network, adjust the computational plan based on the device change;
program instructions to, responsive to identifying a characterization change of the video feed, adjust the computational plan to include the characterization change; and
program instructions to execute the computational plan by sending data to assigned computational units.

8. The computer program product of claim 7 , wherein the set of computational units are executables selected from a group consisting of data processing algorithms and a common framework.

9. The computer program product of claim 7 , wherein program instructions to distribute the set of computational units comprise:
program instructions to broadcast the set of computational units to the set of computing devices; and
program instructions, responsive to receiving a selected computation unit by an accepting device in the set of computing devices, to self-assign the selected computation unit.

10. The computer program product of claim 9 , wherein program instructions to self-assign the selected computation unit comprise program instructions to broadcast an acceptance of the selected computational unit.

11. The computer program product of claim 7 , wherein the data is a video feed.

12. The computer program product of claim 11 , wherein the mesh network includes devices selected from a group consisting of video feed device without an integrated computing capability, computing device without an integrated camera, and hybrid device with both camera and computing capability.

13. A computer system comprising:
one or more computer processors, one or more computer readable storage media, and program instructions stored on the one or more computer readable storage media for execution by at least one of the one or more computer processors, the program instructions comprising:
program instructions to receive data to be processed in a mesh network including a set of computing devices;
program instructions to distribute a set of computational units to the set of computing devices in the mesh network;
program instructions to create a computational plan to construct a computational pipeline of the set of computational units wherein the computational plan considers cost and performance trade-offs by considering limitation of hardware resources, processing speed, accuracy and application requirements;
program instructions to, responsive to detecting a device change in the mesh network, adjust the computational plan based on the device change;
program instructions to, responsive to identifying a characterization change of the video feed, adjust the computational plan to include the characterization change; and
program instructions to execute the computational plan by sending data to assigned computational units.

14. The computer system of claim 13 , wherein the set of computational units are executables selected from a group consisting of data processing algorithms and a common framework.

15. The computer system of claim 13 , wherein program instructions to distribute the set of computational units comprise:
program instructions to broadcast the set of computational units to the set of computing devices; and
program instructions, responsive to receiving a selected computation unit by an accepting device in the set of computing devices, to self-assign the selected computation unit.

16. The computer system of claim 15 , wherein program instructions to self-assign the selected computation unit comprise program instructions to broadcast an acceptance of the selected computational unit.

17. The computer system of claim 13 , wherein the data is a video feed.

Assignees

• IBM

Inventors

• Bobbitt Russell Patrick
• Pinel Florian
• Coldicott Peter Alan

Classifications

• H04N23/80

  Camera processing pipelines; Components thereof · CPC title

• H04L41/0816

  the condition being an adaptation, e.g. in response to network events · CPC title

• H04L41/0826

  for reduction of network costs (H04L41/0833 takes precedence) · CPC title

• H04L67/12

  specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks · CPC title

• H04L67/10 Primary

  in which an application is distributed across nodes in the network (software deployment G06F8/60; multiprogramming arrangements G06F9/46) · CPC title