Peernet-Archive/core
1
0
Fork 0
mirror of https://github.com/PeernetOfficial/core.git synced 2026-07-17 02:47:51 +01:00
Code Issues Packages Projects Releases Wiki Activity

UDT: Fix critical bug in multiplexer.goWrite. It was overwriting packets on the fly. A new buffer is needed for each outgoing packet.

Browse Source
This commit is contained in:
Kleissner
2021-10-25 07:56:35 +02:00
parent a8592e9975
commit 1ec20e6386
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
udt/multiplexer.go
View File

@@ -117,8 +117,8 @@ func (m *multiplexer) goRead() {
// write runs in a goroutine and writes packets to conn using a buffer from the writeBufferPool, or a new buffer. // write runs in a goroutine and writes packets to conn using a buffer from the writeBufferPool, or a new buffer.
func (m *multiplexer) goWrite() { func (m *multiplexer) goWrite() {
buf := make([]byte, m.maxPacketSize)
for pkt := range m.pktOut { for pkt := range m.pktOut {
buf := make([]byte, m.maxPacketSize)
plen, err := pkt.WriteTo(buf) // encode plen, err := pkt.WriteTo(buf) // encode
if err != nil { if err != nil {
// TODO: handle write error // TODO: handle write error