Создать клиент, принимающий данные с использованием сокетов

#include <winsock2.h>
#include <string.h>
#include <stdio.h>
#ifdef _MSC_VER
#pragma comment(lib, "ws2_32.lib")
#endif
#define BUFSIZE   512
 
 
class tcp_client {
private:
    SOCKET sock;
    HANDLE thd;
    BOOL   loop;
    void   (*pfn)(char*, int);
public:
    tcp_client(void):sock(INVALID_SOCKET), 
                     thd(NULL),
                     loop(TRUE), 
                     pfn(NULL) {}
    ~tcp_client(){
        this->close();
    }
    tcp_client(const tcp_client&);
    tcp_client& operator = (const tcp_client&);
public:
    
    int create(const char* hostname, u_short port, void (*pread)(char*, int)){
        int err;
        sock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
        if(sock == INVALID_SOCKET)
            return WSAGetLastError();
        
        sockaddr_in addr = {0}; 
        addr.sin_family      = AF_INET;
        addr.sin_port        = htons(port);
        addr.sin_addr.s_addr = inet_addr(hostname);
 
        if(addr.sin_addr.s_addr == INADDR_NONE){
            hostent* host = gethostbyname(hostname);
            if(host == NULL) {
                err = WSAGetLastError();
                this->close();
                return err;
            }
            memcpy(&addr.sin_addr, host->h_addr_list[0], host->h_length);
        }
 
        err = connect(sock, (const sockaddr*)&addr, sizeof(addr));
        if(err == SOCKET_ERROR) {
            err = WSAGetLastError();
            this->close();
            return err;
        }
        
        loop = TRUE;
        pfn = pread;
        thd = CreateThread(NULL, 0, thread_wait, this, 0, NULL);
        if(thd == NULL){
            err = (int)GetLastError();
            this->close();
            return err;
        }
        return 0;
    }
 
    int write(const char* buf, int len, int flags = 0){
        int ret, num = 0;
        while(len > 0){
            ret = send(sock, buf + num, len, flags);
            if(ret == SOCKET_ERROR)
                return WSAGetLastError();
            len -= ret;
            num += ret;
        }
        return 0;
    }
    
    void close(void){
        loop = FALSE;
        if(sock != INVALID_SOCKET)
            closesocket(sock);
        sock = INVALID_SOCKET;
 
        if(thd != NULL){
            WaitForSingleObject(thd, INFINITE);
            CloseHandle(thd);
        }
        thd = NULL;
    }
 
private:
 
    static DWORD WINAPI thread_wait(LPVOID arg){
        int  ret;
        char buf[BUFSIZE];
        tcp_client* ptr = (tcp_client*)arg;
 
        while(ptr->loop){
            ret = recv(ptr->sock, buf, BUFSIZE - 1, 0);
            if(ret > 0){
                buf[ret] = '\0';
                (*ptr->pfn)(buf, ret);
            } else if(ret <= 0){
                ptr->loop = FALSE;
                break;
            }
        }
        return 0;
    }
};
 
 
//принятие данных
void onRead(char* buf, int len){
    printf("recv data: %d\n", len);
    puts(buf);
}
 
 
int main(void){
    WSADATA ws = {0};
    if(WSAStartup(MAKEWORD(2, 2), &ws) != 0)
        return 1;
 
    char host[]  = "localhost";
    u_short port = 7777;
 
    tcp_client client;
    int ret = client.create(host, port, onRead);
    if(! ret){
        
        char buf[256];
        while(1){
            printf("Enter to server: ");
            fgets(buf, sizeof(buf), stdin);
            fflush(stdin);
 
            //для выхода команда exit
            if(! strncmp(buf, "exit", 4))
                break;
    
            ret = client.write(buf, strlen(buf));
            if(ret != 0){
                fprintf(stderr, "error code: %d\n", ret);
                break;
            }
        }
        client.close();
    } else 
        fprintf(stderr, "error code: %d\n", ret);
 
    WSACleanup();
    return 0;
}