Сокет для получения udp пакетов с определенным портом

SOCKET DataReader::createdSocketUnicast()
{
    SOCKET udpSocket = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP);
 
    if (udpSocket == INVALID_SOCKET)
        closeSocket("Failed creating UDP DataSender socket", udpSocket);
 
    SOCKADDR_IN addr;
    memset(&addr, 0, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_port = htons(DATA_PORT);
    addr.sin_addr.s_addr = _localIP.toIPv4Address();
 
    BOOL opt = TRUE;
    if (setsockopt(udpSocket, SOL_SOCKET, SO_REUSEADDR, (char*)&opt, sizeof(opt)) == -1)
        return closeSocket("Set opt SO_REUSEADDR  failed with error", udpSocket);
 
    if (::bind(udpSocket, (SOCKADDR*)&addr, sizeof(addr)) != NO_ERROR)  // без :: компилятор берет функцию из стандартной библиотеки, а не winsock
        return closeSocket("UDP socket receiver bind  failed with error", udpSocket);
 
    u_long iMode = 1; //при iMode = 0 блок режим
    if (ioctlsocket(udpSocket, FIONBIO, &iMode) != NO_ERROR)
        return closeSocket("Set opt ioctsocket  failed with error", udpSocket);
 
    return udpSocket;
}

SOCKET socketUnicast = createdSocketUnicast();
    if (socketUnicast == INVALID_SOCKET)
    {
        closeSocket("Failed creating socketUnicast socket", socketUnicast);
        return;
    }
    while (isWorking)
    {
        memset(Buffer, 0, sizeof(Buffer));
 
        int countRecv = recvfrom(socketUnicast, Buffer, MAX_PACKET_SIZE, 0, (SOCKADDR*)&addrFrom, &addrFromSize);
        if (countRecv == SOCKET_ERROR)
            continue;
           ..........................................................
        }

//addr.sin_addr.s_addr = _localIP.toIPv4Address();
addr.sin_addr.s_addr = INADDR_ANY;

WSADATA wsadata;
    if (WSAStartup(MAKEWORD(2, 2), &wsadata) != NO_ERROR)
        emit messageToLog("Failed WSASTARTUP while creating UDP socket", "red");
 
    dataReader = new DataReader(&_localIP);
    connect(dataReader, &DataReader::messageToLog, this, &ProxyCore::sendMessageToLog);
    dataReader->start();

SOCKET broadcast = createdSocket();
    if (broadcast == INVALID_SOCKET)
    {
        closeSocket("Failed creating UDP socket", broadcast);
        return;
    }
 
    SOCKADDR_IN addrFrom = fillAddr(QHostAddress(), 0);                     // передаем нулевые параметры потому, что они будут заполнены сами при получении пакета
    int addrFromSize = sizeof(addrFrom);
    const SOCKADDR_IN addrSendUDP = fillAddr(_dataSender->_remoteIP, DATA_PORT);//заполняем куда полетит пакет
 
    char Buffer[MAX_PACKET_SIZE];                                           // сюда принимаем пакет
    char bufferSendUDP[MAX_PACKET_SIZE];                                    // сюда копируем пакет и отправляем
 
    while (isWorking)
    {
        memset(Buffer, 0, sizeof(Buffer));
        memset(bufferSendUDP, 0, sizeof(bufferSendUDP));
 
        int countRecv = recvfrom(broadcast, Buffer, MAX_PACKET_SIZE, 0, (SOCKADDR*)&addrFrom, &addrFromSize);
        if (countRecv == SOCKET_ERROR)
            continue;
 
        QHostAddress addBroad(addrFrom.sin_addr.s_addr);
        if ((_dataSender->_localIP.toIPv4Address() & info.mask.toIPv4Address()) != ((addBroad.toIPv4Address() & info.mask.toIPv4Address())))
            continue;
 
        // заполняем данные
        Payload* payloadHeaders = (Payload*)bufferSendUDP;
        memcpy(bufferSendUDP + sizeof(Payload), (char*)&Buffer, countRecv);
 
        // заполняем заголовки
        fillHeadersUDP(payloadHeaders);
 
        countRecv += sizeof(UDPHeader);
        //заполняем заголовок UDP
        payloadHeaders->udpHeader.dst_port = addrFrom.sin_port;  // порт получателя равен src_port из полученного сообщения  
        payloadHeaders->udpHeader.src_port = addrFrom.sin_port;  // порт отправителя равен src_port из полученного сообщения 
        payloadHeaders->udpHeader.length = _byteswap_ushort(countRecv);
        payloadHeaders->udpHeader.crc = 0;
 
        countRecv += sizeof(IPHeader);
        // заполняем заголовок IP
        payloadHeaders->ipHeader.iph_length = _byteswap_ushort(countRecv);
        payloadHeaders->ipHeader.iph_xsum = 0;
        payloadHeaders->ipHeader.iph_src = addrFrom.sin_addr.s_addr;
        countRecv += sizeof(ProxyHeader);
 
        // отправляем данные
        if (sendto(*_dataSender->data, (char*)bufferSendUDP, countRecv, 0, (SOCKADDR*)&addrSendUDP, sizeof(addrSendUDP)) == SOCKET_ERROR)
        {
            emit messageToLog("Failed to send from DiggerBroadcast", "red");
            continue;
        }
    }

