Функция recv не разблокируется после отправки сообщения в канал

typedef list<player *> PL;
class gameplay
{
private:
    int gType;
    PL players;
    SOCKET clientSocket;
    SOCKET serverSocket;
    consoleLine *message;
 
    HANDLE ev1;
    bool initWSA();
    void createServer();
    void createClient();
public:
    virtual void playGamePvP() = 0;
    virtual void playGamePvC() = 0;
    gameplay(player *, player *);
    PL *getPlayers();
    int getGType();
    virtual ~gameplay();
    void startServer(player *);
    void startClient(player *);
    sockType createSockType(player *);
    consoleLine *myMessage();
    SOCKET getServSock();
    SOCKET getClieSock();
    void setServSock(const SOCKET &);
    void setClieSock(const SOCKET &);
    HANDLE getEv1() { return ev1; }
    void setEv1() { SetEvent(ev1); }
 
    string recieveCMD();
 
    int sendCMD(const string &);
};

void gameplay::createClient() {
    
    SOCKET cliSock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    
    if (cliSock == SOCKET_ERROR)
    {
        myMessage()->printLine("Unable to create socket\n");
        WSACleanup();
        Sleep(2000);
        exit(-1);
    }
 
    SOCKADDR_IN destAddr;
    destAddr.sin_family = AF_INET;
    destAddr.sin_port = htons(PORT);
    destAddr.sin_addr.S_un.S_addr = inet_addr(SERVERADDR);
 
    if (connect(cliSock, (SOCKADDR *)&destAddr, sizeof(destAddr)) == 0) {
        cout << "Connect to " << SERVERADDR << " a connection SUCCESS" << endl;
    } else {
        cout << "Connect to " << SERVERADDR << " connection LOST" << endl;
    }
 
    setClieSock(cliSock);
    setServSock(NULL);
}

void gameplay::createServer() {
    SOCKET servSock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
    if (serverSocket == SOCKET_ERROR)
    {
        cout << "Unable to create socket" << endl;
        WSACleanup();
        Sleep(2000);
        exit(-1);
    }
    
    SOCKADDR_IN servInfo;
    servInfo.sin_family = AF_INET;
    servInfo.sin_port = htons(PORT);
    servInfo.sin_addr.s_addr = inet_addr(SERVERADDR);
 
    if (::bind(servSock, (LPSOCKADDR)&servInfo, sizeof(servInfo)) != 0) {
        cout << "Unable to bind socket" << endl;
        WSACleanup();
        Sleep(2000);
        exit(-1);
    }
 
    if (listen(servSock, MAXPLAYERSCONN) != 0) {
        cout << "Unable to connection" << endl;
        WSACleanup();
        Sleep(2000);
        exit(-1);
    }
 
    SOCKET cliSock;
    SOCKADDR_IN cliInfo;
    int len = sizeof(cliInfo);
    cliSock = accept(servSock, (SOCKADDR *)&cliInfo, &len);
    setServSock(servSock);
    setClieSock(cliSock);
}

string gameplay::recieveCMD() {
    char data_size[4];
    int sz;
    if ((sz = recv(clientSocket, data_size, 4, 0)) <= 0) {
        return "ERR";
    }
    int size = 0;
    size |= (unsigned char)data_size[0] << 24;
    size |= (unsigned char)data_size[1] << 16;
    size |= (unsigned char)data_size[2] << 8;
    size |= (unsigned char)data_size[3] << 0;
    size = ntohl(size);
    char *buf = new char[size + 1];
    int result = recv(clientSocket, buf, size, 0);
    string str;
    if (result > 0) {
        str = string(buf, result);
    }
    delete buf;
    return str;
}
 
int gameplay::sendCMD(const string &str) {
    int size = htonl(str.size());
    char data_size[4];
    data_size[0] = (size & 0xff000000) >> 24;
    data_size[1] = (size & 0x00ff0000) >> 16;
    data_size[2] = (size & 0x0000ff00) >> 8;
    data_size[3] = (size & 0x000000ff) >> 0;
    int sz;
    if ((sz = send(clientSocket, data_size, 4, 0)) <= 0) {
        return -1;
    }
    sz = send(clientSocket, str.c_str(), str.size(), 0);
    return sz;
}

void gameplay::startClient(player *pl) {
    WaitForSingleObject(getEv1(), INFINITE); //ожидает когда будет создан сервер
    cout << recieveCMD() << endl;
    while (1);
}
 
void gameplay::startServer(player *pl) {
    createSockType(pl);
    setEv1(); //сервер создан, разблокировать поток клиента
    sendCMD("HELLO");
    while (1);
}