0

マルチスレッドサーバーを作成していますが、これをデバッグしようとしましたが、何らかの理由で、メインの下部にある pthread_create() によって呼び出されるクライアントスレッドに実際には入りません。pthread_create() が失敗する理由は何ですか?

また、サーバーとクライアント間の主な通信として、構造体をクライアントに送信し、クライアントが構造体をサーバーに送り返すのが良い考えかどうか疑問に思っていましたか? または send() と recv() を実装するより良い方法ですか?

int main(int argc, char* argv[])
{
    int fdServer;
    int accept_fd;
    int optVal = 1;
    struct sockaddr_in fromAddr;
    struct sockaddr_in serverAddr;
    struct pollfd* pServerPollFd;
    pthread_t threadId;
    socklen_t fromAddrSize;

    /*
     * Check user input and assign values
     */
    if(argc != 4)
        errorServer(WRONG_CLI);
    char* greeting = calloc(100,sizeof(char*));
    char* file_name = calloc(100,sizeof(char*));
    greeting = argv[2];
    file_name = argv[3];

    /*
     * Check pthread_key_create != 0 -> ERROR
     */
    if(pthread_key_create(&threadSpecificKey, dataDestructor))
        errorServer(SYSTEM_ERROR);
    int port_num = atoi(argv[1]);
    if(!((port_num <= 65535)&&(1<=port_num)))
        errorServer(INVALID_PORT);

    /*
     * Set up the server socket
     */
    fdServer = socket(AF_INET, SOCK_STREAM, 0);
    if(fdServer < 0)
        errorServer(SYSTEM_ERROR);
    if(setsockopt(fdServer, SOL_SOCKET, SO_REUSEADDR, &optVal, sizeof(int)) < 0)
        errorServer(SYSTEM_ERROR);
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_port = htons(port_num);
    serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);
    if(bind(fdServer, (struct sockaddr*)&serverAddr, sizeof(struct sockaddr_in)) < 0)
        errorServer(PORT_ERROR);

    /*
     * Setup poll pool
     */
    pMessageBuffer = fifo_buffer_create(-1);
    poll_pool* pPool = poll_pool_create(MAX_CONNECTIONS + 1);
    pServerPollFd = poll_pool_allocate(pPool, fdServer);
    pServerPollFd->events |= POLLIN;
    int flags = fcntl(fdServer, F_GETFL);// Get the file access mode and the file status flags;
    if(fcntl(fdServer, F_SETFL, flags | O_NONBLOCK) == -1)// Set the file descriptor flags to the value specified by 3rd arg.
            errorServer(SYSTEM_ERROR);
    if(listen(fdServer, 4) != 0)//Allow only 4 connections to the server
            errorServer(SYSTEM_ERROR);




    while(1) {

            fromAddrSize = sizeof(struct sockaddr_in);
        /* Block, waiting for a connection request to come in and accept it.
         * fromAddr structure will get populated with the address of the client
         */
            while((accept_fd = accept(fdServer, (struct sockaddr*)&fromAddr,  &fromAddrSize)) != -1){
                printf("Someone connected \n");

            client_connection *pClientConnection = client_connection_create(accept_fd);
            client_details *pClientDetails = client_details_create();
            client_session *pClientSession = client_session_create(pClientConnection,pClientDetails);

            pthread_mutex_lock(&game_state_mutex);
            //SEARCH THE LINKEDLIST FOR THE GAME NAME - IF FALSE CREATE NEW LINKED ELEMENT
            C_lst requestedGame;
            clst_init(&requestedGame,NULL);
            clst_insert_next(&requestedGame,NULL,pClientSession);

            pthread_mutex_unlock(&game_state_mutex);
            write(accept_fd, greeting, strlen(greeting));



        /* Start a thread to deal with client communication - pass the
         * connected file descriptor as the last argument.
         */
            pthread_create(&threadId, NULL, client_thread, (void*)pClientSession);
            pthread_detach(threadId);
            }

    }
    free(greeting);
    free(file_name);
    return 0;
}

これが client_thread の始まりです

void * client_thread(void* arg)
    {
    ssize_t numBytesRead;
    char buffer[MAXBUFFER];
    client_session* pClientSession = (client_session*)arg;

    if(pthread_setspecific(threadSpecificKey, pClientSession))
        errorServer(SYSTEM_ERROR);
/* below read fails because of the nonblocking fdServer from fnctl*/
 while((numBytesRead = read(fd,buffer,MAXBUFFER))>0){ 
    //loop code here
   }
4

1 に答える 1

1

pthread_create の戻り値をチェックせず、対応するエラー メッセージを出力しないのはなぜですか?

s = pthread_create(...);
if (s != 0) {
    errno = s;
    perror("pthread_create");
    exit(EXIT_FAILURE);
}

ソース: pthread_create(3)

アップデート。また、ソケットの設定については、すべて手動で行う代わりに getaddrinfo(3) を試すことができます: http://www.beej.us/guide/bgnet/output/html/multipage/syscalls.html#getaddrinfo

UPD 2.「送信構造体」とはどういう意味ですか?

于 2013-10-24T10:19:44.750 に答える