Эхо-сервер

#include <vector>
#include <sys/types.h>
#include <sys/socket.h>
#include <sys/poll.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <unistd.h>
#include <string.h>
#include <system_error>
 
#define CHECK(func) \
    if ((func) == -1) \
    { \
        throw std::system_error(errno, std::generic_category()); \
    }
 
int BUF_SIZE =  100;
 
int main (int argc, char *argv[])
{
    int server_fd = socket(AF_INET, SOCK_STREAM|SOCK_NONBLOCK, 0);
 
    union { sockaddr_in sain; sockaddr sa; } addr{}; // инициализация нулями
    addr.sain.sin_family = AF_INET; // IPv4
    addr.sain.sin_port = htons(22222);
    addr.sain.sin_addr.s_addr = htonl(INADDR_LOOPBACK); // 127.0.0.1 
    // или inet_aton("127.0.0.1", &addr.sin_addr.s_addr);
 
    bind(server_fd, &addr.sa, sizeof(addr)); // присвоить адрес (имя) сокету
    listen(server_fd, SOMAXCONN);  // ожидать соединений
    std::vector<pollfd> fds{{server_fd,POLLIN}}; // добавить сервер
 
    poll(fds.data(), fds.size(), -1); // опросить дескрипторы
    
    std::vector<char []> buffs; // данные
    std::vector<int> is_send;  // все отправили, что было получено, или нет 
    std::vector<int> size_remaining_data; // сколько осталось отправить, если не все отправилось
 
    for (size_t i = 0; i < fds.size(); ++i) 
    {
        const pollfd& f = fds[i];
 
        if (f.revents == 0) { continue; }
 
        if (f.fd == server_fd) 
        { // прием новых соединений
            int client_fd = accept4(server_fd, 0, 0, SOCK_NONBLOCK);
            fds.push_back({client_fd, POLLIN|POLLOUT}); // добавить клиента
            char buff[BUF_SIZE];
            buffs.push_back(buff);
            is_send.push_back(1);
            size_remaining_data.push_back(0);
 
        } 
        else // чтение/запись в существующие соединения
 
        {   
            int valread;
            int valsend;
            if (is_send[i]) // все предыдущее отправлено 
            {
                CHECK(valread = recv(f.fd, buffs[i], BUF_SIZE, 0));
                CHECK(valsend = send(f.fd, buffs[i], BUF_SIZE, 0));
 
                if (valsend != BUF_SIZE) // не все отправилось
                {
                    is_send[i] = 0;
                    size_remaining_data[i] = BUF_SIZE - valsend;
                }
                else // все отправилось
                {
                    is_send[i] = 1;
                }
            }
            else // что-то не смогли отправить в прошлый раз
            {
                char new_buff[size_remaining_data[i]];
                memcpy(new_buff,buffs[i] + (BUF_SIZE - size_remaining_data[i]), size_remaining_data[i]); // копируем те данные, которые надо отправить
                CHECK(valsend = send(f.fd, new_buff, size_remaining_data[i], 0));
 
                if (valsend != size_remaining_data[i]) // если и в этот раз не все отправилось
                {
                    is_send[i] = 0;
                    size_remaining_data[i] = size_remaining_data[i] - valsend;
                }
                else // все остатки отправили 
                {
                    is_send[i] = 1;
                }
            }           
        } 
    }
}