Коротких Виктор / ИТМО DWS / Stage 6 #211
Conversation
# Conflicts: # src/main/java/ru/vk/itmo/test/viktorkorotkikh/ConsistentHashingManager.java # src/main/java/ru/vk/itmo/test/viktorkorotkikh/LSMServerImpl.java # src/main/java/ru/vk/itmo/test/viktorkorotkikh/LSMServiceImpl.java # src/main/java/ru/vk/itmo/test/viktorkorotkikh/http/LSMConstantResponse.java
![codeclimate[bot]](https://avatars.githubusercontent.com/in/9403?s=60&v=4){kind=small}
src/main/java/ru/vk/itmo/test/viktorkorotkikh/LSMServerImpl.java
Outdated
Show resolved
Hide resolved
src/main/java/ru/vk/itmo/test/viktorkorotkikh/LSMServiceImpl.java
Outdated
Show resolved
Hide resolved
| this.lsmRangeWriter = lsmRangeWriter; | ||
| sendNextRangeChunks(); | ||
|
|
||
| if (this.lsmRangeWriter.hasChunks()) { |
There was a problem hiding this comment.
Нет ли здесь ошибки? У нас ещё есть неотправленные чанки, а мы переходим к обработке следующего входящего запроса...
There was a problem hiding this comment.
Да, это меня тоже смутило, когда я рефакторинг кода делал. Но отталкивался я от реализации метода sendResponse - там как раз идёт отправка ответа и переход к обработке следующего. Да, там ситуация другая с той точки зрения того, что мы по сути отправляем весь ответ сразу. Но нам могло не повезти и мы могли записать в сокет не весь ответ. Ну или же банально - у нас queueHead != null и мы наш Response добавили в очередь. Тогда по сути мы также пойдем дальше обрабатывать запросы.
Поэтому я тут сомневаюсь
There was a problem hiding this comment.
В существующей реализации sendResponse() мы ставим весь готовый Response в очередь на отправку в сокет, поэтому можем переходить к обработке следующего запроса, потому что его ответ уйдёт в сокет после предыдущего.
В случае streaming всё совсем не так.
src/main/java/ru/vk/itmo/test/viktorkorotkikh/reports/stage6/report.md
Outdated
Show resolved
Hide resolved
No description provided.