Сокет сервера для нескольких клиентов без потоков? - C++ - Ответ 6314481

#include <cstdlib>
#include <iostream>
#include <string>
#include <sstream>
#include <signal.h>
#include <io.h>
 
#pragma comment(lib, "Ws2_32.lib")
 
#include <winsock2.h>
#include <windows.h>
 
using namespace std;
 
int nclients =0; //ñ÷åò÷èê êëèåíòîâ
struct icmp_header 
{
unsigned char type; // òèï ICMP- ïàêåòà
unsigned char code; // êîä ICMP- ïàêåòà 
unsigned short crc ; // êîíòðîëüíàÿ ñóììà 
unsigned long orig_timestamp; // äîïîëíèòåëüíûå ïîëÿ 
unsigned long recv_timestamp; // óòî÷íÿþùèé òèï
unsigned long trns_timestamp; //ICMP-ïàêåòà
};
struct ip_header
{
unsigned char version; // íîìåð âåðñèè ïðîòîêîëà 
unsigned char tos; // òèï ñåðâèñà 
unsigned short length; // îáùàÿ äëèíà ïàêåòà 
unsigned short id ; // èäåíòèôèêàòîð ïàêåòà
unsigned short flags; // ôëàãè 
unsigned char ttl ; // Âðåìÿ æèçíè ïàêåòà 
unsigned char proto; // Ïðîòîêîë âåðõíåãî óðîâíÿ 
unsigned short crc; // CRC çàãîëîâêà 
unsigned int src_addr; // IP- àäðåñ îòïðàâèòåëÿ 
unsigned int dst_addr; // IP- àäðåñ ïîëó÷àòåëÿ 
}; 
//ïîäñ÷åò êîíòðëüíîé ñóììû
unsigned short rs_crc (unsigned short * buffer, int length)
{ 
unsigned long crc = 0;
// Âû÷èñëåíèå CRC 
while (length > 1)
 { 
 crc += *buffer++; 
 length -= sizeof (unsigned short); 
 } 
if (length) crc += *(unsigned char*) buffer;
// Çàêîí÷èòü âû÷èñëåíèÿ 
crc = (crc >> 16) + (crc & 0xffff);
crc += (crc >> 16);
//Ñìåùåíèå CRC , åñëè íåîáõîäèìî
if (1) crc = crc << 1; 
// Âîçâðàùàåì èíâåðòèðîâàííîå çíà÷åíèå 
return (unsigned short)(~crc); 
} 
 
int main(int argc, char *argv[])
{
    struct ip_header iph;
    struct icmp_header icmph;
    icmph.type = 8; // òèï ICMP- ïàêåòà
    icmph.code= 0; // êîä ICMP- ïàêåòà 
    icmph.crc=0; // êîíòðîëüíàÿ ñóììà 
    icmph.orig_timestamp; // äîïîëíèòåëüíûå ïîëÿ 
    icmph.recv_timestamp; // óòî÷íÿþùèé òèï
    icmph.trns_timestamp; //ICMP-ïàêåòà
    iph.version=0x4; // íîìåð âåðñèè ïðîòîêîëà 
   iph.tos= 0; // òèï ñåðâèñà (íîðìàëüíûé)
   iph.length= 10; // îáùàÿ äëèíà ïàêåòà 
   iph.id= htonl(54321) ; // èäåíòèôèêàòîð ïàêåòà
   iph.flags= htons(0); // ôëàãè 
   iph.ttl=255 ; // Âðåìÿ æèçíè ïàêåòà 
   iph.proto = IPPROTO_ICMP; // Ïðîòîêîë âåðõíåãî óðîâíÿ 
   iph.crc=0; // CRC çàãîëîâêà 
  SOCKET s, s_new, client_socket[30], sd;// nieaou aey na?aa?a
   int max_clients=30;
    //Eieoeaeecaoey aeaeeioaee WinSock
    WSADATA wsaData;
        int errcod;
        errcod = WSAStartup(MAKEWORD(2, 2), &wsaData);
            if(errcod!=0)
            {
             cout<<"WinSock not found!";
             return 0;
            }
    //set of socket descriptors
    fd_set readfds;
    //initialise all client_socket[] to 0 so not checked
    for (int i = 0; i < max_clients; i++)
    {
        client_socket[i] = 0;
    }
    
    s = socket (AF_INET,SOCK_RAW, IPPROTO_ICMP);
    if(s == INVALID_SOCKET)
    {
        cout<<"Error create socket";
    }
    else cout<<"Create socket succesfull";
    
    int opt = TRUE;
    if( setsockopt(s, SOL_SOCKET, SO_REUSEADDR, (char *)&opt, sizeof(opt)) < 0 )
    {
        perror("setsockopt");
        exit(EXIT_FAILURE);
    }
    struct sockaddr_in server, client_addr;
    memset ((char *)&server, '\0', sizeof(server));
    server.sin_family = AF_INET;
    server.sin_addr.s_addr = inet_addr("192.168.1.107");
    server.sin_port = 0;
    bind (s, (struct sockaddr*)&server, sizeof(server));
    listen (s, 3);
    //one soidinie proxodit
  int addrlen = sizeof(server);
  cout<<"Waiting";
  while(TRUE)
    {
        //clear the socket set
        FD_ZERO(&readfds);
  
        //add master socket to set
        FD_SET(s, &readfds);
        int max_sd = s;
         
        //add child sockets to set
        for ( int i = 0 ; i < max_clients ; i++)
        {
            //socket descriptor
            sd = client_socket[i];
             
            //if valid socket descriptor then add to read list
            if(sd > 0)
                FD_SET( sd , &readfds);
             
            //highest file descriptor number, need it for the select function
            if(sd > max_sd)
                max_sd = sd;
        }
  
        //wait for an activity on one of the sockets , timeout is NULL , so wait indefinitely
        int activity = select( max_sd + 1 , &readfds , NULL , NULL , NULL);
    
        if ((activity < 0) && (errno!=EINTR))
        {
            cout<<"select error";
        }
        if (FD_ISSET(s, &readfds))
        {
            if ((s_new = accept(s, (struct sockaddr *)&server, &addrlen))<0)
            {
                perror("accept");
                exit(EXIT_FAILURE);
            }
            cout<<endl;
            cout<<"New connection , socket fd is %d , ip is : %s , port : %d \n";
            cout<< s_new;
            cout<<inet_ntoa(server.sin_addr);
            cout<<ntohs(server.sin_port);
            //add new socket to array of sockets
            for (int i = 0; i < max_clients; i++)
            {
                //if position is empty
                if( client_socket[i] == 0 )
                {
                    client_socket[i] = s_new;
                    cout<<endl;
                    cout<<"Adding to list of sockets as %d\n";
                    cout<< i;
                     
                    break;
                }
            }
        }
   //int client_addr_size = sizeof(client_addr);
   //s_new = accept(s,(sockaddr*)&client_addr, &client_addr_size); 
   /*cout<<endl;
   cout<<"Ip client   ";
   cout<<inet_ntoa(client_addr.sin_addr)<<endl;*/
    system("PAUSE");
    return EXIT_SUCCESS;
}
}