Общение между потоками с разными сокетами

#include "stdafx.h"
#include <winsock2.h>
#include <iostream>
#include <stdio.h>
#include <stdlib.h>
#pragma comment(lib,"Wsock32.lib")
using namespace std;
 
// макрос для печати количества активных
// пользователей 
#define PRINTNUSERS if (nclients)\
cout << nclients << " user on-line" << endl;\
else cout << "No User on line" << endl;
 
// прототип функции, обслуживающий
// подключившихся пользователей
DWORD WINAPI SexToClient(LPVOID client_socket);
 
//количество активных пользователей 
int nclients = 0;
 
int main(int argc, char ** argv)
{
    char buf[255], res[100], b[255], *Res;
 
    std::cout << "Server is initializing ...";
    //инициализация библиотеки сокетов
    WORD wVersionRequested;
    WSADATA wsaData;
    wVersionRequested = MAKEWORD(2, 2);
    WSAStartup( wVersionRequested, &wsaData );
 
    //создаем потоковый TCP сокет
    SOCKET s = socket(AF_INET, SOCK_STREAM, 0);
 
    struct sockaddr_in local;
    local.sin_family      = AF_INET;
    local.sin_port        = htons(1280);
    local.sin_addr.s_addr = htonl(INADDR_ANY);
 
    //связываем сокет с адресом
    int c = bind( s, (struct sockaddr*)&local, sizeof(local) );
 
    //помещаем сокет в состояние прослушивания
    int r = listen(s,5);
 
    SOCKET s2;
    //структура определяет удаленный адрес,
    // с которым соединяется сокет
    sockaddr_in remote_addr;
    int size  = sizeof(remote_addr);
    //цикл извлечения запросов на подключение из очереди
    while(s2 = accept( s, (struct sockaddr*)&remote_addr, &size))
    {
        nclients++;
        hostent *hst;
        hst=gethostbyaddr((char *)
            &remote_addr.sin_addr.s_addr,4,AF_INET);
        cout << hst->h_name << inet_ntoa(remote_addr.sin_addr) << "new connect" << endl;
        PRINTNUSERS
            // Вызов нового потока для обслужвания клиента
        DWORD thID;
        CreateThread(NULL,NULL,SexToClient,&s2,NULL,&thID);
 
    }
    
    return 0;
}
 
//функция создается в отдельном потоке и обслуживает очередного клиента независимо
 
DWORD WINAPI SexToClient(LPVOID c_s)
{
    SOCKET my_s;
    my_s=((SOCKET *) c_s)[0];
    char buff[20*1024];
    char b[255];
 
    
        //принимаем данные - отправляем данные
    while ( recv( my_s, b, sizeof(b), 0) != SOCKET_ERROR ) {
        cout << b << endl;
        
        send(my_s,b,sizeof(b),0);
    }
 
    //если мы здесь, клиент дисконнектед
    nclients--;
    cout<<"disconnect" << endl;
    // закрываем сокет
    closesocket(my_s);
    return 0;
}

struct conn {
    char * client_name;
    SOCKET client_socket;
};
 
map<int, conn> conns;
 
connection = new conn;
connection-> client_name="client x";
connection-> client_socket = my_socket;
 
conns[0] = connection;

conns.insert( std::make_pair( my_socket, *connection ) )

cout << "элемент => " << conns.find(my_s)->second.client_name << endl;

hostent *hst;
        hst=gethostbyaddr((char *)
            &remote_addr.sin_addr.s_addr,4,AF_INET);

cout << "элемент => " << conns.find(my_s)->second.client_name << endl;

map<int, conn>::const_iterator itr;
 
            for(itr = conns.begin(); itr != conns.end(); ++itr){
                cout << "Key: "  << (*itr).second.client_name;
            }

//получаем адрес
    SOCKADDR peer;
    int peerlen = sizeof(peer);
    
    if (0 == getpeername(my_s, &peer, &peerlen))
    {
      printf("\nConnect from %s:%i", 
        inet_ntoa(((SOCKADDR_IN *)&peer)->sin_addr), 
        ntohs(((SOCKADDR_IN *)&peer)->sin_port));
    }
    cout << endl;
    //получаем имя хоста
    hostent *hst;
        hst=gethostbyaddr((char *)
            &peer,4,AF_INET);
        cout << hst->h_name << endl;

map<int, conn>::const_iterator itr;
        for(itr = conns.begin(); itr != conns.end(); ++itr){
            send((*itr).second.client_socket,b,sizeof(b),0);
        }

                try
                  {
                    send(my_s,b,sizeof(b),0);
                  }
                  catch(...)
                  {
                    cout << "error:" << endl;
                  }

map<int, conn> conns;
int main(int argc, char ** argv)
......................

if((*itr).first != my_s )

try
                  {
                    send(my_s,b,sizeof(b),0);
                  }
                  catch(...)
                  {
                    cout << "error:" << endl;
                  }

#include "stdafx.h"
#include <winsock2.h>
#include <iostream>
#include <stdlib.h>
#pragma comment(lib,"Wsock32.lib")
using namespace std;
 
int main(int argc, char ** argv)
{
    WORD wVersionRequested;
    WSADATA wsaData;
    wVersionRequested = MAKEWORD(2, 2);
 
    WSAStartup( wVersionRequested, &wsaData );
 
 
    //создаем потоковый(sock_stream) сокет
    //Нулевое значение - по умолчанию: TCP - для потоковых сокетов
    SOCKET s = socket(AF_INET,SOCK_STREAM,0);
 
    struct sockaddr_in peer;
    //семейство используемых протоколов. Для Интернет - приложений - AF_INET.
    peer.sin_family = AF_INET;
    peer.sin_port   = htons(1280);
    // т.к. клиент и сервер на одном компьютере, пишем адрес 127.0.0.1
    peer.sin_addr.s_addr = inet_addr("127.0.0.1");
    HOSTENT *hst;
    
    //посылаем запрос на открытие соединения
    connect(s,(struct sockaddr*) &peer,sizeof(peer));
 
    char buf[255],b[255];
    
    while(true) {
        std::cout << "Enter the string, please" << std::endl;
        std::cin.getline(buf, 100, '\n');
        //посылаем запрос
        send(s, buf,sizeof(buf), 0);
        //принимаем данные
        if (recv(s, b,sizeof(b), 0) != 0) {
            //Удаление ненужных символов в конце строки
            b[strlen(b)]='\0';
            std::cout << "RESULT: ";
            std::cout << b << std::endl;
            std::cout << std::endl;
        }
    }
    closesocket(s);
    WSACleanup();
 
    system("PAUSE");
    return 0;
}