Реализация отправки сообщения всем клиентам (TCP Socket)

#include <iostream>
#include <winsock2.h>
#pragma comment(lib, "wsock32.lib")
 
using namespace std;
 
int nclients = 0;
char* cbuff= "common buffer";
#define sHello "-------------------------------------Hello--------------------------------------"
#define PRINTNUSERS if (nclients)\
  printf("%d user on-line\n",nclients);\
  else printf("No User on line\n");
 
DWORD WINAPI WorkWithClient(LPVOID client_socket);
 
int main() 
{
    printf("                             TCP Server\n\n\n");
    
    char buff[1024];
    int client_number = 0;
    char response[1024] = {0};
 
    WSADATA ws;
    if(FAILED(WSAStartup(MAKEWORD(1, 1), &ws))) 
    {
        cout << "[WSAStartup]: ERROR #" << WSAGetLastError() << endl;
    } else {
        cout << "[WSAStartup]: SPI - Success" << endl;
    }
 
    SOCKET s;
    if(INVALID_SOCKET == (s = socket(AF_INET, SOCK_STREAM, 0)))
    {
        cout << "[Socket]: ERROR #" << WSAGetLastError() << endl;
    } else {
        cout << "[Socket]: SPI - Success" << endl;
    }
 
    sockaddr_in adr;
    adr.sin_addr.s_addr = inet_addr("127.0.0.1");
    adr.sin_port = htons(666);
    adr.sin_family = AF_INET;
 
    if(bind(s,(sockaddr *)&adr,sizeof(adr)) == SOCKET_ERROR) 
    {
        cout << "[BIND]: ERROR #" << WSAGetLastError() << endl;
    } else {
        cout << "[BIND]: SPI - Success" << endl;
    }
 
    if(listen(s,0x3) == SOCKET_ERROR) 
    {
        cout << "[LISTEN]: ERROR #" << WSAGetLastError() << endl;
    } else {
        cout << "[LISTEN]: SPI - Success" << endl;
    }
 
    printf("\nWaiting connection...\n");
 
    SOCKET client_socket; 
    sockaddr_in client_addr;  
 
    int client_addr_size=sizeof(client_addr);
 
    while((client_socket = accept(s, (sockaddr *)&client_addr, &client_addr_size)))
    {
        nclients++;    
 
        HOSTENT *hst;
        hst = gethostbyaddr((char *)&client_addr.sin_addr.s_addr, 4, AF_INET);
 
        printf("+%s [%s] new connect!\n", (hst)?hst->h_name:"", inet_ntoa(client_addr.sin_addr));
        PRINTNUSERS
 
        DWORD thID;
        CreateThread(NULL, NULL, WorkWithClient, &client_socket, NULL, &thID);
    }
 
    closesocket(s); 
    WSACleanup();
    system("PAUSE");
    return 1;
}
 
DWORD WINAPI WorkWithClient(LPVOID client_socket)
{
    SOCKET my_sock;
    my_sock = ((SOCKET *) client_socket)[0];
    char buff[1024] = "123124";
    #define sHELLO "Hello, new member! This's our win socket chat!))\r\n"
    send(my_sock, sHELLO, sizeof(sHELLO), 0);
 
    int bytes_recv;
    // возвращение ее клиенту
    // while ( (bytes_recv=recv(my_sock,&buff[0],sizeof(buff),0)) && (bytes_recv !=SOCKET_ERROR))
    while (1)
    {
        bytes_recv = recv(my_sock,buff,sizeof(buff),0);
        cbuff = buff; // пишем в глобальную переменную чтобы другие участники
        // узнали о сообщении
        send(my_sock,&buff[0],bytes_recv,0);
    
        cout << buff << endl; // печатает сообщения всех клиентов в консоли сервера
    }
 
    nclients--; // уменьшаем счетчик активных клиентов
    printf("-disconnect\n"); PRINTNUSERS
 
    // закрываем сокет
    closesocket(my_sock);
    return 0;
}

#include <iostream>
#include <winsock2.h>
#pragma comment(lib, "wsock32.lib")
 
using namespace std;
 
int main() 
{
    printf("                             TCP Client\n\n\n");
 
    char response[1024] = {0};
    char buff[1024];
    WSADATA ws;
    if(FAILED(WSAStartup(MAKEWORD(1, 1), &ws))) 
    {
        cout << "[WSAStartup]: ERROR #" << WSAGetLastError() << endl;
    } else {
        cout << "[WSAStartup]: SPI - Success" << endl;
    }
 
    SOCKET s;
    if(INVALID_SOCKET == (s = socket(AF_INET, SOCK_STREAM, 0)))
    {
        cout << "[Socket]: ERROR #" << WSAGetLastError() << endl;
    } else {
        cout << "[Socket]: SPI - Success" << endl;
    }
 
    sockaddr_in adr;
    adr.sin_family = AF_INET;
    adr.sin_addr.S_un.S_addr = inet_addr("127.0.0.1"); 
    adr.sin_port = htons(666);
 
    if(SOCKET_ERROR == (connect(s, (sockaddr *) &adr, sizeof(adr))))
    {
        cout << "[Connect]: ERROR #" << WSAGetLastError() << endl;
    } else {
        cout << "[Connect]: SPI - Success" << endl;
    }
 
    int nsize;
    while((nsize = recv(s,&buff[0], sizeof(buff)-1,0)) !=SOCKET_ERROR)
    {
        // ставим завершающий ноль в конце строки
        buff[nsize]=0;
 
        // выводим на экран
        printf("S=>C:%s",buff);
 
        // читаем пользовательский ввод с клавиатуры
        printf("S<=C:"); fgets(&buff[0],sizeof(buff)-1, stdin);
 
        // проверка на "quit"
        if (!strcmp(&buff[0],"quit\n"))
        {
            // Корректный выход
            printf("Exit...");
            closesocket(s);
            WSACleanup();
            return 0;
        }
 
        // передаем строку клиента серверу
        send(s,&buff[0],nsize,0);
    }
 
    closesocket(s); 
    WSACleanup();
    system("PAUSE");
    return 0;
}