Boost Asio UdpSocket

#include "boost_asio.h"
 
boost_asio::boost_asio(QObject *parent) :
    QThread(parent)
{
    imagethread = new imageThread();
 
    udpSocket = new ip::udp::socket(service);
    len = 0;
    connected = false;
 
 
 
    connect(this,SIGNAL(setArray(QByteArray)),imagethread,SLOT(getArr(QByteArray)));
    connect(imagethread,SIGNAL(finished()),this,SLOT(fin()));
 
}
 
void boost_asio::fin()
{
    qDebug() << "Поток обработки завершен";
}
 
 
void boost_asio::Init(string address,int port)
{
    imagethread->stopThread = false;
 
    imagethread->start();
 
    //Адресс отправки
    addr = ip::address::from_string(address);
 
    //Настройки точки отправки
    sender_ep = ip::udp::endpoint(addr,port);
 
    //Настройки приема, тип ip и порт
    ip::udp::endpoint res(ip::udp::v4(),4809);
 
    //Открывает сокет
        udpSocket->open(sender_ep.protocol());
 
        //Выставляем признак состояния сокета
        if(udpSocket->is_open())
            connected = true;
        else
            connected = false;
 
        //Сигнал состояния сокета в MainWindow
        emit status_connected(connected);
 
        //Биндим сокет с заданными ранее настройками
        udpSocket->bind(res);
 
        //    udpSocket->set_option(boost::asio::ip::udp::socket::reuse_address(true));
 
        //Увеличиваем буфер сокета
        ip::tcp::socket::receive_buffer_size sbs;
        sbs = 6144;
        udpSocket->set_option(sbs);
 
        char buf[1400];
        udpSocket->async_receive(buffer(buf, 1400), boost::bind(&boost_asio::read_handler, this,buf,_1,_2));
    this->start();
}
 
void boost_asio::run()
{
    if(service.stopped())
        service.reset();
    service.run();
}
 
void boost_asio::read_handler(char *ptr,const boost::system::error_code& ec, size_t bytes_transferred)
{
 
    if(bytes_transferred > 0){
 
        scaleImage(ptr,bytes_transferred);
    }
    char buf[1400];
    udpSocket->async_receive(buffer(buf, 1400), boost::bind(&boost_asio::read_handler, this,buf,_1,_2));
 
}
 
void boost_asio::Disconnect()
{
    imagethread->stopThread = true;
    imagethread->waitcon.wakeOne();
        service.stop();
    //    service.reset();
      udpSocket->close();
 
        if(!udpSocket->is_open())
    connected = false;
    emit status_connected(connected);
}
 
void boost_asio::scaleImage(char *ptr, size_t len)
{
    QByteArray tempDatImage;
    tempDatImage.append(ptr, len);
    //    {
    //        delete[] ptr;
    //    }
    emit setArray(tempDatImage);
}