Khadyrov Almasgali, ITMO CT, M33351, Stage6 #210
Conversation
![codeclimate[bot]](https://avatars.githubusercontent.com/in/9403?s=60&v=4){kind=small}
| @@ -42,22 +42,25 @@ public class DaoServer extends HttpServer { | |||
| private static final String HEADER_REMOTE_ONE_NIO_HEADER = HEADER_REMOTE + ": da"; | |||
| private static final String HEADER_TIMESTAMP = "X-flag-remote-reference-server-to-node-by-paschenko2"; | |||
| private static final String HEADER_TIMESTAMP_ONE_NIO_HEADER = HEADER_TIMESTAMP + ": "; | |||
| private static final byte[] CHUNK_HEADERS = | |||
| "HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\nTransfer-Encoding: chunked\r\nConnection: keep-alive\r\n\r\n" | |||
There was a problem hiding this comment.
Line is longer than 120 characters (found 121).
| } | ||
| writeFull(session, CHUNK_HEADERS); | ||
| while (iterator.hasNext()) { | ||
| writeChunk(session, iterator.next()); |
There was a problem hiding this comment.
Получается много записей в сокет (writeFull) с небольшими значениями (отдельно на ключ, значения, сепараторы).
Будет эффективнее строить один блок, возможно из нескольких пар ключ-значение, чтобы делать меньше операций записи в сокет.
| } | ||
|
|
||
| private void writeFull(HttpSession session, byte[] data) throws IOException { | ||
| session.write(data, 0, data.length); |
There was a problem hiding this comment.
write возвращает некоторый int - число байт, которые удалось записать.
Хотелось бы обработать также случай, когда не все данные успешно записаны. Ведь в таком случае клиент не сможет распарсить цельный ответ, так как он получит кусок чанка, который вполне может оборваться посреди байтов ключа или значения.
There was a problem hiding this comment.
upd: что-то я не туда посмотрел, там ArrayQueueItem пишется, это будет гарантировать доставку всех данных, но если клиент медленный, то эти ArrayQueueItem будут копиться и выжрут всю оперативную память. Надо было написать чуть аккуратнее, чтобы данные вычитывались из итератора по мере записи в клиентский сокет.
No description provided.