Method TCPTalker

code/common/src/PVRSocketUtils.cpp:13–107

//  prefix -> 6 bytes

TCPTalker::TCPTalker(uint16_t port,
                     function<void(PVR_MSG, vector<uint8_t>)> recCb,
                     function<void(std::error_code)> errCb,
                     bool isServer,
                     string ip) {
    bool initted = false;
    PVR_DB_I("[TCPTalker::TCPTalker] Init'ed with p:" + to_string(port) +
             " isServer:" + to_string(isServer) + " ip:" + to_string(ip))

    thr = new std::thread([=, &initted] {
        try {
            io_service svc;
            tcp::socket skt(svc);
            _skt = &skt;
            tcp::acceptor acc(svc, {tcp::v4(), port});

            asio::error_code ec = asio::error::fault;
            auto errHdl = [&](const asio::error_code &err) { ec = err; };
            if (isServer) {   // talker is a server; Mobile device will be Announcing UDP + Will be
                              // Server
                if (ip.empty()) {
                    acc.async_accept(skt, errHdl);   // todo: simplify
                    PVR_DB_I("[TCPTalker::TCPTalker] Talker is Server and ip is Empty. Accepting "
                             "All connection...");
                } else {
                    acc.async_accept(skt, errHdl);   // todo: simplify
                    // skt.async_connect({ address::from_string(ip), port }, errHdl);
                    PVR_DB_I("[TCPTalker::TCPTalker] Talker is Server and Accepting connections "
                             "from ip:" +
                             ip + " & port:" + to_string(port) + "...");
                }
                initted = true;   // early unblock server
            } else   // talker is a client; Desktop will be Client will receive the Announcement +
                     // Will try to connect.
            {
                skt.async_connect({address::from_string(ip), port}, errHdl);
                PVR_DB_I("[TCPTalker::TCPTalker] Talker is Client and Connecting to ip:" + ip +
                         " & port:" + to_string(port) + "...");
            }
            svc.run();
            svc.reset();
            if (!isServer)
                initted = true;   // on server mode this goes out of scope

            if (ec.value() == 0) {
                IP = skt.remote_endpoint().address().to_string();

                const size_t bufsz = 256;
                string prefix = "pvr";
                uint8_t buf[bufsz];
                vector<uint8_t> stream;
                size_t msgLen = 0;

                function<void(const asio::error_code &, size_t)> handle = [&](const asio::error_code
                                                                                  & /*err*/,
                                                                              size_t len) {
                    // PVR_DB_I("[TCPTalker::TCPTalker] Revd some data... Interpreting...");
                    stream.insert(stream.end(), buf, buf + len);