Method SendMessageGetResponse

Core/ConnectionSML/src/sml_Connection.cpp:486–549

include include include "soar_instance.h" * @brief Send a message and get the response. * * @param pAnalysis This will be filled in with the analyzed response * @param pMsg The message to send * @returns True if got a reply and there were no errors. *************************************************************/

* @returns          True if got a reply and there were no errors.
*************************************************************/
bool Connection::SendMessageGetResponse(AnalyzeXML* pAnalysis, ElementXML* pMsg)
{
    // If the connection is already closed, don't do anything
    if (IsClosed())
    {
        return false ;
    }
    
    // Make sure only one thread is sending messages at a time
    // (This allows us to run a separate thread in clients polling for events even
    //  when the client is sleeping, but we don't want them both to be sending/receiving at the same time).
    soar_thread::Lock lock(&m_ClientMutex) ;
    
    // Send the command over.
    SendMsg(pMsg);
    
    // There was an error in the send, so we're done.
    if (HadError())
    {
        return false ;
    }
    
    // Get the response
    ElementXML* pResponse = GetResponse(pMsg) ;
    
    // These was an error in getting the response
    if (HadError())
    {
        return false ;
    }
    
    if (!pResponse)
    {
        // We failed to get a reply when one was expected
        SetError(Error::kFailedToGetResponse) ;
        return false ;
    }
    
    // Analyze the response and return the analysis
    pAnalysis->Analyze(pResponse) ;
    
#ifdef _DEBUG
    char* pMsgText = pResponse->GenerateXMLString(true) ;
    pResponse->DeleteString(pMsgText) ;
#endif
    
    delete pResponse ;
    
    // If the response is not SML, return false
    if (!pAnalysis->IsSML())
    {
        SetError(Error::kResponseIsNotSML) ;
        return false ;
    }
    
    // If we got an error, return false.
    if (pAnalysis->GetErrorTag())
    {