Dynamic data publication and dissemination

• US 8,897,806 B2
• Filed: 10/08/2012
• Issued: 11/25/2014
• Est. Priority Date: 03/27/2012
• Status: Active Grant

• Current Assignee: Google LLC (Alphabet Inc.), Toyota Jidosha Kabushiki Kaisha (Toyota Motor Corporation)
• Original Assignee: Toyota Jidosha Kabushiki Kaisha (Toyota Motor Corporation)
• Inventors: Wakikawa, Ryuji, Vuyyuru, Rama Krishna, Kuntz, Romain
• Primary Examiner(s): ROSE, KERRI M
• Application Number:
  US13/647,252
• Publication Number:
  US 20130258878A1
• Time in Patent Office: 778 Days
• Field of Search: 455/414.3, 455/456.1, 455/456.3, 701117-119
• US Class Current: 455/456.1
• CPC Class Codes: G08G 1/0112 from the vehicle, e.g. floating car data [FCD]
• CPC Class Codes: G08G 1/0116 from roadside infrastructure, e.g. beacons
• CPC Class Codes: G08G 1/0133 for classifying traffic situation
• CPC Class Codes: G08G 1/0141 for traffic information dissemination
• CPC Class Codes: G08G 1/092 Coding or decoding of the information
• CPC Class Codes: G08G 1/096716 where the received information does not generate an automatic action on the vehicle control
• CPC Class Codes: G08G 1/096758 where no selection takes place on the transmitted or the received information
• CPC Class Codes: G08G 1/096783 where the origin of the information is a roadside individual element
• CPC Class Codes: G08G 1/096791 where the origin of the information is another vehicle
• 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/568 Storing data temporarily at an intermediate stage, e.g. caching

Abstract

A system for dynamic data publication and dissemination in a mobile node network is disclosed. The system comprises a collection module, a naming module and a publishing module. The collection module collects sensor data and detects a road event based at least in part on the sensor data. The collection module generates event data that describes the road event. The naming module converts the event data to a set of naming data that conforms to a naming structure. The naming structure includes an application identifier that identifies an application for the road event and a location that identifies a geographical scope for the road event. The naming module caches the set of naming data in a storage device. The publishing module publishes the set of naming data in the mobile node network.

Claims

1. A method for dynamic data publication and dissemination in a mobile node network, the method comprising:

collecting sensor data;

detecting a road event based at least in part on the sensor data;

generating event data that describes the road event;

converting the event data to a first set of naming data that conforms to a naming structure, the naming structure including an application identifier that identifies an application for the road event and a location that identifies a geographical scope for the road event;

caching the first set of naming data in a storage device;

publishing the first set of naming data in the mobile node network;

receiving a second set of naming data conforming to the naming structure at a first node, the second set of naming data describing an interest packet and including location data for a destination node;

determining whether the interest packet is scheduled for transmission at the first node;

responsive to determining that the interest packet is scheduled for transmission at the first node, determining a first distance between the destination node and the first node;

determining a second distance between the destination node and a second node located within a transmission range of the destination node;

determining whether the first distance is greater than the second distance; and

responsive to determining that the first distance is greater than the second distance, canceling the transmission of the interest packet at the first node.

2. The method of claim 1, wherein the naming structure further includes a timestamp that identifies a temporal scope for the road event, a data type indicating a category for the road event and a name identifier that identifies the first set of naming data.

3. The method of claim 1, further comprising:

receiving an interest request from a consumer node;

determining whether reply data matching an interest included in the interest request is found in the storage device;

responsive to determining that the reply data is found, retrieving the reply data from the storage device;

aggregating the reply data to generate a reply packet; and

sending the reply packet to the consumer node.

4. The method of claim 1, further comprising:

receiving a third set of naming data conforming to the naming structure;

caching the third set of naming data in the storage device; and

forwarding the third set of naming data to one or more nodes in the mobile node network.

5. The method of claim 1, further comprising:

generating an interest request including an interest;

determining whether the interest request relates to at least one of a location-specific search and a real-time search; and

responsive to determining that the interest request relates to at least one of the location-specific search and the real-time search, performing a local search for the interest request.

6. A method for dynamic data publication and dissemination in a mobile node network, the method comprising:

collecting sensor data;

detecting a road event based at least in part on the sensor data;

generating event data that describes the road event;

converting the event data to a first set of naming data that conforms to a naming structure, the naming structure including an application identifier that identifies an application for the road event and a location that identifies a geographical scope for the road event;

caching the first set of naming data in a storage device;

publishing the first set of naming data in the mobile node network;

receiving a second set of naming data conforming to the naming structure at a first node, the second set of naming data describing a data packet and including location data describing a source node;

determining whether the data packet is scheduled for transmission at the first node;

responsive to determining that the data packet is scheduled for transmission at the first node, determining a first distance between the source node and the first node;

determining a second distance between the source node and a second node located within a transmission range of the source node;

determining whether the first distance is less than the second distance; and

responsive to determining that the first distance is less than the second distance, canceling the transmission of the data packet at the first node.

