Dynamic Data Publication and Dissemination

• US 20130258878A1
• Filed: 10/08/2012
• Published: 10/03/2013
• 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 Infotechnology Center Co., Ltd. (Toyota Motor Corporation), Toyota Jidosha Kabushiki Kaisha (Toyota Motor Corporation)
• Inventors: Wakikawa, Ryuji, Vuyyuru, Rama Krishna, Kuntz, Romain
• Granted Patent: US 8,897,806 B2
• Time in Patent Office: Days
• US Class Current: 370/252
• 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; and

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

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 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.

4. The method of claim 1, further comprising:

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.

5. 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.

6. The method of claim 1, further comprising:

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

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

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

7. 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.

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

a collection module for collecting sensor data, the collection module detecting a road event based at least in part on the sensor data and generating event data that describes the road event;

a naming module communicatively coupled to the collection module, the naming module 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, the naming module caching the first set of naming data in a storage device; and

a publishing module communicatively coupled to the naming module and collection module, the publishing module publishing the first set of naming data in the mobile node network.

9. The system of claim 8, 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.

10. The system of claim 8, further comprising:

a communication module communicatively coupled to the collection module, the naming module and the publishing module, the communication module 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; and

a forwarding module communicatively coupled to the communication module, the forwarding module configured 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.

11. The system of claim 8, further comprising:

a communication module communicatively coupled to the collection module, the naming module and the publishing module, the communication module 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; and

a forwarding module communicatively coupled to the communication module, the forwarding module configured 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.

12. The system of claim 8, further comprising:

a communication module communicatively coupled to the collection module, the naming module and the publishing module, the communication module receiving an interest request from a consumer node, the communication module sending a reply packet to the consumer node; and

a reply module communicatively coupled to the communication module, the collection module, the naming module and the publishing module, the reply module configured 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.

13. The system of claim 8, further comprising:

a communication module communicatively coupled to the collection module, the naming module and the publishing module, the communication module receiving a second set of naming data conforming to the naming structure;

a forwarding module communicatively coupled to the communication module, the forwarding module caching the second set of naming data in the storage device, the forwarding module forwarding the second set of naming data to one or more nodes in the mobile node network.

14. The system of claim 8, further comprising:

an interest module communicatively coupled to the collection module, the naming module and the publishing module, the interest module generating an interest request including an interest; and

a search module communicatively coupled to the interest module, the search module determining 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 performing a local search for the interest request.

15. 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; and

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

16. The computer program product of claim 15, 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.

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

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.

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

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.

19. The computer program product of claim 15, 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.

20. The computer program product of claim 15, 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.