Method wait_recv_task_result

Extensions/PilotOSMachine/TCPClient.h:293–390

	}

	bool wait_recv_task_result(std::string& recv_msg, const std::string &task_id)
	{
        PTraceInfo("recv_msg:" << recv_msg);
		m_recv_buf = std::make_unique<char []> (MAX_BUF_SIZE);//TCPMsg::_make_arry_shared<char>(MAX_BUF_SIZE);

		try
		{
			int recv_msg_body_size = 0;
			while (true)
			{
				memset(m_recv_buf.get(), 0, MAX_BUF_SIZE);
				recv_msg_body_size = full_recv(m_socket_id, m_recv_buf.get(), MAX_BUF_SIZE - 1, 0);
                if (recv_msg_body_size)
                {
                    JsonMsg::JsonParser parser;
                    if (parser.load_json(m_recv_buf.get()) && parser.has_member_string("taskId") && (parser.get_string("taskId") != task_id))
                    {
                        PTraceInfo("Wrong taskId: " << parser.get_string("taskId"));
                        return false;
                    }
                }
                PTraceInfo("tmp recv " << recv_msg_body_size << " B");

				if (recv_msg_body_size > 0)
				{
					TCPMsg::TcpMsgHead* p_msg_head = (TCPMsg::TcpMsgHead*)m_recv_buf.get();
					char* p_msg_body = (char*)(m_recv_buf.get()) + sizeof(TCPMsg::TcpMsgHead);
					
                    /* check msg type */ 
					switch ((TCPMsg::TcpMsgType)p_msg_head->m_type)
					{
					case TCPMsg::TcpMsgType::STATE_MSG:
					{
						m_task_status = string(p_msg_body, recv_msg_body_size);
                        PTraceInfo("tcp recv status: " << m_task_status << ", for task:" << m_task_id);
						const uint32_t status = std::stoul(m_task_status);
                        if ((status == ((uint32_t)(PilotQVM::TaskStatus::FAILED)))
                            || (status == ((uint32_t)(PilotQVM::TaskStatus::CANCELLED))))
                        {
                            PTraceError("Error: the status for task " << m_task_id << " is " << status);
                            //return false; /* 不退出循环，以接收具体错误信息 */
                        }
						continue;
					}
						break;

					case TCPMsg::TcpMsgType::RESULT_MSG:
					{
						stop_heart_thread();
						recv_msg.append(string(p_msg_body, recv_msg_body_size));
                        PTraceInfo(" tmp recv result size:" << recv_msg_body_size);
					}
						break;

					default:
                        PTraceError("Error: Undef msg type:" << p_msg_head->m_type);
						return false;
					}