Плясов Климентий, ИТМО DWS, stage 6 #228
Conversation
# Conflicts: # src/main/java/ru/vk/itmo/test/klimplyasov/PlyasovServer.java # src/main/java/ru/vk/itmo/test/klimplyasov/PlyasovService.java # src/main/java/ru/vk/itmo/test/klimplyasov/Server.java
|
PR открыт после soft deadline, поэтому максимум 5 баллов. |
![codeclimate[bot]](https://avatars.githubusercontent.com/in/9403?s=60&v=4){kind=small}
| if ("/v0/entities".equals(path)) { | ||
| handleEntitiesRequest(request, session); | ||
| } else { | ||
| handleOtherRequest(request, session); |
| while (iterator.hasNext()) { | ||
| ChunkGenerator.writeDataChunk(session, iterator.next()); | ||
| } |
There was a problem hiding this comment.
В случае медленного клиента мы затянем все данные в память и упадём по OOM, верно? Вся суть задания в том, чтобы этого избежать. Будете переделывать?
There was a problem hiding this comment.
Немного не пониманию, я же отправляю в сессию данные, ничего не оставляя в памяти. Подскажите, пожалуйста, что не так?
There was a problem hiding this comment.
Данные не отправляются сразу, с ставятся в очередь на отправку -- см. Session.write(). Но в очередь добавляется всё содержимое Iterator, т.е. никакого streaming нет.
| ### one/nio/net/Session.write | ||
| занимает 46% всей выделенной памяти. Внутри этого метода распределение памяти выглядит следующим образом: | ||
|
|
||
| - writeDataChunk - 70% |
There was a problem hiding this comment.
Откуда на профиле аллокаций Class.getSimpleName() с почти 20%?
There was a problem hiding this comment.
private <Z> Z toArray(Class<Z> arrayClass, ValueLayout elemLayout, IntFunction<Z> arrayFactory, Function<Z, MemorySegment> segmentFactory) {
int size = checkArraySize(arrayClass.getSimpleName(), (int)elemLayout.byteSize());
Z arr = arrayFactory.apply(size);
MemorySegment arrSegment = segmentFactory.apply(arr);
MemorySegment.copy(this, elemLayout, 0, arrSegment, elemLayout.withOrder(ByteOrder.nativeOrder()), 0, size);
return arr;
}
когда мы вызываем toArray в MemorySegment, он вызывает этот метод, чтобы проверить размер массива
| ### one/nio/net/Session.write | ||
| занимает 46% всей выделенной памяти. Внутри этого метода распределение памяти выглядит следующим образом: | ||
|
|
||
| - writeDataChunk - 70% |
There was a problem hiding this comment.
Откуда аллокация HeapByteBuffer? Можно её избежать?
There was a problem hiding this comment.
Насколько я понимаю он начинает использоваться в SocketChannel.write, где на вход идет bytebuffer и там где-то внутри обрабатывается.
|
@incubos Не буду. К сожалению, мне уже не хватает баллов до 50( |
|
Тогда 1 балл за попытку :( |
No description provided.