Streaming communication between devices
In accordance with implementations of the subject matter described herein, there is provided a solution for streaming communication between devices. In this solution, a memory of a first device comprising a ring buffer is allocated to be dedicated for storing a data stream of an application to be transmitted to a second electronic device. The application of the first device writes data to be transmitted into the ring buffer, to form a portion of the first data stream, and a write pointer of the ring buffer is thus updated. A portion of data is read based on a source memory address from the ring buffer via the interface device. The interface device also transmits the data portion to a second device. The read data portion is stored in a dedicated ring buffer of the memory. In accordance with the solution, an efficient streaming communication interface is provided between devices.
1. An interface device comprising:
a physical interface connected to a first device comprising a first memory, the first memory comprising a first ring buffer allocated to be dedicated for storing a first data stream of an application to be transmitted to a second device; and
control logic configured to:
in response to detection of a command from the first device, read, based on a source memory address indicated by the command, a first data portion of the first data stream from the first ring buffer via the physical interface;
transmit, based on a destination memory address indicated by the command, the first data portion to the second device via the physical interface; and
receive, via a network, a second packet to confirm that the first data portion is stored, the second packet comprising a second header, and the second header at least indicating that the first data portion is confirmed to be stored to the destination memory address, wherein the second packet is received from a further interface device coupled to the physical interface, the further interface device comprising a second physical interface connected with the second device, wherein the network is used to establish a connection between the first device and the second device.
2. The interface device of claim 1 , wherein the control logic is configured to:
encapsulate the first data portion and a first header into a first packet for data transmission, the first header at least indicating the destination memory address; and
transmit the first packet to the further interface device via the network.
3. The interface device of claim 2 , wherein the second header is extracted from the first header by the further interface device to be comprised in the second packet.
4. The interface device of claim 2 , wherein the second device comprises a second ring buffer allocated to be dedicated for storing the first data stream received from the first device, the first memory storing a write pointer of the second ring buffer to a data-writable memory address in the second ring buffer; and
wherein the control logic is further configured to cause, in response to the second packet, the first device to update the write pointer of the second ring buffer to point to a new data-writable memory address in the second ring buffer.
5. The interface device of claim 4 , wherein the control logic is further configured to:
transmit a third packet comprising a third header to the further interface device via the network, the third packet indicating that the further interface device transmits an interrupt request to an application of the second device, the third header at least indicating an interrupt address of the second ring buffer to be used by the application of the second device.
6. The interface device of claim 4 , wherein the first memory stores a read pointer of the second ring buffer to a data-readable memory address in the second ring buffer; and
wherein the control logic is further configured to:
receive, from the further interface device and via the network, a fourth packet comprising a fourth header and notifying an update of the read pointer of the second ring buffer, the update being triggered by reading data from the second ring buffer by an application of the second device, and the fourth header indicating a memory address pointed to by the updated read pointer.
7. A method implemented at an interface device, comprising:
detecting a command from a first device with a first memory, the first memory comprising a first ring buffer allocated to be dedicated for storing a first data stream of an application to be transmitted to a second device;
in response to detection of the command, reading, based on a source memory address indicated by the command, a first data portion of the first data stream from the first ring buffer via a physical interface of the interface device;
transmitting, based on a destination memory address indicated by the command, the first data portion to the second device via the physical interface; and
receiving, via a network, a second packet to confirm that the first data portion is stored, the second packet comprising a second header, and the second header at least indicating that the first data portion is confirmed to be stored to the destination memory address, wherein the second packet is received from a further interface device coupled to the physical interface, the further interface device comprising a second physical interface connected with the second device, wherein the network used to establish a connection between the first device and the second device.
8. The method of claim 7 , wherein transmitting the first data portion to the second device comprises:
encapsulating the first data portion and a first header into a first packet for data transmission, the first header at least indicating the destination memory address; and
transmitting the first packet to the further interface device via the network.
9. The method of claim 8 , wherein the second header is extracted from the first header by the further interface device to be comprised in the second packet.
10. The method of claim 7 , wherein the second device comprises a second ring buffer allocated to be dedicated for storing the first data stream received from the first device, the first memory storing a write pointer of the second ring buffer to a data-writable memory address in the second ring buffer and the method further comprising:
in response to the second packet, updating, by the first device, the write pointer of the second ring buffer to point to a new data-writable memory address in the second ring buffer.
11. The method of claim 10 , further comprising:
transmitting a third packet comprising a third header to the further interface device via the network, the third packet indicating that the further interface device transmits an interrupt request to an application of the second device, the third header at least indicating an interrupt address of the second ring buffer to be used by the application of the second device.
12. The method of claim 10 , wherein the first memory stores a read pointer of the second ring buffer to a data-readable memory address in the second ring buffer and the method further comprising:
receiving, from the further interface device and via the network, a fourth packet comprising a fourth header and notifying an update of the read pointer of the second ring buffer, the update being triggered by reading data from the second ring buffer by an application of the second device, and the fourth header indicating a memory address pointed to by the updated read pointer.
13. The method of claim 7 , wherein a third ring buffer is allocated to be dedicated for storing a second data stream for the application received from the further interface device and the method further comprising:
in response to a third data portion of the second data stream being directly written by the interface device into the third ring buffer, modifying a write pointer of the third ring buffer stored in the first memory to point to a data-writable memory address in the third ring buffer.
14. At least one non-transitory machine-readable medium comprising instructions that, when executed by at least one processor, cause the at least one processor to perform operations to:
detect a command from a first device with a first memory, the first memory comprising a first ring buffer allocated to be dedicated for storing a first data stream of an application to be transmitted to a second device;
in response to detection of the command, read, based on a source memory address indicated by the command, a first data portion of the first data stream from the first ring buffer via a physical interface of an interface device;
transmit, based on a destination memory address indicated by the command, the first data portion to the second device via the physical interface; and
receive, via a network, a second packet to confirm that the first data portion is stored, the second packet comprising a second header, and the second header at least indicating that the first data portion is confirmed to be stored to the destination memory address, wherein the second packet is received from a further interface device coupled to the physical interface, the further interface device comprising a second physical interface connected with the second device, wherein the network used to establish a connection between the first device and the second device.
15. The at least one non-transitory machine-readable medium of claim 14 , wherein the instructions to transmit the first data portion to the second device comprises instructions to:
encapsulate the first data portion and a first header into a first packet for data transmission, the first header at least indicating the destination memory address; and
transmit the first packet to the further interface device via the network.
16. The at least one non-transitory machine-readable medium of claim 15 , wherein the second header is extracted from the first header by the further interface device to be comprised in the second packet.
17. The at least one non-transitory machine-readable medium of claim 14 , wherein the second device comprises a second ring buffer allocated to be dedicated for storing the first data stream received from the first device, the first memory storing a write pointer of the second ring buffer to a data-writable memory address in the second ring buffer and the instructions further comprising instructions to:
in response to the second packet, update, by the first device, the write pointer of the second ring buffer to point to a new data-writable memory address in the second ring buffer.
18. The at least one non-transitory machine-readable medium of claim 17 , further comprising instructions to:
transmit a third packet comprising a third header to the further interface device via the network, the third packet indicating that the further interface device transmits an interrupt request to an application of the second device, the third header at least indicating an interrupt address of the second ring buffer to be used by the application of the second device.
19. The at least one non-transitory machine-readable medium of claim 17 , wherein the first memory stores a read pointer of the second ring buffer to a data-readable memory address in the second ring buffer and the at least one non-transitory machine-readable medium further comprising instructions to:
receive, from the further interface device and via the network, a fourth packet comprising a fourth header and notifying an update of the read pointer of the second ring buffer, the update being triggered by reading data from the second ring buffer by an application of the second device, and the fourth header indicating a memory address pointed to by the updated read pointer.
20. The at least one non-transitory machine-readable medium of claim 14 , wherein a third ring buffer is allocated to be dedicated for storing a second data stream for the application received from the further interface device and further comprising instructions to:
in response to a third data portion of the second data stream being directly written by the interface device into the third ring buffer, modify a write pointer of the third ring buffer stored in memory to point to a data-writable memory address in the third ring buffer.