Добавление нескольких клиентов в TCP сервере winsock

#include "stdafx.h"
#include <iostream>
#include <string>
#include "WS2tcpip.h"
#include <stdio.h>
#include <time.h>
#include <fstream>
#pragma comment(lib, "ws2_32.lib")
#pragma warning(disable:4996)
using namespace std;
 
void main(){
    
 
    WSADATA wsData;
    WORD ver = MAKEWORD(2, 2);
    int wsOk = WSAStartup(ver, &wsData);
    if (wsOk != 0)
    {
        cerr << "Cant initialize winsock! Bye Bye" << endl;
        return;
    }
 
    SOCKET listening = socket(AF_INET, SOCK_STREAM, 0);
    if (listening == INVALID_SOCKET)
    {
        cerr << "Cant create a socket! Bye bye" << endl;
        return;
    }
 
    sockaddr_in hint;
    hint.sin_family = AF_INET;
    hint.sin_port = htons(54000);
    hint.sin_addr.S_un.S_addr = INADDR_ANY;
 
    bind(listening, (sockaddr*)&hint, sizeof(hint));
 
    listen(listening, SOMAXCONN);
 
    sockaddr_in client;
    int clientSize = sizeof(client);
 
    SOCKET clientSocket = accept(listening, (sockaddr*)&client, &clientSize);
    
        char host[NI_MAXHOST];
        char service[NI_MAXSERV];
 
 
        ZeroMemory(host, NI_MAXHOST);
        ZeroMemory(service, NI_MAXSERV);
 
        if (getnameinfo((sockaddr*)&client, sizeof(client), host, NI_MAXHOST, service, NI_MAXSERV, 0) == 0)
        {
            time_t tm = time(NULL);
            cout << host << " Connected on port " << service << " at " << ctime(&tm) << endl;
 
        }
        else
        {
            time_t tm = time(NULL);
            inet_ntop(AF_INET, &client.sin_addr, host, NI_MAXHOST);
            cout << host << "connected on port " << ntohs(client.sin_port) << " at " << ctime(&tm) << endl;
        }
    
        closesocket(listening);
 
        char buf[4096];
 
        while (true)
        {
            ZeroMemory(buf, 4096);
            int byteReceived = recv(clientSocket, buf, 4096, 0);
            if (byteReceived == SOCKET_ERROR)
            {
                cerr << "Error in recv(). Bye Bye" << endl;
                break;
            }
            if (byteReceived == 0)
            {
                time_t tm = time(NULL);
                cout << "Client " << host << " " << service << " disconnected" << " at " << ctime(&tm) << endl;
                break;
            }
            cout << string(buf, 0, byteReceived) << endl;
            send(clientSocket, buf, byteReceived + 1, 0);
        
        }
 
    closesocket(clientSocket);
    WSACleanup();
    system("pause");
}

inline
int SockVerify(int err)
{
    if (err == SOCKET_ERROR)
        std::cout << "ERROR: " << ::WSAGetLastError();
 
    return err;
}
 
void SimpleEchoServer(u_short port)
{
    char buf[1024];
    std::vector<WSAPOLLFD> fds;
    fds.push_back({::socket(AF_INET, SOCK_STREAM, 0), POLLIN, 0});
    
    sockaddr_in addr = {0};
    addr.sin_family = AF_INET;
    addr.sin_addr.s_addr = INADDR_ANY;
    addr.sin_port = htons(port);
    
    SockVerify(::bind(fds[0].fd, (const sockaddr *)&addr, sizeof(addr)));
    SockVerify(::listen(fds[0].fd, SOMAXCONN));
    std::cout << "Listen: " << port << std::endl;
    while (!_kbhit())
    {
        int res = SockVerify(::WSAPoll(fds.data(), ULONG(fds.size()), 100));
        if (res < 0)
            break;
 
        if (!res)
            continue;
 
        if (fds[0].revents == POLLRDNORM)
        {
            sockaddr_in addr = { 0 };
            socklen_t len = sizeof(addr);
            SOCKET sock = ::accept(fds[0].fd, (sockaddr *)&addr, &len);
            std::cout << "Accept" << std::endl;
            fds.push_back({sock, POLLIN, 0});
            --res;
        }
 
        for (size_t i = 1; res > 0 && i < fds.size(); )
        {
            if (fds[i].revents == 0)
            {
                ++i;
                continue;
            }
 
            if (fds[i].revents != POLLRDNORM)
            {
                std::cout << "Disconnect #" << i << std::endl;
                ::closesocket(fds[i].fd);
                fds.erase(fds.begin() + i);
            }
            else if (const auto n = SockVerify(recv(fds[i].fd, buf, int(std::size(buf)), 0)); n == 0)
            {
                std::cout << "Connection closed, #" << i << std::endl;
                ::closesocket(fds[i].fd);
                fds.erase(fds.begin() + i);
            }
            else
            {
                std::cout << "Recv #" << i << ": " << n << std::endl;
                SockVerify(::send(fds[i].fd, buf, n, 0));
                ++i;
            }
 
            --res;
        }
    }
 
    for (auto &item: fds)
        ::closesocket(item.fd);
}