A method including receiving a data packet over a network, the data packet having a size. The method also includes parsing the data packet into a header and a body. The method also includes identifying a protocol type from the header and the size. The method also includes identifying a signal characteristic of signal data in the body. The method also includes identifying a classification of a source sensor which generated the data packet based on the protocol type and the signal characteristic. The method also includes generating a metadata file based on the source sensor. The method also includes labeling the data packet with the metadata file to form a labeled data packet.

Systems and methods for financial settlement of transactions within an electric power grid network are disclosed. A multiplicity of active grid elements are constructed and configured for electric connection and network-based communication over a blockchain-based platform. The multiplicity of active grid elements are operable to make peer-to-peer transactions based on their participation within the electric power grid by generating and executing a digital contract. The multiplicity of active grid elements generate messages autonomously and/or automatically within a predetermined time interval. The messages comprise energy related data and settlement related data. The energy related data of the multiplicity of active grid elements are based on measurement and verification. The energy related data and the settlement related data are validated and recorded on a distributed ledger with a time stamp and a geodetic reference.

Systems and methods for financial settlement of transactions within an electric power grid network are disclosed. A multiplicity of active grid elements are constructed and configured for electric connection and network-based communication over a blockchain-based platform. The multiplicity of active grid elements are operable to make peer-to-peer transactions based on their participation within the electric power grid by generating and executing a digital contract. The multiplicity of active grid elements generate messages autonomously and/or automatically within a predetermined time interval. The messages comprise energy related data and settlement related data. The energy related data of the multiplicity of active grid elements are based on measurement and verification. The energy related data and the settlement related data are validated and recorded on a distributed ledger with a time stamp and a geodetic reference.

A system and method is provided for performing lossless switching in a redundant multicast network. An exemplary method includes receiving a primary media stream and a redundant media stream over different forwarding network paths by network ports of a receiver communicatively coupled to an A/V device. Furthermore, the receiver outputs media data of the media streams to the A/V device to be presented thereon. In response to a control signal to switch the receiver to a new primary media stream, the method disconnected either the primary ort the redundant media streams from the respective network port of the receiver receiving that stream. Furthermore, the method includes controlling the disconnected network port to receive the new primary media stream and then outputting media data of the new primary media stream to the A/V device to be presented thereon.

A system and method is provided for performing lossless switching in a redundant multicast network. An exemplary method includes receiving a primary media stream and a redundant media stream over different forwarding network paths by network ports of a receiver communicatively coupled to an A/V device. Furthermore, the receiver outputs media data of the media streams to the A/V device to be presented thereon. In response to a control signal to switch the receiver to a new primary media stream, the method disconnected either the primary ort the redundant media streams from the respective network port of the receiver receiving that stream. Furthermore, the method includes controlling the disconnected network port to receive the new primary media stream and then outputting media data of the new primary media stream to the A/V device to be presented thereon.

In order to allow for improvement on a case where data of a cellular network is transmitted and/or received through a wireless local area network (WLAN), a base station of the present invention includes: a first communication processing unit configured to add a header of a framing protocol to downlink data transmitted to a terminal apparatus; and a second communication processing unit configured to transmit the downlink data to which the header is added to a gateway that is used for transmission from the base station to the terminal apparatus through a wireless local area network. The framing protocol is a protocol for communication between the base station and the gateway and the header includes identification information corresponding to quality of service for the downlink data.

Systems and methods of network packet switching use a table representation of a trie data structure to identify a timestamp (TS) range (or time range) for a received packet based on the packet timestamp (TS). The trie data structure is programmed with a plurality of predetermined time ranges. Each node in the trie data structure corresponds to a TS prefix and is associated with a corresponding predetermined time range. A search engine in the network switch can use the packet TS as a key to traverse the trie data structure and thereby matching the packet TS to a predetermined time range according to a Longest Prefix Match (LPM) process. Provided with the TS ranges of the incoming packets, various applications and logic engines in the network switch can accordingly process the packets, such as determining a new destination IP address and performing channel switch accordingly.

Systems and methods of network packet switching use a table representation of a trie data structure to identify a timestamp (TS) range (or time range) for a received packet based on the packet timestamp (TS). The trie data structure is programmed with a plurality of predetermined time ranges. Each node in the trie data structure corresponds to a TS prefix and is associated with a corresponding predetermined time range. A search engine in the network switch can use the packet TS as a key to traverse the trie data structure and thereby matching the packet TS to a predetermined time range according to a Longest Prefix Match (LPM) process. Provided with the TS ranges of the incoming packets, various applications and logic engines in the network switch can accordingly process the packets, such as determining a new destination IP address and performing channel switch accordingly.

Some embodiments provide novel inline switches that distribute data messages from source compute nodes (SCNs) to different groups of destination service compute nodes (DSCNs). In some embodiments, the inline switches are deployed in the source compute nodes datapaths (e.g., egress datapath). The inline switches in some embodiments are service switches that (1) receive data messages from the SCNs, (2) identify service nodes in a service-node cluster for processing the data messages based on service policies that the switches implement, and (3) use tunnels to send the received data messages to their identified service nodes. Alternatively, or conjunctively, the inline service switches of some embodiments (1) identify service-nodes cluster for processing the data messages based on service policies that the switches implement, and (2) use tunnels to send the received data messages to the identified service-node clusters. The service-node clusters can perform the same service or can perform different services in some embodiments. This tunnel-based approach for distributing data messages to service nodes/clusters is advantageous for seamlessly implementing in a datacenter a cloud-based XaaS model (where XaaS stands for X as a service, and X stands for anything), in which any number of services are provided by service providers in the cloud.

Some embodiments provide novel inline switches that distribute data messages from source compute nodes (SCNs) to different groups of destination service compute nodes (DSCNs). In some embodiments, the inline switches are deployed in the source compute nodes datapaths (e.g., egress datapath). The inline switches in some embodiments are service switches that (1) receive data messages from the SCNs, (2) identify service nodes in a service-node cluster for processing the data messages based on service policies that the switches implement, and (3) use tunnels to send the received data messages to their identified service nodes. Alternatively, or conjunctively, the inline service switches of some embodiments (1) identify service-nodes cluster for processing the data messages based on service policies that the switches implement, and (2) use tunnels to send the received data messages to the identified service-node clusters. The service-node clusters can perform the same service or can perform different services in some embodiments. This tunnel-based approach for distributing data messages to service nodes/clusters is advantageous for seamlessly implementing in a datacenter a cloud-based XaaS model (where XaaS stands for X as a service, and X stands for anything), in which any number of services are provided by service providers in the cloud.