Просто индексы передавай разные по твоему массиву, не?

Ну вот ща так и делаю

Но

Выглядит это кривовато

А где аллокации, от которых ты хочешь избавиться?

Просто индексы передавай разные по твоему массиву, не?

не - он хочет перетасовать байты в нужном порядке и "замапить" на int[]

не - он хочет перетасовать байты в нужном порядке и "замапить" на int[]

ого

Просто мне по-любому массив переворачивать

А я бы все инты прочитал как есть, а потом на них цикол натравил IPAddress.HostToNetwork

То на то и выйдет!

На чтении инта/лонга

Просто мне по-любому массив переворачивать

Э, не, тут аккуратнее

Смотри чо

Два подряд идущих шорта в LE это одно

А я бы все инты прочитал как есть, а потом на них цикол натравил IPAddress.HostToNetwork

Еще бы не забыть BitConverter.IsLittleEndian

А два шорта в BE, которые потом перевернули в LE — это другое

Вводную часть можно было и опустить, я в теме

Еще бы не забыть BitConverter.IsLittleEndian

IPAddress.HostToNetwork/NetworkToHost уже всё за тебя знают

Кое-на-каких системах они no-op, ясное дело.

В жаве у байтового буфера более удобный апи с этой точки зрения, кстати.

Ну вот у меня с той стороны скальный сервак

Ну мне же надо еще собирать сообщения из кусочков пришедших

Выглядит как кандидат в пайпы

Выглядит как кандидат в пайпы

На самом деле да. В каком они состоянии? Я знаю про превосходный апи, но какие у него есть реализации?

Выглядит как кандидат в пайпы

Обошелся MemoryStream с нужной capacity

Обошелся MemoryStream с нужной capacity

Ну это уже алокейшен

Из пайпов поюзал Pipelines.Sockets.Unofficial

Из пайпов поюзал Pipelines.Sockets.Unofficial

Вроде в 3 коре кестрел собирались на пайпы пересаживать

Вроде в 3 коре кестрел собирались на пайпы пересаживать

Интересно, что у них получилось, третий кор-то уже не за горами.

Ну и сходу не нашел, как мне на пайпах наговнякать условия разделения сообщений

Интересно, что у них получилось, третий кор-то уже не за горами.

А мб и не пересадили - я не смотрел

А мб и не пересадили - я не смотрел

Ну я тоже помню, что Дэвид собирался.

Т.е. есть пайп, куда валится всякое из канала

А дальше из него надо читать только готовые сообщения, т.е. длина+блоб

Ну и сходу не нашел, как мне на пайпах наговнякать условия разделения сообщений

https://devblogs.microsoft.com/dotnet/system-io-pipelines-high-performance-io-in-net/#user-content-tcp-server-with-systemiopipelines

Ну у меня пайпами уже из канала читаются куски данных

НО

Пайпы не помогают их склеить

В PipeReader поидее всё это должно происходить

Ну склейка

Предлагаешь своего написать?

Предлагаешь своего написать?

Нет же

Обёртку сделать поверх

Ну я так и сделал

Ну я так и сделал

Там сниппет довольно вменяемый

Т.е. они скипают обработку буфера до тех пор, пока /n не встретят

и набивают буфер

без лишних аллокаций

Ну у меня к сожалению, не /n

А чуть сложнее логика

Ну всё равно как-то сообщения же разделяются

Длина+блоб

И это может идти сплошным потоком

Например, получили первый месседж, прочитали длину и вычитываем буфер на длину, которая в начале пришла.

Потом этот буфер отдаём на обработку

И начинаем читать новый меседж

И как же нам вычитать буфер на нужную длину?

С учетом, что может еще придти кусок от следующего сообщения

С учетом, что может еще придти кусок от следующего сообщения

У тебя там udp что ли или как?

tcp

Но сообщения могут быть длинными

А ты просто читаешь первые сколько то байт, чтобы из первого сообщения длину запарсить.

Ye lf

А потом собираешь из сегментов буфер свой

Угу

Только вопрос

Пока длина не наберётся нужная

Вот есть набор сегментов

Как набрали, всё что дальше - считается новым сообщением

Что делать, когда сегмент надо разбить?

Что делать, когда сегмент надо разбить?

Slice

там же есть в примере всё

я бы считывал фреймы в ArrayPool и набивал бы на стеке массив референсов на эти массивы, потом как встречу разделитель сообщения, склеивал бы массивы в месаджи, освобождал кусочки массивов и начинал заново

Я просто смотрю на этот ебанутый ReadOnlySequence

И нихуя не понимаю

Увидел сочетание кастомный стол, стало интересн. Тем более если работаешь стоя

Функционально это обычный стол. Но сделан сермяжно, из нехипстерского железа, высотой 125+ см и увесистой столешницей 85+*175+.

Наверное, я старый

Я просто смотрю на этот ебанутый ReadOnlySequence

Ну дык тебе райтер в пайп последовательность из Memory<byte> пихает

Логично что он ридонли

Вернее мы у него берём этот Memory<byte>, пишем в него что то, а потом говорим сколько именно данных мы туда записали

Допустим