First time using select(), maybe a basic question?
- by darkletter
Hello people,
i've been working for a few days with this server using select(). What it does, is that, i have two arrays of clients (one is "suppliers", and the other is "consumers"), and the mission of the server is to check whether the suppliers have something to send to the consumers, and in case affirmative, send it.
The second part of the server is that, when the consumers have received the suppliers' info, they send a confirmation message to the same suppliers that sent the info.
When a client connects, it gets recognized as "undefined", until it sends a message with the word "supplier" or "consumer" (in Spanish, as i'm from there), when the server puts it in the correct clients array.
Well, what the server does is not very important here. What's important is that, i'm doing both parts with two different "for" loops, and that's where i'm getting the problems. When the first user connects to the server (be it a supplier or a consumer), the server gets stuck in the first or second loop, instead of just continuing its execution. As it's the first time i'm using select(), i may be missing something. Could you guys give me any sort of help?
Thanks a lot in advance.
for(;;)
{
rset=allset;
nready=select(maxfd+1,&rset,NULL,NULL,NULL);
if (FD_ISSET(sockfd, &rset)){
clilen=sizeof(cliente);
if((connfd=accept(sockfd,(struct sockaddr *)&cliente,&clilen))<0) printf("Error");
IP=inet_ntoa(cliente.sin_addr);
for(i=0;i<COLA;i++){if(indef[i]<0){indef[i]=connfd;IPind[i]=IP;break;}}
FD_SET(connfd,&allset);
if(connfd > maxfd)
maxfd=connfd;
if(i>maxii) maxii=i;
if(--nready<=0) continue;
}// Fin ISSET(sockfd)
for(i=0;i<=maxii;i++){
if((sockfd1=indef[i])<0){ continue;} //!
if(FD_ISSET(sockfd1,&rset)){
if((n=read(sockfd1,comp,MAXLINE))==0){close(sockfd1);FD_CLR(sockfd1,&allset);indef[i]=-1;printf("Cliente indefinido desconectado \n");}
else{
comp[n]='\0';
if(strcmp(comp,"suministrador")==0){
for(j=0;j<=limite;j++){if(sumi[j]<0){IPsum[j]=IPind[i];sumi[j]=indef[i]; indef[i]=-1;if(j>maxis) {maxis=j;}break; } }
}
else if(strcmp(comp,"consumidor")==0){
for(o=0;j<=limite;j++){if(consum[o]<0){IPcons[o]=IPind[i];consum[o]=indef[i]; indef[o]=-1;if(o>maxic) {maxic=o;}break; }
}
}
if(--nready <=0)break;
}
}
}//fin bucle for maxii
for(i=0;i<=maxis;i++){
if((sockfd2=sumi[i])<0){continue;}
if(FD_ISSET(sockfd2,&rset)){
if((n=read(sockfd2,buffer2,MAXLINE))==0){close(sockfd2);FD_CLR(sockfd2,&allset);sumi[i]=-1;printf("Suministrador desconectado \n");}
else{
buffer2[n]='\0';
for(j=0;j<=maxic;j++){
if((sockfd3=consum[j])<0){ continue;}
else {strcpy(final,IPsum[i]);strcat(final,":");strcat(final,buffer2);write(sockfd3,final,sizeof(final));respuesta[i]=1;}
}
break; // ?
}
}
}//fin for maxis
for(i=miniic;i<=maxic;i++){
if((sockfd4=consum[i])<0){continue;}
if(FD_ISSET(sockfd4,&rset)){
if((n=read(sockfd4,buffer3,MAXLINE))==0){close(sockfd4);FD_CLR(sockfd4,&allset);consum[i]=-1;printf("Consumidor desconectado \n");}
else{
buffer3[n]='\0';
IP2=strtok(buffer3,":");
obj=strtok(NULL,":");
for(j=0;j<100;j++){
if((strcmp(IPsum[j],IP2)==0) && (respuesta[j]==1)) {write(sumi[j],obj,sizeof(obj)); miniic=i+1; respuesta[j]=0;
break;
}
}
}
}
}
