[C]fallimento connect su server multithread

[mr.and]

Salve,
sto implementando un'applicazione composta da un server multi threading ma ho incontrato un problema singolare, che magari qualcuno con più esperienza di me con i socket saprà a cosa può essere dovuto.
Il mio server è composto di un server principale che accetta connessioni da parte di client,dedicandogli un nuovo thread.Questo thread apre una nuova connessione su un nuovo socket aspettando che il client a sua volta vi si connetta tramite una connect.
Ho implementato il tutto e tutto funziona normalmente, ma solo per il primo thread creato:se subito dopo la morte del primo thread dedicato, ne viene creato un altro su richiesta di un nuovo client(connessosi al server principale), il tentativo di creare la nuova connessione fallisce,perchè la connect del client fallisce.
Perchè questo comportamento?i socket gli chiudo correttamente al termine del thread chiamando prima la shutdown e poi la close.
So che senza codice è un brancolare all buio, ma dato che il tutto è abbastanza lungo, speravo di poter evitare di pubblicare il papiro se qualcuno si fosse già imbattuto in un problema simile.

[oregon]

No ... un problema del genere e' dovuto ad errori logici nel tuo programma che, se non si vede ...

[mr.and]

Potrei restringere il campo ad una parte...non so magari, è un problema della funzione che crea il thread, o di gestione dei socket...dove potrebbe essere l'errore per giustificare un tale comportamento? ho notato che non lo fa sempre sul secondo thread,a volte anche il secondo va con successo, mentre mi si blocca sul terzo....mah....un comportamento piuttosto singolare, a quanto pare sbaglio qualcosa che lascia alla macchina la possibilità di comportarsi in diverso modo...

[oregon]

Comincia a mostrare la parte del codice che ascolta e crea il thread alla connessione ...

[mr.and]

In pratica questo è il server principale:

INT main(int argc, char* argv []){


/* AMBIENTE WINDOWS  */ 

   HANDLE ListaServer[MAX_SERV];
   HANDLE Console;
   DWORD ConsoleId;
   DWORD ServID[MAX_SERV];
   SOCKADDR_IN Client_addr;
   SOCKET listenSocket;
   SOCKET connessione;
   int id_serv,sin_size,i;
   LONG volatile n_serv;
   LONG volatile client[MAX_SERV];
   serv_arg* param;


/*inizializzazione libreria Socket*/

   WORD wVersionRequested = MAKEWORD(2,2);
   WSADATA wsaData;
   int wsastartup = WSAStartup(wVersionRequested, &wsaData);
   if (wsastartup != NO_ERROR) printf("Errore WSAStartup()\n");
   
   id_serv=0;
   for(i=0;i<MAX_SERV;i++) client[i]=0;


/*Inizializzazione connessione server*/

   ConnessioneServer("127.0.0.1",N_PORT,&listenSocket);
   
   printf("Mainserver in attesa di client..\n");

   while(1){
            connessione = accept(listenSocket, (struct sockaddr*)&Client_addr, &sin_size);
	    printf("Accettata Connessione con Client: %s su socket %d\n", inet_ntoa(Client_addr.sin_addr),connessione);
	    InterlockedIncrement(&n_serv);
            param=malloc(sizeof(serv_arg));
             for(i=0;i<MAX_SERV;i++) { if(client[i]==0){ InterlockedIncrement(&(client[i]));
                                                          break; }
             }
            (*param).nserv=&(client[i]);
            (*param).idServ=i;
            (*param).conn=connessione;
            (*param).clientAddr.sin_family = AF_INET;
            (*param).clientAddr.sin_addr.s_addr=Client_addr.sin_addr.s_addr;
            (*param).clientAddr.sin_port=Client_addr.sin_port;

            ListaServer[i]=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)server,param,0,&ServID[i]);

	    }

   shutdown(listenSocket,2);
   close(listenSocket);

   WSACleanup();

   return 0;

}

dove server e la struttura a cui punta param sono definite così:

DWORD WINAPI server(serv_arg* param);

typedef struct serv_arg{
  SOCKET conn;
  SOCKADDR_IN clientAddr;
  int idServ;
  LONG volatile* nserv;} serv_arg;

[oregon]

Mostra la ConnessioneServer ...

[mr.and]

E' vero,scusami....

int ConnessioneServer(char* addr,int port,SOCKET* listenSocket){
  
  SOCKADDR_IN Server_addr;
  SOCKADDR_IN Client_addr;
  int sin_size;
  
  *listenSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
  if (listenSocket < 0) { perror("ConnessioneServer,Errore socket");
                          ChiudiSocket(*listenSocket);
                          return -1; }
  
  Server_addr.sin_family = AF_INET;
  Server_addr.sin_addr.s_addr = inet_addr(addr);
  Server_addr.sin_port = htons(port);

  sin_size = sizeof(SOCKADDR_IN);
  
  if (bind(*listenSocket,(LPSOCKADDR)&Server_addr,sin_size) < 0){
     perror("ConnessioneServer,Errore bind");
     ChiudiSocket(*listenSocket);
     return -1; }
  
  if((listen(*listenSocket, MAX_SERV))<0) { perror("ConnessioneServer,Errore listen");
                                            ChiudiSocket(*listenSocket);
                                            return -1; }
  return 0;
  
}

[oregon]

Quanto vale MAX_SERV ?

[mr.and]

20

[XWolverineX]

Quanto è brutto vedere quel listensocket deferenziato così tante volte.
Alla fine è un numero intero, quindi passarlo per valore o riferimento non serve a niente. Ritornalo dalla funzione e controllalo se diverso da INVALID_SOCKET