i/o multiplexing & thread 에서..

nonblocking 소켓입니다.
main thread에서 io_thread를 하나 생성하고,
io_thread에서 work_thread를 여러개 생성하였습니다.

io_thread는 select() 하고 데이타를 recv() 합니다.
그리고나서 놀고있는 work_thread를 찾아 recv한 데이타를 넘깁니다.

/* work thread */
struct {
    pthread_mutex_t mutex;
    pthread_cond_t cond;
    int ready;
    int sfd;                              /* 이벤트 발생한 소켓 */
    int status;                         /* 1 is running, 0 is sleep */
    char buff[MSG_BUFFER];
}WK_thread[MAXNTHREADS];

근데!!! 문제점은
io_read_thread 에서 select()를 잘 못합니다..(?) 무슨 말인고 하니.. 여러개의 client가 접속을 해도 하나의 client 소켓 event만 return 합니다. i/o multiplexing을 못한단 말이죠...

뭐가 문젠지 잘 모르겠습니당.. 왜 이런거죠~?

대충의 코드 구조입니다.

io_thread

        /*
        ** i/o multiplexing
        */
        select(....);

        /* packet read */
        if((ret_val = read_packetC(event_fd)) < 0) {
            /* disconnect work */
            .....
        }

        /* 휴면 스레드를 찾는다. */
        for(free_tid = 0; free_tid < MAXNTHREADS; free_tid++) {
            if(WK_thread[free_tid].status == 0) {
                memcpy(WK_thread[free_tid].buff, (user_buff +5), readed_len);

                packet_len = 0;
                readed_len = 0;
                memset(user_buff,  '\0', MSG_BUFFER);
                break;
            }
        }

        /*
        ** work thread를 깨운다.
        */
        pthread_mutex_lock(&(WK_thread[free_tid].mutex)); 
       
        /*
        ** event가 발생된 socket을 세팅한다.
        */
        WK_thread[free_tid].sfd = event_fd;

        if(WK_thread[free_tid].ready == 0) {
            pthread_cond_signal(&(WK_thread[free_tid].cond));
        }
        WK_thread[free_tid].ready = 1;


        /* thread full ~~~~~ */
        if(RD_WK_thread_count >= MAXNTHREADS) {
                ;
        }

        pthread_mutex_unlock(&(WK_thread[free_tid].mutex));