<div dir="ltr"><div dir="ltr">On Linux and BSD, the recvmmsg would can read multiple packets at once. Adding it to gen_udp might be impractical, but the new socket module would be a good place for a function that uses that system call.</div><br><div class="gmail_quote"><div dir="ltr" class="gmail_attr">Am Mi., 7. Apr. 2021 um 13:19 Uhr schrieb Avinash Dhumane <<a href="mailto:trigunatit@gmail.com">trigunatit@gmail.com</a>>:<br></div><blockquote class="gmail_quote" style="margin:0px 0px 0px 0.8ex;border-left:1px solid rgb(204,204,204);padding-left:1ex"><div lang="EN-IN" style="overflow-wrap: break-word;"><div class="gmail-m_1374343363828340702WordSection1"><p class="MsoNormal"><span class="gmail-m_1374343363828340702DefaultFontHxMailStyle"><span style="font-size:12pt">Our case is similar. The stock exchange disseminates the market movements (called, ticks) as stream of variable length messages (datagrams or packets), each less than 50 bytes, and each stamped with sequence number, over multicast (udp) streams, each stream replicated so that if a packet is missed (dropped) – due to the nature of underlying udp – it may be received on the replicated stream (before fallback on a tcp-based recovery server).<u></u><u></u></span></span></p><p class="MsoNormal"><span class="gmail-m_1374343363828340702DefaultFontHxMailStyle"><span style="font-size:12pt"><u></u> <u></u></span></span></p><p class="MsoNormal"><span class="gmail-m_1374343363828340702DefaultFontHxMailStyle"><span style="font-size:12pt">The message rate (without replication) exceeds 100K per second. Issuing as many calls, at Erlang-application level, viz. gen_udp:recv, is impractical, though I suppose, at underlying OS system-call level, each datagram must be received using a separate call. Therefore, I believed, that Erlang might provide an abstraction, which packs a number of datagrams (packets / messages) arrived so far and deliver to the application, for further handling. One-to-one call from app to Erlang, and further from Erlang to OS, for each datagram, would seem too much taxing.<u></u><u></u></span></span></p><p class="MsoNormal"><span class="gmail-m_1374343363828340702DefaultFontHxMailStyle"><span style="font-size:14pt"><u></u> <u></u></span></span></p><p class="MsoNormal"><span class="gmail-m_1374343363828340702DefaultFontHxMailStyle"><span style="font-size:14pt"><u></u> <u></u></span></span></p><div style="border-right:none;border-bottom:none;border-left:none;border-top:1pt solid rgb(225,225,225);padding:3pt 0cm 0cm"><p class="MsoNormal" style="border:none;padding:0cm"><b>From: </b><a href="mailto:max.lapshin@gmail.com" target="_blank">Max Lapshin</a><br><b>Sent: </b>06 April 2021 10:20 PM<br><b>To: </b><a href="mailto:lukasz@niemier.pl" target="_blank">Łukasz Niemier</a><br><b>Cc: </b><a href="mailto:erlang-questions@erlang.org" target="_blank">Erlang Questions</a><br><b>Subject: </b>Re: gen_udp:recv()</p></div><p class="MsoNormal"><span class="gmail-m_1374343363828340702DefaultFontHxMailStyle"><span style="font-size:14pt"><u></u> <u></u></span></span></p><p class="MsoNormal">Exactly.</p><p class="MsoNormal"><u></u> <u></u></p><p class="MsoNormal">We receive MPEG-TS _stream_ in multicast messages and it is very</p><p class="MsoNormal">painful to receive so many messages (it can be around 90K per second</p><p class="MsoNormal">totally or 300-900 per one stream per second) one by one. Reducing</p><p class="MsoNormal">this about by 10 decreases CPU usage a lot.</p><p class="MsoNormal"><u></u> <u></u></p><p class="MsoNormal"><u></u> <u></u></p><p class="MsoNormal"><u></u> <u></u></p><p class="MsoNormal"><u></u> <u></u></p><p class="MsoNormal">On Tue, Apr 6, 2021 at 6:31 PM Łukasz Niemier <<a href="mailto:lukasz@niemier.pl" target="_blank">lukasz@niemier.pl</a>> wrote:</p><p class="MsoNormal">><u></u> <u></u></p><p class="MsoNormal">> > Well, I like the idea to receive 20-200 UDP messages in a single</p><p class="MsoNormal">> > binary with separate structure holding mapping of this data.</p><p class="MsoNormal">><u></u> <u></u></p><p class="MsoNormal">> Then it sounds like you want stream protocol instead of packet protocol.</p><p class="MsoNormal">> The whole idea of packet protocol is to receive messages in packets.</p><p class="MsoNormal">><u></u> <u></u></p><p class="MsoNormal">> --</p><p class="MsoNormal">><u></u> <u></u></p><p class="MsoNormal">> Łukasz Niemier</p><p class="MsoNormal">> <a href="mailto:lukasz@niemier.pl" target="_blank">lukasz@niemier.pl</a></p><p class="MsoNormal">><u></u> <u></u></p><p class="MsoNormal"><span class="gmail-m_1374343363828340702DefaultFontHxMailStyle"><span style="font-size:14pt"><u></u> <u></u></span></span></p></div></div>
</blockquote></div><br clear="all"><div><br></div>-- <br><div dir="ltr" class="gmail_signature"><p><span style="font-family:verdana,geneva,sans-serif;font-size:10pt">Andreas Schultz<br></span></p>
</div></div>