7. The method of claim 6, wherein the naming structure further includes a timestamp that identifies a temporal scope for the road event, a data type indicating a category for the road event and a name identifier that identifies the first set of naming data.

8. The method of claim 6, further comprising:

receiving an interest request from a consumer node;

determining whether reply data matching an interest included in the interest request is found in the storage device;

responsive to determining that the reply data is found, retrieving the reply data from the storage device;

aggregating the reply data to generate a reply packet; and

sending the reply packet to the consumer node.

9. The method of claim 6, further comprising:

receiving a third set of naming data conforming to the naming structure;

caching the third set of naming data in the storage device; and

forwarding the third set of naming data to one or more nodes in the mobile node network.

10. The method of claim 6, further comprising:

generating an interest request including an interest;

determining whether the interest request relates to at least one of a location-specific search and a real-time search; and

responsive to determining that the interest request relates to at least one of the location-specific search and the real-time search, performing a local search for the interest request.

11. A system for dynamic data publication and dissemination in a mobile node network, the system comprising:

one or more processors;

a collection module executable by the one or more processors to collect sensor data, the collection module further executable to detect a road event based at least in part on the sensor data and to generate event data that describes the road event;

a naming module executable by the one or more processors and communicatively coupled to the collection module, the naming module executable to convert the event data to a first set of naming data that conforms to a naming structure, the naming structure including an application identifier that identifies an application for the road event and a location that identifies a geographical scope for the road event, the naming module further executable to cache the first set of naming data in a storage device;

a publishing module executable by the one or more processors and communicatively coupled to the naming module and collection module, the publishing module executable to publish the first set of naming data in the mobile node network;

a communication module executable by the one or more processors and communicatively coupled to the collection module, the naming module and the publishing module, the communication module executable to receive a second set of naming data conforming to the naming structure at a first node, the second set of naming data describing an interest packet and including location data for a destination node; and

a forwarding module executable by the one or more processors and communicatively coupled to the communication module, the forwarding module executable to;

determine whether the interest packet is scheduled for transmission at the first node;

responsive to determining that the interest packet is scheduled for transmission at the first node, determine a first distance between the destination node and the first node;

determine a second distance between the destination node and a second node located within a transmission range of the destination node;

determine whether the first distance is greater than the second distance; and

responsive to determining that the first distance is greater than the second distance, cancel the transmission of the interest packet at the first node.

12. The system of claim 11, wherein the naming structure further includes a timestamp that identifies a temporal scope for the road event, a data type indicating a category for the road event and a name identifier that identifies the first set of naming data.

13. The system of claim 11, wherein the communication module is further executable to receive an interest request from a consumer node and to send a reply packet to the consumer node, and the system further comprises:

a reply module executable by the one or more processors and communicatively coupled to the communication module, the collection module, the naming module and the publishing module, the reply module executable to;

determine whether reply data matching an interest included in the interest request is found in the storage device;

responsive to determining that the reply data is found, retrieve the reply data from the storage device; and

aggregate the reply data to generate the reply packet.

14. The system of claim 11, wherein the communication module is further executable to receive a third set of naming data conforming to the naming structure, and

the forwarding module is further executable to cache the third set of naming data in the storage device and to forward the third set of naming data to one or more nodes in the mobile node network.

15. The system of claim 11, further comprising:

an interest module executable by the one or more processors and communicatively coupled to the collection module, the naming module and the publishing module, the interest module executable to generate an interest request including an interest; and

a search module executable by the one or more processors and communicatively coupled to the interest module, the search module executable to determine whether the interest request relates to at least one of a location-specific search and a real-time search, responsive to determining that the interest request relates to at least one of the location-specific search and the real-time search, the search module further executable to perform a local search for the interest request.

16. A system for dynamic data publication and dissemination in a mobile node network, the system comprising:

one or more processors;

a collection module executable by the one or more processors to collect sensor data, the collection module further executable to detect a road event based at least in part on the sensor data and to generate event data that describes the road event;

a naming module executable by the one or more processors and communicatively coupled to the collection module, the naming module executable to convert the event data to a first set of naming data that conforms to a naming structure, the naming structure including an application identifier that identifies an application for the road event and a location that identifies a geographical scope for the road event, the naming module further executable to cache the first set of naming data in a storage device;

a publishing module executable by the one or more processors and communicatively coupled to the naming module and collection module, the publishing module executable to publish the first set of naming data in the mobile node network;

a communication module executable by the one or more processors and communicatively coupled to the collection module, the naming module and the publishing module, the communication module executable to receive a second set of naming data conforming to the naming structure at a first node, the second set of naming data describing a data packet and including location data describing a source node; and

a forwarding module executable by the one or more processors and communicatively coupled to the communication module, the forwarding module executable to;

determine whether the data packet is scheduled for transmission at the first node;

responsive to determining that the data packet is scheduled for transmission at the first node, determine a first distance between the source node and the first node;

determine a second distance between the source node and a second node located within a transmission range of the source node;

determine whether the first distance is less than the second distance; and

responsive to determining that the first distance is less than the second distance, cancel the transmission of the data packet at the first node.

