Method doTest

Tests/UnitTests/src/multiagenttest.cpp:194–278

}

void MultiAgentTest::doTest()
{
    sml::Kernel* pKernel = sml::Kernel::CreateKernelInNewThread();
    CPPUNIT_ASSERT_MESSAGE(pKernel->GetLastErrorDescription(), !pKernel->HadError());
    
    // We'll require commits, just so we're testing that path
    pKernel->SetAutoCommit(false) ;
    
    // Comment this in if you need to debug the messages going back and forth.
    //pKernel->SetTraceCommunications(true) ;
    
    CPPUNIT_ASSERT(numberAgents < MAX_AGENTS);
    
    std::vector< std::string > names;
    std::vector< sml::Agent* > agents;
    std::vector< std::stringstream* > trace;
    std::vector< int > callbackPrint;
    
    // Create the agents
    for (int agentCounter = 0 ; agentCounter < numberAgents ; ++agentCounter)
    {
        std::stringstream name;
        name << "agent" << 1 + agentCounter;
        names.push_back(name.str());
        
        sml::Agent* pAgent   = pKernel->CreateAgent(name.str().c_str()) ;
        CPPUNIT_ASSERT(pAgent != NULL);
        CPPUNIT_ASSERT_MESSAGE(pKernel->GetLastErrorDescription(), !pKernel->HadError());
        
        agents.push_back(pAgent);
        
        std::stringstream path;
        // TODO: use boost filesystem
        CPPUNIT_ASSERT(pAgent->LoadProductions("test_agents/testmulti.soar"));
        createInput(pAgent, 0);
        
        // Collect the trace output from the run
        trace.push_back(new std::stringstream());
        callbackPrint.push_back(pAgent->RegisterForPrintEvent(sml::smlEVENT_PRINT, MultiAgentTest::MyPrintEventHandler, trace[agentCounter]));
    }
    
    pKernel->RegisterForUpdateEvent(sml::smlEVENT_AFTER_ALL_GENERATED_OUTPUT, MultiAgentTest::MyUpdateEventHandler, NULL) ;
    
    // Run for a first set of output, so we can see whether that worked
    pKernel->RunAllTilOutput() ;
    
    // Print out some information
    reportAgentStatus(pKernel, numberAgents, trace) ;
    
    // Now get serious about a decent run
    const int kFirstRun = 5 ;
    for (int i = 0 ; i < kFirstRun ; i++)
    {
        // Run for a bit
        pKernel->RunAllTilOutput() ;
    }
    
    reportAgentStatus(pKernel, numberAgents, trace) ;