FastBinaryEncoding icon indicating copy to clipboard operation
FastBinaryEncoding copied to clipboard

Leak if sending data in a loop.

Open forlayo opened this issue 2 years ago • 2 comments

I am trying to check net capacity and I am doing:

    private async Task FakeDataSource()
    {
        await Task.Delay(500);
        Random rnd = new Random();
        var randomBytes = new byte[64000]; // 64k
        rnd.NextBytes(randomBytes);

        while (true)
        {
             var packet = new VideoPacket(1280, 720, new MemoryStream(randomBytes , 0, randomBytes .Length, false, true));
             _client.Send(packet);
        }
    }
  • _client is SimpleProtoClient as in the example.
  • VideoPacket is a message defined as
message VideoPacket
{
    uint16 width;
    uint16 height;
    bytes data;
}

Memory goes high in few seconds taking some Gb and then it crashes, I can see that an object of type Buffer has got all the RAM. As a weird note, If I add "await Task.Delay(1);" after the Send() it doesn't crash (but obviously is sending just a fraction of what's possible ).

What I am doing wrong ? How can I send as much as possible?

forlayo avatar Jan 19 '23 23:01 forlayo

You should limit a send buffer frame to some reasonable value (e.g. 10mb per client) and control in your code with BytesPending property or void OnSent(long sent, long pending) handler.

Also it is possible to generate and send a first portion of data, and wait until virtual void OnEmpty() handler it called and all the data was sent, then generate another portion.

chronoxor avatar Jan 20 '23 04:01 chronoxor

@forlayo can you put this line

var packet = new VideoPacket(1280, 720, new MemoryStream(randomBytes , 0, randomBytes .Length, false, true));

out of while loop? Your code generate garbage in a loop. There is no point to do this.

ceceomer avatar Feb 22 '24 01:02 ceceomer