Method safeDispatch

code/common/src/PVRSocketUtils.cpp:109–125

}

void TCPTalker::safeDispatch(function<void()> hdl) {
    try {
        sktMtx.lock();
        if (_skt) {
            bool done = false;
            _skt->get_io_service().dispatch([&] {
                hdl();
                done = true;
            });
            while (!done)
                sleep_for(milliseconds(10));
        }
        sktMtx.unlock();
    } catch (exception &e) {
        PVR_DB_I("[TCPTalker::safeDispatch] Exception caught: " + string(e.what()));
    }
}

bool TCPTalker::send(PVR_MSG msgType, vector<uint8_t> data) {
    vector<uint8_t> buf = {'p', 'v', 'r', (uint8_t) msgType, 0, 0};