Programming

    
if ((sockfd = socket(PF_INET, SOCK_STREAM, 0)) == -1) {
        perror("socket");
        exit(1);
    }

    printf(">>>client socket = %d   master ip=%s\n", sockfd, master_ip);
    setnonblocking(sockfd);

    bzero(&serv_addr, sizeof(serv_addr));
    serv_addr.sin_family = PF_INET;
    serv_addr.sin_port = htons(PORT);
    inet_aton(master_ip, &serv_addr.sin_addr);

    ret=connect(sockfd, (struct sockaddr *) &serv_addr, sizeof(struct sockaddr));
    if(ret <0 ) {
        if(errno!=EINPROGRESS) {
            ret = lustre_event_add(sockfd, EPOLLIN | EPOLLET,
                    lustre_sendmsg_event_handler, (void *)NULL);
            if (ret) {
                fprintf(stderr, "lustre_event_add failed.\n");
                return;
            }
        }
        else
            sockfd=ret;
        perror("connect");
    }