SOCKET udpSocket = socket(AF_INET, SOCK_DGRAM, 0);
    if (udpSocket == INVALID_SOCKET)
    {
        closeSocket("Failed creating UDP socket in func", udpSocket);
        return;
    }
        
    SOCKADDR_IN addr;
    memset(&addr, 0, sizeof(addr));
    addr.sin_family = AF_INET;
    addr.sin_port = htons(PORT_DATA);
    addr.sin_addr.s_addr = INADDR_ANY;
 
    BOOL opt = TRUE;
    if (setsockopt(udpSocket, SOL_SOCKET, SO_REUSEADDR, (char*)&opt, sizeof(opt)))
    {
        closeSocket("Set opt SO_REUSEADDR failed", udpSocket);
        return;
    }
        
    if (::bind(udpSocket, (SOCKADDR*)&addr, sizeof(addr)) != NO_ERROR)  // без :: компилятор берет функцию из стандартной библиотеки, а не winsock
    {
        closeSocket("UDP socket receiver bind failed", udpSocket);
        return;
    }
        
    u_long iMode = 1; //при iMode = 0 блок режим
    if (ioctlsocket(udpSocket, FIONBIO, &iMode) != NO_ERROR)
    {
        closeSocket("Set opt ioctsocket failed", udpSocket);
        return;
    }    
 
    SOCKADDR_IN addrFrom = fillAddr(QHostAddress(), 0);           // передаем нулевые параметры потому, что они будут заполнены сами при получении пакета
    int addrFromSize = sizeof(addrFrom);
 
    char Buffer[MAX_PACKET_SIZE];
 
    while (isWorking)
    {
        memset(Buffer, 0, sizeof(Buffer));
 
        int countRecv = recvfrom(udpSocket, Buffer, MAX_PACKET_SIZE, 0, (SOCKADDR*)&addrFrom, &addrFromSize);
        if (countRecv == SOCKET_ERROR)
            continue;
               ........................................................

    SOCKET socketUnicast = createdSocketUnicast();
    if (socketUnicast == INVALID_SOCKET)
    {
        closeSocket("Failed creating socketUnicast socket", socketUnicast);
        return;
    }
    while (isWorking)
    {
        memset(Buffer, 0, sizeof(Buffer));
 
        int countRecv = recvfrom(socketUnicast, Buffer, MAX_PACKET_SIZE, 0, (SOCKADDR*)&addrFrom, &addrFromSize);
        if (countRecv == SOCKET_ERROR)
        {
            if (WSAGetLastError() != EWOULDBLOCK)
                std::cout << WSAGetLastError();
            continue;
           ..........................................................
        }