(C언어로 C++ 흉내내기 2) OOP-2

 

void ClientManager_Processing(ClientManager* cm){
    if(cm == NULL){ return; }
    // @ Initialize EmailReceiver processing
    if(pthread_create(&cm->er_t_id, NULL, EmailReceiver_Processing, (void*)(cm->er)) != 0){
        perror("(ClientManager) { Fail to create pthread EmailReceiver processing }");
        return;
    }
 
    while(1){
        int temp_sock = 0;
        struct sockaddr_in clnt_addr;
        cm->clnt_addr_size = sizeof(clnt_addr);
        ClientManager_Check_clnt(cm);
        temp_sock = accept(cm->serv_sock, (struct sockaddr*)&clnt_addr, &(cm->clnt_addr_size));
 
        // @ Initialize NameReceiver processing
        if(temp_sock == -1){
            perror("(ClientManager) { Fail to accept }");
            break;
        }
        else if(temp_sock == 0){
            printf("(ClientManager) { return 0  }");
            continue;
        }
        else{
            // @ Initialize a NameReceiver thread
            cm->empty = NameReceiver_Get_empty_thread(cm->nr);
            if(cm->empty == -1){
                continue;
            }
 
            cm->clnt_sock[cm->empty] = temp_sock;
            cm->nr_t_id[cm->empty] = 0;
            
            NameReceiver_Initialize_thread(cm->nr, cm->nr_t_id, cm->clnt_sock[cm->empty], &clnt_addr, cm->empty);
 
            if(pthread_create(&cm->nr_t_id[cm->empty], NULL, NameReceiver_Processing, (void*)(&cm->nr[cm->empty])) < 0){
                perror("(ClientManager) { Fail to create pthread NameReceiver processing }");
                break;
            }
            pthread_detach(cm->nr_t_id[cm->empty]);
            //printf("(ClientManager) [ %d Clients are connected ] \n", NameReceiver_Check_thread_Client(cm->nr));
        }
    }
}