Задержка в recv()

Скажем, я пытаюсь отправить вам 8 тыкв. Я положил 6 из них на стол. Вы думаете: «Я жду 8 тыкв, а не 6. Подожду, пока он положит на стол последние две». Я думаю: «Я не хочу слишком много тыкв «в полете» сразу. Я подожду, пока он возьмет 2 из этих 6, прежде чем я положу последние 2 на стол». Застряли. Мы ждем друг друга. Мы будем ждать вечно.

Вам не разрешено ждать, пока будут получены дополнительные байты, прежде чем принять уже полученные байты. Причина этого проста: ни один сетевой протокол не может позволить каждой стороне ждать другую. Поскольку TCP позволяет отправляющей стороне ожидать в этом контексте, он не может позволить также ждать принимающей стороне.

Поэтому принимайте байты по мере их получения. Не ждите, пока другая сторона отправит их все, прежде чем принимать какие-либо из них. В противном случае, что произойдет, если другая сторона будет ждать, пока вы примете первый, прежде чем отправить еще?

Вы, вероятно, достигли предела буфера ядра. Вы, вероятно, можете увеличить SO_RCVBUF на приемнике, и он будет работать так, как вы ожидаете: SIOCINQ в конечном итоге вернет полный размер непрочитанных данных.

Но вы не должны этого делать, чтобы обеспечить правильное функционирование. возиться с буферами следует только тогда, когда вы хотите настроить производительность.

Вы должны реструктурировать код, чтобы вам никогда не приходилось спрашивать ядро, сколько байтов доступно. Просто прочитайте до разумного предела (например, 4096) и обработайте одно сообщение уровня приложения, разбитое на несколько частей. Если вам нужны длины/границы сообщений, вы ДОЛЖНЫ реализовать их самостоятельно поверх TCP.

Вот какой-то глупый код для чтения сообщения с длинным заголовком:

int ret, len = 0, have_read;
have_read = 0;
while (have_read < sizeof(len)) {
    // This will likely always return sizeof(len) the first time.
    ret = read(fd, ((char*)&len) + have_read, sizeof(len) - have_read);
    if (ret <= 0) {
        // Handle error.
    }
    have_read += ret;
}
char* buf = malloc(len);
if (!buf) {
    // Handle error.
}
have_read = 0;
while (have_read < len) {
    ret = read(fd, buf + have_read, len - have_read);
    if (ret <= 0) {
        // Handle error.
    }
    have_read += ret;
}
// Handle message in buf.