Systems and methods for random differential relay and network coding
A method of propagating data packets in a network of nodes is disclosed. The method, implemented at one of the nodes, includes: collecting a set of first data packets during a first time period, the set including at least one data packet received from one or more first nodes in the network; obtaining a plurality of encoded data packets, each one of the plurality of encoded data packets being generated by combining two or more first data packets of the set using network coding; determining a mapping of the plurality of encoded data packets and the first data packets of the set to one or more neighbouring nodes connected to the node; and transmitting the plurality of encoded data packets and the first data packets of the set to the one or more neighbouring nodes according to the determined mapping.
1. A blockchain network node for distributing a data packet in a blockchain network according to a data relay protocol, the blockchain network node arranged to:
in a first mode, propagate the data packet according to a random differential relay, RDR, protocol comprising relaying the data packet to a randomly selected subset of one or more neighbouring nodes of the blockchain network node; and
in a second mode, propagate the data packet according to a standard diffusion model comprising relaying the data packet to every neighbouring node of the blockchain network node,
wherein propagation of the data packet for the blockchain network node participating in a diffusion mixer protocol is independently selected from the first mode or the second mode.
2. The blockchain network node of claim 1 , wherein the blockchain network node in the first mode is further arranged to:
generate or receive the first data packet at a time t 1 ;
receive at least a second data packet at a time t 2 from a neighbouring node; and
initiate broadcasting of the received first and second data packets at a time t 3 .
3. The blockchain network node of claim 1 , further arranged to:
collect first data packets over a particular time period; and
use network coding to combine two or more of the collected first data packets to generate encoded data packets for relaying to the neighbouring nodes.
4. The blockchain network node of claim 3 , wherein in the first mode, the particular time period has a predefined length.
5. The blockchain network node of claim 3 , wherein the blockchain network node is prevented from transmitting any data packets during the particular time period.
6. The blockchain network node of claim 1 , wherein the data packets are blockchain transactions.
7. The blockchain network node of claim 1 , further arranged to build a routing data structure comprising an RDR table that defines a data packet allocation scheme.
8. The blockchain network node of claim 7 , wherein the RDR table keeps track of all data packets received or generated in a given amount of time, ΔTRDR, as well as one or more source peers of the data packets.
9. The blockchain network node of claim 7 , wherein the RDR table includes additional information, comprising:
time of arrival of a first instance of a data packet (ToA timestamp);
times chosen for relaying a data packet (ToR timestamp); and/or
a counter of a number of instances of a same data packet received by the blockchain network node.
10. The blockchain network node of claim 1 , further arranged to schedule a delay to transmission of the data packet.
11. The blockchain network node of claim 1 , wherein the blockchain network node joins the diffusion mixer protocol via a decentralized manner or through inclusion in a group of participating nodes assembled by a central authority.
12. A computer-implemented method of propagating a data packet by a blockchain network node, the blockchain network node having one or more neighbouring nodes, the method comprising:
in a first mode, propagating the data packet according to a random differential relay, RDR, protocol comprising relaying the data packet to a randomly selected subset of the one or more neighbouring nodes of the blockchain network node; and
in a second mode, propagating the data packet according to a standard diffusion model comprising relaying the data packet to every neighbouring node of the blockchain network node,
wherein propagation of the data packet for the blockchain network node participating in a diffusion mixer protocol is independently selected from the first mode or the second mode.
13. The computer-implemented method of claim 12 , further comprising:
generating or receiving the first data packet at a time t 1 ;
receiving at least a second data packet at a time t 2 from a neighbouring node; and
initiating broadcasting of the received first and second data packets at a time t 3 .
14. The computer-implemented method of claim 12 , further comprising:
collecting further data packets over a particular time period; and
using network coding to combine two or more of the collected data packets to generate encoded data packets for relaying to the neighbouring nodes.
15. The computer-implemented method of claim 14 , further comprising preventing the blockchain network node from transmitting any data packets during the particular time period.
16. The computer-implemented method of claim 12 , further comprising building a routing data structure comprising an RDR table that defines a data packet allocation scheme, wherein the RDR table keeps track of all the data packets received or generated in a given amount of time, ΔTRDR, as well as a source of the data packets.
17. The computer-implemented method of claim 16 , wherein building the RDR table includes adding information, comprising:
time of arrival of a first instance of a data packet (ToA timestamp);
times chosen for relaying a data packet (ToR timestamp); and/or
a counter of a number of instances of a same data packet received by the blockchain network node.
18. The computer-implemented method of claim 12 , further comprising scheduling delays to transmission of data packets.
19. The computer-implemented method of claim 12 , further comprising the network node joining the diffusion mixer protocol via a decentralized manner or through inclusion in a group of participating nodes assembled by a central authority.
20. A non-transitory processor-readable medium storing processor-executable instructions to participate in a process for propagating data packets in a blockchain network node, wherein the processor-executable instructions, when executed by a processor in the blockchain network node, causes the processor to carry out the method of claim 12 .