Programming

main()
{       
    .......
 
    while(1==1)
                {
                        channel=srv_accept(sockfd,(struct sockaddr *)&tcp_cli_addr,&length);
                        if(channel<0)
                        {
                                //cout<<"channel ="<<channel<<" retry srv_accept ...."<<endl;
                                continue;
                        }
                        num=-1; 
                       // find the nonused pthread number.
                        for(int i=0;i<MAX_REPORT_NUM;i++)
                                {       
                                        if(pth_struct[i].flag<0)
                                        {       
                                                num=i;
                                                break;
                                        }
                                }
                        printf("num is %d \n",num);
                        for(int i=0;i<MAX_REPORT_NUM;i++)
                                {       
                                        printf("....pos=%d flag=%d ......\n",i,pth_struct[i].flag);
                                }
                        if(num<0)
                        {       
                                Tcp_close(channel);
                                continue;
                        }
                        pthch[num].channel=channel;
                        pthch[num].pos=num;
                        pth_struct[num].flag=1;
                         
                       pthread_create(&pth_struct[num].pthread_no,&attr,(pthread_startroutine_t)channel_handler,

(pthread_addr_t *)&pthch[num]);
        }

}

int  channel_handler(struct  pthname_channel *recv_s=NULL)// handling the tcp message.
{
      .......
       while(1==1)
        {
                ret=Tcp_read(recv_s->channel,(char *)&ptr,sizeof(struct  MESS_BLOCK));
                if(ret<=0)
                {       
                        printf("@@@@@@@@@@@@ ------ Tcp_read err : ---------- @@@@@@@@@@@@@  \n");
                        fflush(stdout);
                        Tcp_close(recv_s->channel);
                        pth_struct[recv_s->pos].flag=-1;
                        
                        tid = pthread_self();
                        pthread_detach((pthread_t *)&tid);
                        pthread_exit(0);
                        break;
                }
            // processing packets .
}