17. The system of claim 16, wherein the naming structure further includes a timestamp that identifies a temporal scope for the road event, a data type indicating a category for the road event and a name identifier that identifies the first set of naming data.

18. The system of claim 16, wherein the communication module is further executable to receive an interest request from a consumer node and to send a reply packet to the consumer node, and the system further comprises:

a reply module executable by the one or more processors and communicatively coupled to the communication module, the collection module, the naming module and the publishing module, the reply module executable to;

determine whether reply data matching an interest included in the interest request is found in the storage device;

responsive to determining that the reply data is found, retrieve the reply data from the storage device; and

aggregate the reply data to generate the reply packet.

19. The system of claim 16, wherein

the communication module is further executable to receive a third set of naming data conforming to the naming structure, and

the forwarding module is further executable to cache the third set of naming data in the storage device and to forward the third set of naming data to one or more nodes in the mobile node network.

20. The system of claim 16, further comprising:

an interest module executable by the one or more processors and communicatively coupled to the collection module, the naming module and the publishing module, the interest module executable to generate an interest request including an interest; and

a search module executable by the one or more processors and communicatively coupled to the interest module, the search module executable to determine whether the interest request relates to at least one of a location-specific search and a real-time search, responsive to determining that the interest request relates to at least one of the location-specific search and the real-time search, the search module further executable to perform a local search for the interest request.

21. A computer program product comprising a non-transitory computer readable medium encoding instructions that, in response to execution by a computing device, cause the computing device to perform operations comprising:

collecting sensor data;

detecting a road event based at least in part on the sensor data;

generating event data that describes the road event;

converting the event data to a first set of naming data that conforms to a naming structure, the naming structure including an application identifier that identifies an application for the road event and a location that identifies a geographical scope for the road event;

caching the first set of naming data in a storage device;

publishing the first set of naming data in the mobile node network;

receiving a second set of naming data conforming to the naming structure at a first node, the second set of naming data describing an interest packet and including location data for a destination node;

determining whether the interest packet is scheduled for transmission at the first node;

responsive to determining that the interest packet is scheduled for transmission at the first node, determining a first distance between the destination node and the first node;

determining a second distance between the destination node and a second node located within a transmission range of the destination;

determining whether the first distance is greater than the second distance; and

responsive to determining that the first distance is greater than the second distance, canceling the transmission of the interest packet at the first node.

22. The computer program product of claim 21, wherein the naming structure further includes a timestamp that identifies a temporal scope for the road event, a data type indicating a category for the road event and a name identifier that identifies the first set of naming data.

23. The computer program product of claim 21, wherein the instructions cause the computing device to perform operations further comprising:

receiving an interest request from a consumer node;

determining whether reply data matching an interest included in the interest request is found in the storage device;

responsive to determining that the reply data is found, retrieving the reply data from the storage device;

aggregating the reply data to generate a reply packet; and

sending the reply packet to the consumer node.

24. The computer program product of claim 21, wherein the instructions cause the computing device to perform operations further comprising:

generating an interest request including an interest;

determining whether the interest request relates to at least one of a location-specific search and a real-time search; and

responsive to determining that the interest request relates to at least one of the location-specific search and the real-time search, performing a local search for the interest request.

25. A computer program product comprising a non-transitory computer readable medium encoding instructions that, in response to execution by a computing device, cause the computing device to perform operations comprising:

collecting sensor data;

detecting a road event based at least in part on the sensor data;

generating event data that describes the road event;

converting the event data to a first set of naming data that conforms to a naming structure, the naming structure including an application identifier that identifies an application for the road event and a location that identifies a geographical scope for the road event;

caching the first set of naming data in a storage device;

publishing the first set of naming data in the mobile node network;

receiving a second set of naming data conforming to the naming structure at a first node, the second set of naming data describing a data packet and including location data describing a source node;

determining whether the data packet is scheduled for transmission at the first node;

responsive to determining that the data packet is scheduled for transmission at the first node, determining a first distance between the source node and the first node;

determining a second distance between the source and a second node located within a transmission range of the source node;

determining whether the first distance is less than the second distance; and

responsive to determining that the first distance is less than the second distance, canceling the transmission of the data packet at the first node.

26. The computer program product of claim 25, wherein the naming structure further includes a timestamp that identifies a temporal scope for the road event, a data type indicating a category for the road event and a name identifier that identifies the first set of naming data.

27. The computer program product of claim 25, wherein the instructions cause the computing device to perform operations further comprising:

receiving an interest request from a consumer node;

determining whether reply data matching an interest included in the interest request is found in the storage device;

responsive to determining that the reply data is found, retrieving the reply data from the storage device;

aggregating the reply data to generate a reply packet; and

sending the reply packet to the consumer node.

28. The computer program product of claim 25, wherein the instructions cause the computing device to perform operations further comprising:

generating an interest request including an interest;

determining whether the interest request relates to at least one of a location-specific search and a real-time search; and

responsive to determining that the interest request relates to at least one of the location-specific search and the real-time search, performing a local search for the interest request.