Method createKernelAndAgents

Tests/UnitTests/src/iotest.cpp:103–152

}

void IOTest::createKernelAndAgents(const KernelBitset& options, int port)
{
    CPPUNIT_ASSERT(pKernel == NULL);
    
    if (options.test(EMBEDDED))
    {
        CPPUNIT_ASSERT(!remote);
        if (options.test(USE_CLIENT_THREAD))
        {
            pKernel = sml::Kernel::CreateKernelInCurrentThread(options.test(FULLY_OPTIMIZED), sml::Kernel::GetDefaultPort());
        }
        else
        {
            pKernel = sml::Kernel::CreateKernelInNewThread(sml::Kernel::GetDefaultPort());
        }
    }
    else
    {
        CPPUNIT_ASSERT(remote);
        pKernel = sml::Kernel::CreateRemoteConnection(true, 0, port);
    }
    
    CPPUNIT_ASSERT(pKernel != NULL);
    CPPUNIT_ASSERT_MESSAGE(pKernel->GetLastErrorDescription(), !pKernel->HadError());
    
    pKernel->SetAutoCommit(options.test(AUTO_COMMIT_ENABLED)) ;
    
    // Set this to true to give us lots of extra debug information on remote clients
    // (useful in a test app like this).
    // pKernel->SetTraceCommunications(true) ;
    
    CPPUNIT_ASSERT(std::string(pKernel->GetSoarKernelVersion()) == std::string(sml::sml_Names::kSoarVersionValue));
    
    // Report the number of agents (always 0 unless this is a remote connection to a CLI or some such)
    CPPUNIT_ASSERT(pKernel->GetNumberAgents() == 0);
    
    // NOTE: We don't delete the agent pointer.  It's owned by the kernel
    sml::Agent* pAgent = pKernel->CreateAgent("IOTest") ;
    CPPUNIT_ASSERT_MESSAGE(pKernel->GetLastErrorDescription(), !pKernel->HadError());
    CPPUNIT_ASSERT(pAgent != NULL);
    
    // a number of tests below depend on running full decision cycles.
    pAgent->ExecuteCommandLine("set-stop-phase --before --input") ;
    CPPUNIT_ASSERT_MESSAGE("set-stop-phase --before --input", pAgent->GetLastCommandLineResult());
    
    pAgent->ExecuteCommandLine("watch 0") ;
    pAgent->ExecuteCommandLine("waitsnc --on") ;
    
    CPPUNIT_ASSERT(pKernel->GetNumberAgents() == 1);
}

void IOTest::testInputLeak()
{